Проблема кафки в кубернетах

Question

При появлении любого сообщения pu sh на kafka topi c я вижу сообщение ниже. мое сообщение содержит только 5 элементов, и это простой текст, только он не превышает 300 символов, все еще видя ошибку ниже. 1004 *

Мне нужна хорошая статья по настройке кластера kafka в кубернетах, любая помощь будет оценена.

Answer 1

1920298859 - это узнаваемое значение, оно ruok декодируется как целое число:

>>> struct.unpack("!I", struct.pack("!4s", "ruok".encode("UTF8")))
(1920298859,)

Похоже, у вас есть какие-то инструменты / проверка работоспособности Zookeeper, пытающиеся подключиться к Kafka. Команду ruok следует отправлять только хостам Zookeeper. Kafka принимает соединения только от клиентов Kafka.