Ошибка Zookeeper: исключение, вызывающее закрытие сеанса 0x0 из-за java.io.IOException: ошибка Len
У нас есть хорошо настроенные узлы zookeeper и kafka. Ручной тест для создания темы и отправки сообщения по этой теме прошел успешно. Но когда я запускаю тест из электронного тестового оборудования, чтобы создать тему с протоколом MQTT, я получаю: Исключение, вызывающее закрытие сеанса 0x0 из-за java.io.IOException: Len error 271056900[myid: 1] - INFO [ NIOServerCxn.Factory: 0.0.0.0/0.0.0.0: 2181: NIOServerCnxn @ 1008] - Соединение с закрытым сокетом для клиента /192.18.0.1:15659 (сеанс для клиента не установлен).
Может кто-нибудь дать мне подсказку, как решить эту проблему? Спасибо
2 ответа
Похоже, вы превышаете свой jute.maxbuffer, Попробуйте увеличить его. Здесь вы можете найти больше информации.
Если вы используете docker-compose, это помогает мне:
environment:
KAFKA_OPTS: -Djute.maxbuffer=500000000