Что такое Kafka idempotent consumer в Go и зачем это нужно?

GoMiddle+Kafka, RabbitMQ and MessagingТеорияkafka_rabbitmq_and_messagingkafka_idempotent_consumergo_microservices_developer

Что хотят услышать интервьюеры:

Суть: consumer должен уметь безопасно обрабатывать повторные сообщения.

Ответ:

Пример:

dedupe by event_id

Типичная ошибка: считать, что Kafka гарантирует exactly-once для всей бизнес-операции.

Как отвечать на собеседовании: Хороший ответ: гарантии доставки, ack/commit, идемпотентность, retry, DLQ и observability важнее, чем название брокера.

Источники

Похожие вопросы