У нас есть хорошо настроенные узлы 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 (сеанс для клиента не установлен).
Может кто-нибудь подсказать, как решить эту проблему?
Спасибо