0
回答
用spring-integration集成kafka时,报SchemaException:Error reading field 'brokers'?
终于搞明白,存储TCO原来是这样算的>>>   

用spring-integration集成kafka时,报SchemaException:Error reading field 'brokers'?

详细报错信息如下:

org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'brokers': Error reading field 'host': Error reading string of length 25445, only 76 bytes available
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73)
at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:380)
at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:449)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:269)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:229)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
at java.lang.Thread.run(Thread.java:744)


但是地址切换向我本地搭建的kafka就是可以正常发送的成功的!本地和内网服务器两个不一样,一个是内网kafka版本过低,再一个内网是搭建kafka集群,望各位不吝赐教!

举报
春秋苣
发帖于11个月前 0回/881阅
顶部