2017-07-19 4 views
0
  1. コンシューマが接続されているパーティションを取得するにはどうすればよいですか?
  2. 複数のトピックを購読している場合、異なるトピックのメトリック(受信バイトレート)をconsumer.metrics()から取得するにはどうすればよいですか?あなたは、コンシューマ・グループの一部であり、自動パーティション割り当てに活用している場合は、毎回のパーティションは(によるリバランスに)割り当てられている

答えて

1
  1. 、(ConsumerRebalanceListenerの)onPartitionsAssignedは()と呼ばれています割り当てられたパーティションの集合。 Btwは、割り当てられたパーティションを取得するためにassign()メソッドを呼び出すことができます。
  2. 確かではありませんが、メソッドmetrics()はその作業を行う必要があります。
関連する問題