...
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:
Code Block | ||||
---|---|---|---|---|
| ||||
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.
...