问题描述
我是 Kafka 的新手,我正在尝试设置本地主机集群。
问题:完成设置后,我无法确认我的消息是否已生成或消费。
我所做的步骤:
第 1 步 - 动物园管理员
我确实安装了 zookeeper
并使用本地 telnet 连接和 ruok
命令(在默认端口 2181 上)验证它已启动并运行。
第 2 步 - 配置
我有 3 个文件夹,每个文件夹都包含我从 kafka official quickstart 下载的 kafka。在每个文件夹中,我都对本地 config/server.properties
进行了如下修改:
我已经为其他人设置了 broker.id=1
,然后是 2
和 3
我已经为其他人设置了 listeners=PLAINTEXT://:9093
,然后是 9094
和 9095
我已将 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 (将#修改为@)