我正在尝试启动Kafka使用者,但显示以下错误:
$ 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
............
............
最佳答案
您可以如下使用:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic Hello-Kafka
关于apache-kafka - 确实需要白名单/黑名单/主题之一,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42803119/