设置 Kafka 集群时遇到问题

问题描述

我是 Kafka 的新手,我正在尝试设置本地主机集群。

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

我所做的步骤:

第 1 步 - 动物园管理员

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

第 2 步 - 配置

我有 3 个文件夹,每个文件夹都包含我从 kafka official quickstart 下载的 kafka。在每个文件夹中,我都对本地 config/server.properties 进行了如下修改

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

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

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

第 3 步 - 启动

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

第 4 步 - 主题

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

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

第 5 步 - 测试

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

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}

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

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)