Kafka error deserializing key/value for partition

При попытке считать сообщение из kafka получаю странную ошибку:

 
В конце концов оказалось, что проблема была в следующем коде:

Чтобы всё заработало, нужно просто поправить тип ключа с Integer на  String:

То есть у KafkaConsumerFactory просто указываем строковые ключи и StringDeserializer-ы.


Поделиться:
1 Звезда2 Звезды3 Звезды4 Звезды5 Звезд (Пока оценок нет)
Загрузка...

Добавить комментарий

Ваш e-mail не будет опубликован.

*