REST-вызов внутри consumer связывает скорость Kafka-обработки с доступностью внешнего сервиса. Медленный вызов блокирует обработку partition, накапливает lag и может вызвать rebalance при превышении poll-интервала.
В чём проблема того, что вы вызываете REST прямо из Kafka consumer?
REST-вызов внутри consumer связывает скорость Kafka-обработки с доступностью внешнего сервиса. Медленный вызов блокирует обработку partition, накапливает lag и может вызвать rebalance при превышении poll-интервала.
Короткий ответ
Что ответить на собеседовании
Подробный разбор
Ответ с пояснениями
REST-вызов внутри consumer связывает скорость Kafka-обработки с доступностью внешнего сервиса. Медленный вызов блокирует обработку partition, накапливает lag и может вызвать rebalance при превышении poll-интервала.
Кроме timeout нужны ограничение параллелизма, backpressure и идемпотентность внешнего эффекта: сообщение может прийти повторно после сбоя. Можно быстро сохранять намерение в долговечную очередь/outbox и обрабатывать внешние вызовы отдельно, осознанно меняя семантику подтверждения. Прямой вызов не запрещён, если нагрузка и гарантии позволяют, но его отказ должен быть предусмотрен явно.