apache-kafka 创建名为tweets的Kafka主题时出错

nhn9ugyo  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(167)

我正在尝试使用Kafka创建一个主题,我目前使用的是Kafka版本:kafka_2.13-3.3.1。我第一次启动Kafka时使用的是以下命令:

bin/zookeeper-server-start.sh config/zookeeper.properties & bin/kafka-server-start.sh config/server.properties

我目前正在Windows Ubuntu WSL窗口中运行Kafka,我正在尝试创建一个Kafka主题,如下所示:

bin/kafka-console-consumer.sh --topic tweets --from-beginning --bootstrap-server localhost:9092

一旦我运行这个命令我得到2个警告,但没有命令实际失败,我不知道是什么错误。这是我得到的警告:

[2022-10-11 13:52:03,869] WARN [Consumer clientId=console-consumer, groupId=console-consumer-3781] Error while fetching metadata with correlation id 2 : {tweets=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2022-10-11 13:52:03,977] WARN [Consumer clientId=console-consumer, groupId=console-consumer-3781] Error while fetching metadata with correlation id 4 : {tweets=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

我看过类似的堆栈溢出问题,关于未能创建主题,但似乎没有一个能解决我的问题。

tv6aics1

tv6aics11#

消费一个主题并不能创造它。
您需要首先使用kafka-topics --create。您可能还希望在使用之前向其中实际生成数据...
此外,从Kafka3.3.1开始,您不需要Zookeeper
https://kafka.apache.org/quickstart

相关问题