ฉันกำลังพยายามสร้างตัวอย่างการทำงานกับผู้ผลิตข้อความ avro, kafka และ avro Consumer โดยใช้ spring boot, รีจิสทรีสคีมาสตรีมคลาวด์ของ spring cloud, kafka binder ข้อผิดพลาดต่อไปนี้เกิดขึ้นเมื่อใช้งานข้อความ:
ข้อผิดพลาด 7059 --- [afka-listener-1] os.c.s.b.k.KafkaMessageChannelBinder : ไม่สามารถทำการดีซีเรียลไลซ์ [io.igx.android.Sensor] โดยใช้ contentType [application/x-java-object;type=io.igx.android.Sensor] java .lang.NullPointerException
ฉันมี spring.cloud.stream.bindings.output.contentType=application/+avro บนฝั่งผู้บริโภคและ spring.cloud.stream.bindings.output.contentType=application/+avro บนฝั่งผู้ผลิต
เหตุใดผู้บริโภคจึงไม่เห็นและใช้ประเภทเนื้อหา avro แทน application/x-java-object
