Скорее всего тупой вопрос, сори)
Пытаюсь сделать что-то типа event sourcing, основное хранилище у меня postgresql, а брокер сообщений kafka.
Какой лучший способ обеспечить обработку событий без дубликатов в подписчике кафки? Сохранять в базе атомарно offset вместе с результатом?
И как это обычно делают, мало примеров по теме, или я неправильно гуглю, спасибо)