我正在尝试启动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
............
............
5条答案
按热度按时间wnvonmuf1#
您可以按以下方式使用:
bin/kafka-console-consumer.sh—引导服务器localhost:9092 --from-beginning --你好,Kafka
unftdfkk2#
bin/kafka-console-consumer.sh--缩放器localhost:2181 --bootstrap-server localhost:9092 --topic 测试--从头开始
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
cxfofazt4#
bin/kafka-console-consumer.sh--缩放器localhost:2181 -主题你好Kafka——从一开始——白名单你好Kafka
gcuhipw95#
添加
--whitelist Hello-Kafka
帮助了我。