カフカのトピックメッセージ消費をスケジュールする方法は？

Question

私はApache Kafkaで働いていて、私のUbuntuサーバにメッセージを公開して使用することができました。だから、基本的に私の出版社のJavaプログラム&が私の消費者向けJavaプログラムを持っています。

私はここでコンシューマーclassのソースコードを提供しています。私は、とTimerTaskのようなschedulingについて多少の知識を持っています。ソースコードでは、しばらくの間、メッセージを繰り返し印刷しています。

私が知りたいのは、3秒以内にメッセージの数（つまり、メッセージの数）が消費されたことです。私はメッセージを公開しているとき、このようなことをしました。

TimerTask tasknew = new TimerTask() { 


     @Override 
     public void run() { 
      System.out.println("count : "+ count); 
      count = 0; 

      for (int i = 1; i < 2100; i++) { 
       count = count + 1; 
       String ip = "192.168.2." + rnd.nextInt(255); 
       String msg = " testing "; 
       KeyedMessage<String, String> data = new KeyedMessage<String, String>("Games", ip , msg); 
       producer.send(data); 

      } 
     } 
    }; 
    Timer timer = new Timer(); 
    timer.schedule(tasknew, 100, 3000); 

これは、基本的には、3秒ごとに700個のメッセージを印刷することです。私も消費しているときに同じことをする必要があります。しかし、例えば3秒以内に消費されたメッセージの数を表示する。

どのように対処できますか？どんな助けもありがとう。

Answer 1

あなたの質問にお答えするには、YESとお答えください。
はい、私たちは消費者を監視して、消費者のメッセージレートを調べることができます。
これには、KAFKA UIとGANGLIAのような複数のツールがあります。

KAFKAは、これらのツールをインストールするときに設定可能なJMXポートを提供しています。メトリックを表示するだけです。