启动 Kafka 时出错

Question

我在相关节点上有 zookeeper 守护进程运行，我正在尝试启动 kafka 代理但出现以下错误：

FATAL [Kafka Server 13], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.NumberFormatException: For input string: "2181""
    at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
    at java.lang.Integer.parseInt(Integer.java:492)
    at java.lang.Integer.parseInt(Integer.java:527)
    at org.apache.zookeeper.client.ConnectStringParser.<init>(ConnectStringParser.java:72)
    at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:443)
    at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:380)
    at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:64)
    at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:876)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98)
    at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84)
    at kafka.server.KafkaServer.initZk(KafkaServer.scala:157)
    at kafka.server.KafkaServer.startup(KafkaServer.scala:82)
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:29)
    at kafka.Kafka$.main(Kafka.scala:46)
    at kafka.Kafka.main(Kafka.scala)

我的server.properties

broker.id=13
port=9092
host.name=node013
num.network.threads=3
num.io.threads=8
zookeeper.connect="node014:2181,node135:2181,node136:2181"
zookeeper.connection.timeout.ms=6000

和zookeeper.properties

dataDir=/tmp/zookeeper
clientPort=2181
maxClientCnxns=0

我已经尝试但未能弄清楚为什么错误日志在端口属性中显示额外的 "。知道是什么导致了这个问题吗？

Answer 1

在您的 server.properties 文件中，您需要删除双引号。应该是

zookeeper.connect=node014:2181,node135:2181,node136:2181

Answer 2

可以通过删除“2181”端口和命令行选项“--list”之间的 space 来解决异常。

$ ./kafka-topics --zookeeper localhost:2181 --list Exception in thread "main" java.lang.NumberFormatException: For input string: "2181 " at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65) at java.lang.Integer.parseInt(Integer.java:580) at java.lang.Integer.parseInt(Integer.java:615) at org.apache.zookeeper.client.ConnectStringParser.(ConnectStringParser.java:72) at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:443) at org.apache.zookeeper.ZooKeeper.(ZooKeeper.java:380) at org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:70) at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1228) at org.I0Itec.zkclient.ZkClient.(ZkClient.java:157) at org.I0Itec.zkclient.ZkClient.(ZkClient.java:131) at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:103) at kafka.utils.ZkUtils$.apply(ZkUtils.scala:85) at kafka.admin.TopicCommand$.main(TopicCommand.scala:58) at kafka.admin.TopicCommand.main(TopicCommand.scala)

启动 Kafka 时出错

Error while launching Kafka

apache-kafka

apache-zookeeper