2

我们有一个配置良好的 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).

有人可以给我一些关于如何解决这个问题的提示吗？

4

2 回答 2

1

看起来你超过了你的jute.maxbuffer. 尝试增加它。在这里您可以找到更多信息。

于 2018-11-21T10:04:02.530 回答
0

如果您使用的是 docker-compose，这对我有帮助：

environment:
  KAFKA_OPTS: -Djute.maxbuffer=500000000
于 2022-01-29T02:47:39.300 回答