• 1000 сообщения и публиковать в топи c, как только кафка выходит в сеть. Я использую программу java для проверки статуса kafka, чтобы проверить kafka в сети или нет, при каждой проверке она пишет ошибку в журналах консоли kafka, как показано ниже. После некоторой загрузки этой ошибки msgs kafka убивает себя, теперь я хочу избежать этой ситуации, любые предложения, как я могу избежать этих предупреждающих сообщений и мне нужна моя работа. Любые альтернативные предложения по проверке статуса работы kafka.
Неожиданная ошибка из /127.0.0.1; закрытие соединения (org. apache .kafka.common.network.Selector) org. apache .kafka.common.network.InvalidReceiveException: недопустимый прием (size = 1920298859 больше 504857600) в org. apache .kafka. common.network.NetworkReceive.readFrom (NetworkReceive. java: 104) в орг. apache .kafka.common.network.KafkaChannel.receive (KafkaChannel. java: 381) в орг. apache .kafka. common.network.KafkaChannel.read (KafkaChannel. java: 342) в орг. apache .kafka.common.network.Selector.attemptRead (Selector. java: 609) в орг. 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)