ฉันกำลังพยายามสร้างตัวอย่างการทำงานกับผู้ผลิตข้อความ 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...

ฉันใช้ Spring Kafka ครั้งแรกและฉันไม่สามารถใช้เมธอด Acknowledgement.acknowledge() สำหรับการคอมมิตด้วยตนเองในโค้ดผู้บริโภคของฉันได้ โปรดแจ้งให้เราทราบหากมีสิ่งใดขาดหายไปในการกำหนดค่าผู้บริโภคหรือรหัสผู้ฟังของฉัน...

ฉันใช้ springboot และพยายามเขียน KafkaProducer เพื่อส่งข้อความในคิว Kafka ฉันได้สร้างวิธีการเหล่านี้ในคลาส @Configuration @Bean public KafkaTemplate<String, String> kafkaTemplate(){ return new KafkaTemplate<>(producerFactory()); }...