отвалился, а все еще обрабатывает ранее прочитанные результаты?
Можно увеличить тайм-аут, а можно попробовать руками слать heartbeat, но позволяет ли это ваш клиент - хз
спасибо, изучу про хартбиты. Это аварийный сценарий, тут таймаут не подходит.
Я вообще сам с ними не сталкивался никогда, только вот тут наткнулся на описание https://www.marionzualo.com/2019/08/10/always-manually-send-heartbeats-when-processing-message-batches-in-ruby-kafka/
Обсуждают сегодня