This is the scenario I have in mind
1. Client A gets assigned partitions P1 and P2.
2. Client A polls a message with offset X from P1, opens a transaction and
produces to some output topic.
3. Client B joins the group and gets assigned P2
4. Client A tries to sendOffsets with group metadata but
Hi kafka team
After check the kafka 2.8.0 code,
seems
org.apache.kafka.clients.consumer.KafkaConsumer#poll(org.apache.kafka.common.utils.Timer,
boolean) allow user to keep poll records during consumer-rebalance when
use CooperativeStickyAssignor, and allow this behaivor must
set