...
We shall set `transaction.timout.ms` default to 10000 ms (10 seconds).
Offset Fetch Request
We need to bump OffsetFetchRequest version to include isolation levelwill add a new error code for consumer to wait for pending transaction clearance:
Code Block |
---|
OffsetFetchRequest => Partitions GroupId IsolationLevel
Partitions => List<TopicPartition>
GroupId => String
IsolationLevel => int8 // NEW |
...
PENDING_TRANSACTION(85, "There are pending transactions for the offset topic that needs to be cleared", PendingTransactionException::new), |
Fence Zombie
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 client.
...