Ключ производителя 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
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

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