2017-01-02 19 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が述べたように、whitelist/blacklistオプションを使用して、消費するトピックのセットを含める/除外します。

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

'--bootstrap-server kafkaserver:9092'を使うと、これはうまくいきません。古い消費者は非難されるので、新しい消費者がそれを描く方法があるのだろうか? –

+0

@ colin-SBIカフカ版をお使いですか? –

+0

kafka_2.11-0.11.0.1 –

関連する問題