0
回答
用spring-integration集成kafka时,报SchemaException:Error reading field 'brokers'?
利用AWS快速构建适用于生产的无服务器应用程序,免费试用12个月>>>   

用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集群,望各位不吝赐教!

举报
春秋苣
发帖于1年前 0回/901阅
顶部