我是 Kafka 的新手,我正在尝试设置一个 localhost 集群。
问题:完成设置后,我无法确认我的消息是否已生成或使用它们。
我所做的步骤:
第 1 步 - 动物园管理员
我确实zookeeper
使用本地 telnet 连接和ruok
命令(在默认端口 2181 上)安装并验证它已启动并运行。
第 2 步 - 配置
我有 3 个文件夹,每个文件夹都包含我从kafka 官方快速入门下载的 kafka 。在每个文件夹中,我对本地进行了config/server.properties
如下修改:
我已经设置了broker.id=1
,然后2
和3
其他人
我已经设置了listeners=PLAINTEXT://:9093
,然后9094
和 9095
其他人
我设置logs.dir=
了一个本地日志目录,其中每个代理都有一个子目录
第 3 步 - 启动
我已经使用bin/kafka-server-start.sh config/server.properties
3 个 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}
任何想法我做错了什么?非常感谢 !凯夫!