Почему Kafka Streams не использовали для дедупликации сообщений?

Kafka Streams уместен для дедупликации потока по ключу и окну, но не заменяет идемпотентность бизнес-эффекта во внешней БД.

Если задача — не повторить начисление, уникальный ключ и атомарная транзакция рядом с начислением могут дать более простую и сильную границу защиты. Streams добавляет state store, восстановление, partitioning и правила срока хранения dedup-состояния. Он полезен для предварительной очистки потока, особенно при дальнейшей stream-processing логике. На собеседовании объясните реальные требования и альтернативы своего проекта; фраза «не использовали» не доказывает, что инструмент принципиально не подходит.