Kafka error deserializing key/value for partition

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

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

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

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


Поделиться:

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

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