0

我是 Kafka 的新手,我正在尝试设置一个 localhost 集群。

问题:完成设置后,我无法确认我的消息是否已生成或使用它们。

我所做的步骤:

第 1 步 - 动物园管理员

我确实zookeeper使用本地 telnet 连接和ruok命令(在默认端口 2181 上)安装并验证它已启动并运行。

第 2 步 - 配置

我有 3 个文件夹,每个文件夹都包含我从kafka 官方快速入门下载的 kafka 。在每个文件夹中,我对本地进行了config/server.properties如下修改:

我已经设置了broker.id=1,然后23其他人

我已经设置了listeners=PLAINTEXT://:9093,然后90949095其他人

我设置logs.dir=了一个本地日志目录,其中每个代理都有一个子目录

第 3 步 - 启动

我已经使用bin/kafka-server-start.sh config/server.properties3 个 kafka 文件夹中的命令启动了所有 3 台服务器,每台服务器都使用它自己的本地配置

第 4 步 - 主题

我使用以下命令从三个 kafka 文件夹之一创建了一个共享主题:

bin/kafka-topics.sh --create --topic topic-1 --zookeeper localhost:2181 --partitions 3 --replication-factor 3

第 5 步 - 测试

好的,现在要测试一切是否正常运行,我尝试了两种方法第一种是使用 CLI 并手动添加消息,从任何 kafkabin文件夹中,我使用了这两个命令:

kafka-console-producer.sh --broker-list localhost:9093,localhost:9094,localhost:9095 –topic topic-1

kafka-console-consumer.sh --bootstrap-server localhost:9093 --topic topic-1 --from-beginning

但是,当添加消息时,消费者端似乎什么都没有发生。关闭它时,我有Processed a total of 0 messages消息。

我还尝试使用该kafkajs库与消费者和生产者一起制作“hello world”类型脚本,但出现此错误:

{"level":"ERROR","timestamp":"2021-05-10T09:09:57.464Z","logger":"kafkajs","message":"[Connection] Response GroupCoordinator(key: 10, version: 2)","broker":"kevin-UX390UAK:9093","clientId":"my-app","error":"The group coordinator is not available","correlationId":0,"size":55}

任何想法我做错了什么?非常感谢 !凯夫!

4

0 回答 0