我有一个要求，消息必须张贴到Kafka主题，在此之前，我需要检查Kafka是启动和运行，然后我可以直接张贴消息，否则我需要做其他业务逻辑，如坚持这些消息和主题后，Kafka上线。我使用java程序来检查Kafka状态，在线检查Kafka与否，在Kafka控制台日志中的每个check it writing错误，如下所示。在这个错误的msgsKafka杀死自己一些负荷现在我想避免这种情况下，任何建议，我可以避免这些警告msgs和需要我的工作。验证Kafka运行状态的任何其他建议。
来自/127.0.0.1的意外错误；正在关闭连接（org.apache.kafka.common.network.selector）org.apache.kafka.common.network.invalidreceiveexception:org.apache.kafka.common.network.networkreceive.readfrom（networkreceive）处的接收无效（大小=1920298859大于504857600）。java:104)在org.apache.kafka.common.network.kafkachannel.receive（kafkachannel。java:381)在org.apache.kafka.common.network.kafkachannel.read（kafkachannel。java:342)在org.apache.kafka.common.network.selector.attemptread（selector。java:609)在org.apache.kafka.common.network.selector.pollselectionkeys（selector。java:541)在org.apache.kafka.common.network.selector.poll（selector。java:467)在kafka.network.processor.poll（socketserver。scala:689)在kafka.network.processor.run（socketserver。scala:594)