Ключ производителя Kafka показывает неправильное значение после отправки сообщенияJAVA

Программисты JAVA общаются здесь
Anonymous
Ключ производителя Kafka показывает неправильное значение после отправки сообщения

Сообщение Anonymous »

Я работаю над приложением Spring Boot, в котором использую Kafka для отправки сообщений в тему. Я устанавливаю определенный ключ для каждого сообщения, но после успешной отправки сообщения, когда я проверяю тему, ключ отображается как случайное число вместо установленного мной ключа.
Я установил код ниже в своем приложении ,
application.properties

Код: Выделить всё

spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.IntegerSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
.
Я использую схему avro для отправки значений, все работает нормально, данные также отправляются в kafka.
Может кто-нибудь сказать мне, в чем может быть проблема,
Заранее спасибо.

Подробнее здесь: https://stackoverflow.com/questions/787 ... ng-message

Вернуться в «JAVA»