2017-01-02 1189 views
2

我使用Ubuntu服务器16.04尝试使用Kafka。对于启动生产者和消费者控制台的命令,我使用以下内容。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 

但上述只是预订一个话题的命令。我如何订阅多个主题?

+1

您是否尝试过控制台使用者的白名单选项? – Harald

+0

@Harald还没有,我不知道有白名单 –

回答

1

正如Harald所述,使用白名单/黑名单选项来包含/排除一组用于消费的主题。

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

当我使用'--bootstrap-server kafkaserver:9092'时,这不适用于我。既然旧消费者会被弃用,那么新消费者是否有办法点点滴滴呢? –

+0

@ colin-SBI您正在使用哪种Kafka版本? –

+0

kafka_2.11-0.11.0.1 –

相关问题