Kafka消费控制台订阅多个主题

sycxhyv7 于 2021-06-07 发布在 Kafka

关注(0)|答案(2)|浏览(718)

我使用ubuntuserver16.04尝试使用kafka。对于启动生产者和消费者控制台的命令，我使用以下命令。
生产商控制台：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic hello-topic

用户控制台：

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic hello-topic

但是上面的命令只订阅一个主题。如何订阅多个主题？

2条答案

首先，您应该使用选项bootstrap server连接到kafka服务器本身，而不是zookeeper服务器。
对于多个主题，可以使用白名单选项。这将被解释为一个正则表达式，并且必须被引用，参见kafka文档。所以正确的命令是：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --whitelist 'hello-topic|world-topic|another-topic'

也可以使用其他表达式，例如

kafka-console-consumer.sh --bootstrap-server localhost:9092 --whitelist '.*'

注意
为了方便起见，我们允许使用“，”而不是“|”来指定主题列表。
不适用于Kafka2.0，可能只是在镜像时，我还没有尝试。

正如harald所提到的，使用白名单/黑名单选项来包括/排除一组供消费的主题。

sh kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --whitelist Hello,World