Can CooperativeStickyAssignor be used with transactions?

2022-05-26 Thread Gabriel Giussi
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

why includeMetadataInTimeout could be set only in deprecated api

2022-05-26 Thread Xiangyuan LI
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