Kafka error deserializing key/value for partition

Kafka error deserializing key/value for partition 寫了一個kafka測試的demo 出現瞭如下錯誤: 這是我kafka的配置:   這是我接收的配置: 之前我用別的topic測試了沒有問題,換了一個topic出現這個問題,問題的原因在於這個topic序列化的參數改變了,IntegerDeserializer的長度不是4,所以就改爲StringDes
相關文章
相關標籤/搜索