Apache Kafka - Производитель - Идемпотентность между сообщениями производителей - PullRequest
0 голосов
/ 11 октября 2019

У нас есть микросервисная архитектура в нашем проекте. Существует микросервис, в котором планировщик запускает логику отправки сообщения в Kafka. Проблема в том, что если существует более одного экземпляра микросервиса, каждый из них отправит сообщение в Kafka. Как можно достичь идемпотентности между всеми производителями? Я имею в виду, что если «равные» сообщения будут отправлены в Кафку с разными производителями, тогда это будет зафиксировано в журнале только один раз.

1 Ответ

0 голосов
/ 12 октября 2019

Вы не можете этого сделать. Производители независимы.

...