Page History

...

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:

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.

...