Ceritanya seperti ini. Saya memiliki broker kafka dan objek tertentu (yang saya jsonify untuk dikirim melalui topik saya) yang memiliki ID yang ingin saya gunakan sebagai kunci. Saat ini saya menggunakan konfigurasi 'partitionKeyExtractorClass'...

Saya mencoba membuat contoh kerja dengan produser pesan avro, kafka dan konsumen avro menggunakan spring boot, spring cloud stream Schema registry, kafka binder. Kesalahan berikut terjadi saat menggunakan pesan: ERROR 7059 --- [afka-listener-1]...

Menurut topik ini: Integrasi Kafka Spring: Header tidak hadir untuk konsumen kafka - ini bukan dukungan header untuk Kafka Namun dokumentasi mengatakan: spring.cloud.stream.kafka.binder.headers Daftar header khusus yang akan...