Hi. JoinGroup request is sent from the polling/user thread. In your example, the consumer instance will be removed from the group because it didn't join the group within the timeout. So the partition will be assigned to another consumer and be processed.
2023年11月26日(日) 18:09 Debraj Manna <subharaj.ma...@gmail.com>: > Can someone let me know if the JoinRequest is sent by the consumer from the > polling/user thread or from the background heart-beat thread? > > If JoinRequest is being sent from the polling/user thread then in this case > if the poll user thread takes more than max.poll.interval.secs then the > consumer will remain disconnected from the broker for that long. For > example, if max.poll.interval.secs is 300 sec and if processing in the poll > thread takes 15 mins then for 15 mins the partition from which this > consumer was polling will remain idle and no message will be consumed from > that partition. Is my understanding correct? > > I am using Kafka client 3.5.1 with Apache Kafka broker 2.8.1 with all > default settings on the consumer configs. > -- ======================== Okada Haruki ocadar...@gmail.com ========================
