我们有一个配置良好的zookeeper和kafka集群节点。创建主题和发送该主题消息的手动测试成功通过。但是,当我从测试设备运行一个测试,以便使用MQTT协议创建一个主题时,我收到:
Exception causing close of session 0x0 due to java.io.IOException: Len error 271056900
[myid:1] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1008] - Closed socket connection for client /192.18.0.1:15659 (no session established for client).
有人能给我一些关于如何解决这个问题的提示吗?
发布于 2018-11-21 10:04:03
看起来你已经超出了你的jute.maxbuffer
。试着增加它。Here你可以找到更多信息。
发布于 2022-01-28 18:47:39
如果你使用docker-compose,这对我很有帮助:
environment:
KAFKA_OPTS: -Djute.maxbuffer=500000000
https://stackoverflow.com/questions/50275539
复制