เรื่องราวก็เป็นเช่นนี้ ฉันมีนายหน้าคาฟคาและวัตถุเฉพาะ (ซึ่งฉัน jsonify ส่งผ่านหัวข้อของฉัน) ซึ่งมี ID ที่ฉันต้องการใช้เป็นกุญแจ ขณะนี้ฉันกำลังใช้การกำหนดค่า 'partitionKeyExtractorClass' เพื่อตั้งค่าคลาสที่จะแยก ID และส่งคืนเป็นคีย์...

ฉันกำลังพยายามสร้างตัวอย่างการทำงานกับผู้ผลิตข้อความ avro, kafka และ avro Consumer โดยใช้ spring boot, รีจิสทรีสคีมาสตรีมคลาวด์ของ spring cloud, kafka binder ข้อผิดพลาดต่อไปนี้เกิดขึ้นเมื่อใช้งานข้อความ: ข้อผิดพลาด 7059 --- [afka-listener-1]...

ตามหัวข้อนี้: Kafka Spring Integration: Headers not มาสำหรับผู้บริโภคคาฟคา - นี่ไม่ใช่การสนับสนุนส่วนหัวสำหรับคาฟคา แต่ เอกสารประกอบ พูดว่า: spring.cloud.stream.kafka.binder.headers รายการส่วนหัวแบบกำหนดเองที่จะถูกส่งโดย Binder...