2017-03-15 4 views
2

を必要とする私は、カフカの消費者を起動しようとしていますが、それはエラーの下に表示されます。は、正確に1つのホワイトリスト/ブラックリスト/話題の

$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 —topic Hello-Kafka 
Exactly one of whitelist/blacklist/topic is required. 
Option         Description        
------         -----------        
--blacklist <blacklist>     Blacklist of topics to exclude from  
              consumption.       
--bootstrap-server <server to connect           
    to>                   
--consumer.config <config file>   Consumer config properties file.  
--csv-reporter-enabled     If set, the CSV metrics reporter will 
              be enabled       
--delete-consumer-offsets    If specified, the consumer path in  
              zookeeper is deleted when starting up 

............ 
............ 
+2

私はそれが '--topic Hello-Kafka'だと思いますか? –

+0

お返事ありがとうございます。 – dsa

答えて

2

あなたは以下のように使用することができます。

ビン/ kafka- console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic Hello-Kafka

1

を追加すると、--whitelist Hello-Kafka が助けられました。

0

ビン/ kafka-console-consumer.sh --zookeeperはlocalhost:2181 --bootstrapサーバーはlocalhost:9092 --topicテスト--from-始まる

0

ビン/ kafka-console-consumer.sh - -zookeeper localhost:2181 -topic Hello-Kafka --from-beginning-whitelist Hello-Kafka

関連する問題