Как реализовать простого потребителя Kafka, который обнаруживает и отбрасывает повторяющиеся сообщения. Потребители сообщений очень часто сталкиваются с манипуляциями с государством. Брокеры сообщений могут отправлять повторяющиеся сообщения по разным причинам. Таким образом, потребители должны овладеть искусством «идемпотентной обработки сообщений», чтобы преодолеть серьезные потоки в состоянии приложения. В этом посте я обсуждаю простой механизм обнаружения и удаления..