我正在尝试启动 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
............
............
Run Code Online (Sandbox Code Playgroud) 我试图通过遵循这个要点在EC2的多个实例上配置Kafka ,但是我收到以下错误:
我正在运行此命令:
$ bin/zookeeper-server-start.sh config/zookeeper.properties &
Run Code Online (Sandbox Code Playgroud)
1 13308
错误:
[2017-03-22 08:21:00,314] ERROR Invalid config, exiting abnormally (org.apache.zookeeper.server.quorum.QuorumPeerMain)
org.apache.zookeeper.server.quorum.QuorumPeerConfig$ConfigException: Error processing config/zookeeper.properties
at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:123)
at org.apache.zookeeper.server.quorum.QuorumPeerMain.initializeAndRun(QuorumPeerMain.java:101)
at org.apache.zookeeper.server.quorum.QuorumPeerMain.main(QuorumPeerMain.java:78)
Caused by: java.lang.IllegalArgumentException: /tmp/zookeeper/myid file is missing
at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parseProperties(QuorumPeerConfig.java:350)
at org.apache.zookeeper.server.quorum.QuorumPeerConfig.parse(QuorumPeerConfig.java:119)
... 2 more
Run Code Online (Sandbox Code Playgroud)
我zookeeper.conf的如下图所示:
dataDir=/tmp/zookeeper
# the port at which the clients will connect
#clientPort=2181
clientPort=2080
# disable the per-ip limit on the number of connections since this is a non-production config
maxClientCnxns=0
server.1=ec2-<GLOBAL_IP_1>.amazonaws.com:2888:3888
server.2=ec2-<GLOBAL_IP_2>.amazonaws.com:2888:3888
#add …Run Code Online (Sandbox Code Playgroud)