这个是消费数据格式和发送数据格式不一致转换失败导致
解决办法原配置文件
spring:
kafka:
bootstrap-servers: 127.0.0.1:9092
producer:
acks: 1
retries: 3
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
consumer:
auto-offset-reset: earliest
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
如果去消费字符串类型的数据,就会报这个错误,修改下配置
spring:
kafka:
bootstrap-servers: 127.0.0.1:9092
producer:
acks: 1
retries: 3
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
consumer:
auto-offset-reset: earliest
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
问题解决,只要发送端和消费端数据格式一致即可,根据实际情况修改配置



