...
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), |
And to avoid concurrent processing due to upgrade, we also want to introduce an exception to let consumer back off:
Code Block | ||||
---|---|---|---|---|
| ||||
CONSUME_BACK_OFF(85, "This producer attempted to commit offset to a topic partition which is owned by another producer in this generation.", ConcurrentProducerCommitException::new), |
Will discuss in more details in Compatibility section.
Example
Below we provide an example of a simple read-process-write loop with consumer group-aware EOS processing.
...