в application.yml указать:
consumer:
key-deserializer: org.apache.kafka.common.serialization.LongDeserializer
value-deserializer: org.apache.kafka.common.serialization.LongDeserializer
то работает !
В смысле нет ошибки:
MessageConversionException: Failed to convert message payload ' ' to 'java.lang.Long'
А какое у тебя сообщение прилетает?
Ну вот судя по этому сообщению у тебя там строка из пробелов
в смысле вот это POST_VIEW_TOPIC пробелами прилетает ?
да вроде нет... Sending message to Kafka topic 'postViewTopic': 1
Я про принимающую сторону
ну в docker-compose.yaml такие:
Пофиг что там у тебя. У тебя сообщение из пробелов не может в Long распарсить. Это явно написано в ошибке
Так и в чем ошибка то тогда?
так не могу никак разобраться по какой такой причине class KafkaConsumerConfig не обрабатывает LongDeserializer.class
Обсуждают сегодня