
11/15/2022 · Danica Fine
What this post added
This post focuses on diagnosing and debugging increased consumer rebalance time in Apache Kafka. It details the mechanics of Stop-the-World and Incremental Cooperative rebalancing, introduces Static Group Assignment as a method to reduce rebalance impact, and highlights key consumer metrics (join-rate, records-lag-max) for monitoring rebalance health. It also identifies common root causes for increased rebalance time, including one-consumer-per-thread patterns, undersized KafkaConsumer instances, and overloaded group coordinators.