consumer.subscribe(Pattern.compile(".*"),new ConsumerRebalanceListener() {
@Override
public void onPartitionsRevoked(Collection<TopicPartition> clctn) {
}
@Override
public void onPartitionsAssigned(Collection<TopicPartition> clctn) {
}
});如何使用apache/kafka中的regex使用所有主题？我试过上面的代码，但没用。
1条答案
按热度按时间20jt8wwn1#
对于regex，使用以下签名
e、 g.下面的代码片段使使用者能够收听带有前缀的所有主题
my_topics_```ConsumerRebalanceListener listener = new ConsumerRebalanceListener() {
@Override
public void onPartitionsRevoked(Collection arg0) {
// Don't need it now.
}
@Override
public void onPartitionsAssigned(Collection arg0) {
// Don't need it now.
}
};
pattern = Pattern.compile("my_topics_.*");
kafkaConsumer.subscribe(pattern, listener);