Consumer Liveness檢測機制

我們都知道能夠觸發Rebalance的原因有很多，其中就包括Group中新增或者移除Consumer Client。除去客戶端主動斷開連接會通知Coordinator執行Client的移除操作外，Kafka本身提供了多種機制來檢測Consumer liveness（Consumer的消費能力/Consumer的活躍度）。 熟悉的有session.timeout.ms和heartbeat.inter

>>阅读原文<<