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

yv5phkfx 于 2021-06-07 发布在 Kafka

关注(0)|答案(5)|浏览(674)

我正在尝试启动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

............
............

apache-kafka

来源：https://stackoverflow.com/questions/42803119/exactly-one-of-whitelist-blacklist-topic-is-required

5条答案

按热度按时间

wnvonmuf1#

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

赞(0）回复(0）举报 2021-06-07

unftdfkk2#

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

赞(0）回复(0）举报 2021-06-07

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

赞(0）回复(0）举报 2021-06-07

cxfofazt4#

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

赞(0）回复(0）举报 2021-06-07

gcuhipw95#

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

赞(0）回复(0）举报 2021-06-07