новые сообщения, при получении сообщения оно обрабатывается и должно отправляться обратно в Кафку, но сообщение не отправляется и нет никакой ошибки. Кто может подсказать в чем кроется причина, или направить в какую сторону смотреть?
как и в любой такой ситуации включить логирование повербознее, подебажить еще можно
добрался до такого лога. Такой вывод: https://gist.github.com/ivg97/22f864e6f367659804bdcf6a6164878d Мало что понял из него
как минимум оно подключилось, надо код смотреть, оно вроде слушает 0 партицию у топика
есть возможность сделать чтобы слушались все партиции?
наверное есть, но без кода - это максимально абстрактный разговор зависит от настроек консюмера, в первую очередь думаю надо экзамплы в инете посмотреть
https://gist.github.com/ivg97/22f864e6f367659804bdcf6a6164878d такая конфигурация
А консюмера? Консюмер читает?
Обсуждают сегодня