Пример реализации exactly once - паттерна + сохранение уникальных событий.
Шаги запуска:
docker-compose up- стартуем сам приклад
- смотрим как быстро Кафка сжирает 500к записей
- сохраняем в БД только уникальные события (должен быть один уникальный ключ на событие)
- после обработки сообщений из Кафки - коммитим в Кафку обработанные
offset'ы