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 wil
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 :
> Can
+1 non-binding. I used the staged Scala 2.13 artifacts and the staged Maven
repo for my tests. All seems to work fine.
Thanks
Jakub
On Fri, Nov 24, 2023 at 4:37 PM Mickael Maison wrote:
> Hello Kafka users, developers and client-developers,
>
> This is the first candidate for release of Apache
Ah, yeah, IQ v2 was a pretty big feature so it hasn't yet been implemented
across all parts of Kafka Streams. You'll notice that we're still actively
putting out new KIPs trying to complete this feature. I don't think there's
any particular reason that Global KTables can't be made to work with IQ v
