Hi all, I would like to start a discussion for KIP-1264. Under the new consumer, share and streams protocols (KIP-848, KIP-932, KIP-1071) we calculate assignments on the broker whereas previously we used to calculate assignments on clients under the old classic protocol. The assignment calculation can get expensive for large groups and impact group coordinator performance. The KIP aims to reduce the impact of slow assignor runs through two methods: enforcing a minimum interval between assignment updates and moving the assignment calculation to a separate thread pool.
KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1263%3A+Group+Coordinator+Assignment+Batching+and+Offload Best regards, Sean
