本文主要是介绍Kafka消费消息时报错 zookeeper is not a recognized option，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
bin/kafka-console-consumer.sh 消费消息时报错 “zookeeper is not a recognized option”
使用命令 bin/kafka-console-consumer.sh --zookeeper 10.9.251.33:2181 --from-beginning --topic first 消费消息时报如下错误
.....114/lib/kafka/bin/../libs/zookeeper-3.4.5-cdh6.0.0.jar:/opt/cloudera/parcels/CDH-6.0.0-1.cdh6.0.0.p0.537114/lib/sentry/lib/*:/opt/cloudera/parcels/CDH-6.0.0-1.cdh6.0.0.p0.537114/lib/sentry/lib/plugins/*:/etc/kafka/conf/sentry-conf
zookeeper is not a recognized option
Option Description
------ -----------
--bootstrap-server <String: server to REQUIRED (unless old consumer is connect to> used): The server to connect to.
--consumer-property <String: A mechanism to pass user-defined consumer_prop> properties in the form key=value to the consumer.
--consumer.config <String: config file> Consumer config properties file. Note that [consumer-property] takes precedence over this config.
--enable-systest-events Log lifecycle events of the consumer in addition to logging consumed messages. (This is specific for system tests.)
--formatter <String: class> The name of a class to use for formatting kafka messages for display. (default: kafka.tools. DefaultMessageFormatter)
--from-beginning If the consumer does not already have an established offset to consume from, start with the earliest message present in the log rather than the latest message.
--group <String: consumer group id> The consumer group id of the consumer.
--isolation-level <String> Set to read_committed in order to filter out transactional messages which are not committed. Set to read_uncommittedto read all messages. (default: read_uncommitted)
--key-deserializer <String: deserializer for key>
--max-messages <Integer: num_messages> The maximum number of messages to consume before exiting. If not set, consumption is continual.
--offset <String: consume offset> The offset id to consume from (a non- negative number), or 'earliest' which means from beginning, or 'latest' which means from end (default: latest)
--partition <Integer: partition> The partition to consume from. Consumption starts from the end of the partition unless '--offset' is specified.
--property <String: prop> The properties to initialize the message formatter.
--skip-message-on-error If there is an error when processing a message, skip it instead of halt.
--timeout-ms <Integer: timeout_ms> If specified, exit if no message is available for consumption for the specified interval.
--topic <String: topic> The topic id to consume on.
--value-deserializer <String: deserializer for values>
--whitelist <String: whitelist> Whitelist of topics to include for consumption.
kafka的版本问题,低版本的kafka可以使用以上的命令,但是在高版本的kafka中需要使用命令bin/kafka-console-consumer.sh --bootstrap-server 10.9.251.33:9092 --from-beginning --topic first才行
Shylin
这篇关于Kafka消费消息时报错 zookeeper is not a recognized option的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
