Missing required argument zookeeper

Question

Hi,

I am trying to run the consumer server in Kafka. But I am getting the below error.

./kafka-console-consumer.sh --bootstrap-server localhost:9092,localhost:9093 --topic SimpleProducerTopic --from-beginning
Missing required argument "[zookeeper]"
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   

How can I fix it? Can anybody help me?

Thank You

Answer 1

Hi@akhtar,

I guess you are using the old version of kafka. So you can install the new version or you can add --new-consumer in your command.

$ ./bin/kafka-console-consumer.sh --new-consumer --bootstrap-server localhost:9092 --topic SimpleProducerTopic --from-beginning

Hope this will help you.

Thank You