我正在尝试使用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)
我看过类似的堆栈溢出问题,关于未能创建主题,但似乎没有一个能解决我的问题。
1条答案
按热度按时间tv6aics11#
消费一个主题并不能创造它。
您需要首先使用
kafka-topics --create
。您可能还希望在使用之前向其中实际生成数据...此外,从Kafka3.3.1开始,您不需要Zookeeper
https://kafka.apache.org/quickstart