Stati c членство в Apache Kafka для потребителей

Question

Я узнал в последней версии kafka, стратегия членства stati c доступна для подписки потребителя вместо раннего динамического обнаружения членства c, которое помогает в сценарии, когда потребитель отскакивает как часть скользящего развертывания. Теперь, когда потребитель встал после того, как получил отказ, он догоняет тот же раздел и начинает обработку.

Мой вопрос: что произойдет, если мы намеренно отключим потребителя? Как будет обрабатываться сообщение в разделе, на который был подписан конкретный потребитель?

Answer 1

Если вы подпишетесь вручную, вам придется иметь дело с этим сценарием в коде приложения - в этом преимущество автоматической подписки c, все разделы будут назначены одной из групп после перебалансировки.

Чтобы обслуживать потребителей, постоянно покидающих группу с ручной подпиской, я думаю, вам нужно будет где-то отслеживать подписки и, возможно, попросить каждого потребителя проверить, что он жив.

Я Я не знаю, в каких случаях используется ручная подписка - мне придется go вернуться и проверить Javado c в KafkaConsumer, что довольно полно. Пока у вас нет локального состояния у потребителей, автоматическая подписка c кажется намного более безопасной и более устойчивой.