Kafka error deserializing key/value for partition
写了一个kafka测试的demo
出现了如下错误：
这是我kafka的配置：
这是我接收的配置：
之前我用别的topic测试了没有问题，换了一个topic出现这个问题，问题的原因在于这个topic序列化的参数改变了，IntegerDeserializer的长度不是4，所以就改为StringDeserializer：
这样就行了
相关文章：
相似解决方案
热门标签
Kafka error deserializing key/value for partition
写了一个kafka测试的demo
出现了如下错误：
这是我kafka的配置：
这是我接收的配置：
之前我用别的topic测试了没有问题，换了一个topic出现这个问题，问题的原因在于这个topic序列化的参数改变了，IntegerDeserializer的长度不是4，所以就改为StringDeserializer：
这样就行了
相关文章：