возможны траблы при хранении офсетов снаружи?
Вот у akka projections есть такие сценарии https://doc.akka.io/docs/akka-projection/current/kafka.html#committing-offset-outside-kafka если я правильно вопрос понял
никаких проблем нету, сортируете стрим окном, трекаете офсет для каждой партиции на етом все и атомарно пишете макс офсет для месаджа в батче для определенной партиции
Обсуждают сегодня