我和2个博克一起管理Kafka的集群。
但我一直收到警告日志。
我检查了所有系统,没有主机使用ip 10.8.7.1。
顺便说一下,有更多的IP看起来像从Zookeeper或经纪人?
如果我拍下Kafka的照片,警告记录就会少一些
我不熟悉Kafka和Zookeeper,只是刚刚开始学习
有什么想法吗?
Kafka版本:1.0.1
警告日志如下(获取此类日志约10秒),
[2018-04-19 09:13:08,342] WARN [SocketServer brokerId=0] Unexpected error from /10.8.7.1; closing connection (org.apache.kafka.common.network.Selector)
org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 369295616 larger than 104857600)
at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:132)
at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:93)
at org.apache.kafka.common.network.KafkaChannel.receive(KafkaChannel.java:235)
at org.apache.kafka.common.network.KafkaChannel.read(KafkaChannel.java:196)
at org.apache.kafka.common.network.Selector.attemptRead(Selector.java:545)
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:483)
at org.apache.kafka.common.network.Selector.poll(Selector.java:412)
at kafka.network.Processor.poll(SocketServer.scala:551)
at kafka.network.Processor.run(SocketServer.scala:468)
at java.lang.Thread.run(Thread.java:748)
1条答案
按热度按时间krcsximq1#
一个可能的原因是10.8.7.1上的kafka生产者试图批量传输0.369gb的数据,而不是流式传输。你可能得追查Kafka的制作人,看看情况如何。
希望这有帮助。