В чём проблема того, что вы вызываете REST прямо из Kafka consumer?

REST-вызов внутри consumer связывает скорость Kafka-обработки с доступностью внешнего сервиса. Медленный вызов блокирует обработку partition, накапливает lag и может вызвать rebalance при превышении poll-интервала.

Короткий ответ

Что ответить на собеседовании

REST-вызов внутри consumer связывает скорость Kafka-обработки с доступностью внешнего сервиса. Медленный вызов блокирует обработку partition, накапливает lag и может вызвать rebalance при превышении poll-интервала.

Подробный разбор

Ответ с пояснениями

REST-вызов внутри consumer связывает скорость Kafka-обработки с доступностью внешнего сервиса. Медленный вызов блокирует обработку partition, накапливает lag и может вызвать rebalance при превышении poll-интервала.

Кроме timeout нужны ограничение параллелизма, backpressure и идемпотентность внешнего эффекта: сообщение может прийти повторно после сбоя. Можно быстро сохранять намерение в долговечную очередь/outbox и обрабатывать внешние вызовы отдельно, осознанно меняя семантику подтверждения. Прямой вызов не запрещён, если нагрузка и гарантии позволяют, но его отказ должен быть предусмотрен явно.

ИИ-помощник для собеседований

Хочешь уверенно проходить собеседования?

Попробуй ИИ-помощник для собеседований: слышит вас и собеседника, анализирует экран, подсказывает ответы в реальном времени, работает без VPN и не попадает в захват экрана.

Подробнее