我在vm中设置了kafka集群。
但我有个问题。
我的Kafka版本是Kafka2.11-0.0.0
$ bin/kafka-server-start.sh config/zookeeper.properties
[2017-01-31 09:15:55,216] FATAL (kafka.Kafka$)
org.apache.kafka.common.config.ConfigException: Missing required configuration "zookeeper.connect" which has no default value.
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:148)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:49)
at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:56)
at kafka.server.KafkaConfig.<init>(KafkaConfig.scala:702)
at kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:691)
at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:28)
at kafka.Kafka$.main(Kafka.scala:58)
at kafka.Kafka.main(Kafka.scala)
请帮帮我。
my zookeeper.properties(向下)
zookeeper.properties属性
dataDir=/home/kafka01/zookeeper-data
# the port at which the clients will connect
clientPort=2181
# disable the per-ip limit on the number of connections since this is a non-production config
maxClientCnxns=0
initLimit=5
syncLimit=2
server.1=kafka01:2888:3888
server.2=kafka02:2888:3888
server.3=kafka03:2888:3888
服务器属性
zookeeper.connect=kafka01:2181,kafka02:2181,kafka03:2181
有什么问题??
4条答案
按热度按时间guicsvcw1#
你看错剧本了。应该是:
bin/zookeeper-server-start.sh config/zookeeper.properties
mi7gmzs62#
这是一个错误,因为您的命令有问题。
启动zookeeper运行-
启动服务器运行-
f45qwnt83#
您试图启动kafka服务器,但传递的配置文件错误。
通常要使用以下命令启动kafka服务器:
并在此文件中指定zookeeper的地址:
Kafka官方文档中的快速入门指南相当不错,我建议你去看看。你可以在这里找到它。
olqngx594#
有两种方法可以启动kafka服务器:
单独启动zookeeper服务器(在本地或其他计算机上)
启动嵌入kafka服务器的zookeeper服务器(kafka_2.12/libs/zookeeper-3.4.13.jar)
在第一种情况下:我假设您已经启动了zookeeper服务器,并且该服务器正在运行localhost:2181
现在可以使用以下命令启动kafka服务器了
在server.properties文件中,您必须告诉kafka服务器zookeeper在哪里运行。使用属性:
在第二种情况下
首先启动zookeeper(嵌入kafka服务器)
然后,启动kafka服务器: