org.apache.kafka.common.errors.SerializationException: Can't convert value of class [B to class org.apache.kafka.common.serialization
时间: 2023-12-09 12:03:00 浏览: 219
KOA+egg.js集成kafka消息队列的示例
这个错误通常是因为序列化器和反序列化器不一致导致的,具体来说就是生产者和消费者使用的序列化器和反序列化器不匹配。可以尝试检查以下几个方面:
1. 生产者和消费者使用的序列化器和反序列化器是否一致。
2. 生产者和消费者使用的序列化器和反序列化器是否都是同一家库提供的。
3. 生产者和消费者使用的序列化器和反序列化器是否都是Kafka支持的。
4. 如果使用自定义的序列化器和反序列化器,确保它们正确实现了Kafka提供的接口。
如果以上的解决方法都没有解决问题,可以尝试打印出详细的堆栈信息,以便更好地定位问题。
阅读全文