kafka创建主题出错：kafka.zookeeper.ZooKeeperClientTimeoutException

按教程Kafka Stream操作时，创建第一个主题后，可以查询、生产和消费，然后关了生产者消费者，创建第二个主题，加了–config cleanup.policy=compact命令，要过一会儿才输出信息，报错，说超时了：swhua@swhua:~/Desktop/kafka_2.13-2.7.0$ bin/kafka-topics.sh --create --zookeeper localho

Bugs清道夫

2334人浏览 · 2021-05-09 17:10:02

Bugs清道夫 · 2021-05-09 17:10:02 发布

按教程Kafka Stream操作时，创建第一个主题后，可以查询、生产和消费，然后关了生产者消费者，创建第二个主题，加了–config cleanup.policy=compact命令，要过一会儿才输出信息，报错，说超时了：

swhua@swhua:~/Desktop/kafka_2.13-2.7.0$ bin/kafka-topics.sh --create --zookeeper localhost:9092 --replication-factor 1 --partitions 1 --topic matchresult --config cleanup.policy=compact
[2021-05-09 16:56:39,279] WARN Client session timed out, have not heard from server in 30000ms for sessionid 0x0 (org.apache.zookeeper.ClientCnxn)
Exception in thread "main" kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
	at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:262)
	at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:119)
	at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1881)
	at kafka.admin.TopicCommand$ZookeeperTopicService$.apply(TopicCommand.scala:376)
	at kafka.admin.TopicCommand$.main(TopicCommand.scala:57)
	at kafka.admin.TopicCommand.main(TopicCommand.scala)