apache-kafka - 确实需要白名单/黑名单/主题之一

标签 apache-kafka

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

相关文章:

c# - 如何使用分区以便使用 .NET Core C# 并行使用 kafka 中的一个主题?

apache-kafka - 在kafka_2.12-2.2.0创建topic导致 “Timed out waiting for a node assignment”错误

apache-kafka - Kafka如何从__consumer_offsets主题阅读

使用 appication.yml/properties 具有不同属性配置的 Spring Boot Kafka 多个消费者

java - Spring kafka NonResponsiveConsumerEvent 甚至在broker宕机时触发时间

java - 使用 Jaas 配置进行 Kafka 身份验证

apache-kafka - kafka.server :type=KafkaServer, name=BrokerState 与 4 是什么意思?

java - KafkaProducer 未生成> 1 MB 的消息到主题

spring-boot - Spring Cloud Stream 动态 channel

cassandra - 恰好一次和至少一次保证之间的区别