需要白名单/黑名单/主题中的一个

yv5phkfx  于 2021-06-07  发布在  Kafka
关注(0)|答案(5)|浏览(673)

我正在尝试启动kafka consumer,但它显示以下错误:

$ 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

............
............
wnvonmuf

wnvonmuf1#

您可以按以下方式使用:
bin/kafka-console-consumer.sh—引导服务器localhost:9092 --from-beginning --你好,Kafka

unftdfkk

unftdfkk2#

bin/kafka-console-consumer.sh--缩放器localhost:2181 --bootstrap-server localhost:9092 --topic 测试--从头开始

7tofc5zh

7tofc5zh3#

对于kafka 2.11-2.1.0以上的kafka版本:./kafka-console-consumer.sh--引导服务器ip:port--从开始--主题
对于kafka版本kafka\u 2.11\u 0.9.0.0及以下版本:/kafka-console-consumer.sh--zookeeper ip:port--topic topic--from beging--whitelist topic

cxfofazt

cxfofazt4#

bin/kafka-console-consumer.sh--缩放器localhost:2181 -主题你好Kafka——从一开始——白名单你好Kafka

gcuhipw9

gcuhipw95#

添加 --whitelist Hello-Kafka 帮助了我。

相关问题