...
To fence an old producer accessing the same topic partitiongroup, 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), |
return ILLEGAL_GENERATION exception. A new generation id field shall be added to the `TxnOffsetCommitRequest` request:
...