2017-05-04 11 views
0

私は、消費者が消費するメッセージをブロックするように、非常に長い時間をかけてグループのリバランスを取っています。 私の質問:kafkaグループのリバランスには長い時間がかかります

  1. なぜグループのリバランスに時間がかかるのですか?
  2. この問題を解決するにはどうすればよいですか?カフカクラスターを再起動する必要はありますか?または、我々は以下の生産

にカフカのクラスタを使用しているとして、このため任意の回避策ソリューションは、スクリーンショットです:

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9095 --new-consumer --describe --group command-consumer-ldnpsr000001135 --command-config config/consumer.config 
Consumer group `command-consumer-ldnpsr000001135` is rebalancing. 

はどんなアドバイスを感謝しますか?

答えて

0

このため2つの考えられる理由があります:

  1. 消費者がグループに参加するときにリバランスのプロセスが開始されますが。リトライ回数を設定するrebalance.max.retriesがあり、デフォルトでは4に設定されています。

  2. 消費者が動物園に鼓動しない場合。 ZooKeeperセッションのタイムアウトZooKeeperはこの期間、死んだと見なされ、再調整が行われます。

関連する問題