...

When set to true and exactly-once is turned on, Kafka Streams application will choose to use single producer per thread.

To fence an old producer accessing the same topic partition, we will introduce a new exception type:

CONCURRENT_PRODUCER_COMMIT(85, "This producer attempted to commit offset to a topic partition which is owned by another producer in this generation.", ConcurrentProducerCommitException::new),

Example

Below we provide an example of a simple read-process-write loop with consumer group-aware EOS processing.

...