カフカ複数トピックの消費

Question

consumer.subscribe(Pattern.compile(".*"),new ConsumerRebalanceListener() { 
      @Override 
      public void onPartitionsRevoked(Collection<TopicPartition> clctn) { 

      } 

      @Override 
      public void onPartitionsAssigned(Collection<TopicPartition> clctn) { 
      }    
     }); 

apache/kafkaでregexを使ってすべてのトピックを消費する方法はありますか？ 私は上記のコードを試したが、うまくいかなかった。正規表現の使用次のシグネチャ

KafkaConsumer.subscribe(Pattern pattern, ConsumerRebalanceListener listener) 

例えばについて

Answer 1

次のコードスニペットは、消費者が、あなたはそれが動作しませんでした_how_説明した場合にそれが役立つだろう接頭my_topics_

ConsumerRebalanceListener listener = new ConsumerRebalanceListener() { 

    @Override 
    public void onPartitionsRevoked(Collection<TopicPartition> arg0) { 
    // Don't need it now. 
    } 

    @Override 
    public void onPartitionsAssigned(Collection<TopicPartition> arg0) { 
    // Don't need it now. 
    } 
}; 

pattern = Pattern.compile("my_topics_.*"); 
kafkaConsumer.subscribe(pattern, listener);