apache kafka大量警告日志显示意外错误

flseospp  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(638)

我和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)
krcsximq

krcsximq1#

一个可能的原因是10.8.7.1上的kafka生产者试图批量传输0.369gb的数据,而不是流式传输。你可能得追查Kafka的制作人,看看情况如何。
希望这有帮助。

相关问题