Kafka 0.11版本新功能介紹 —— 空消費組延時rebalance

  在0.11之前的版本中,多個consumer實例加入到一個空消費組將導致多次的rebalance,這是由於每個consumer instance啓動的時間不可控,很有可能超出coordinator確定的rebalance timeout(即max.poll.interval.ms),而每次rebalance的代價又相當地大,因爲很多狀態都需要在rebalance前被持久化,而在rebalanc
相關文章
相關標籤/搜索