Page History

...

We will add a new error code for consumer to wait for pending transaction clearance. In order to be able to return correct exception type corresponding exceptions for old/new clients, we shall also bump the OffsetFetch protocol version.

PENDING_TRANSACTION(85, "There are pending transactions for the offset topic that needsneed to be cleared", PendingTransactionException::new),

...

A zombie process may invoke InitProducerId after falling out of the consumer group. In order to distinguish zombie requests, we need to leverage group coordinator to fence out of generation sync client.

A new generation.id field shall be added to the `TxnOffsetCommitRequest` request:

...