2017-01-02 215 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 –

相關問題