跳转到主内容
极星编程网:以代码为星,赴技术山海!

Golang之发送消息至kafka

在 windows 系统下安装zookeeper和kafka,并使用 golang 向kafka发送消息的步骤如下: 1、安装JAVA-JDK,从Oracle网站下载最新版本的SDK(我使用的是1.8版本)。 2、下载并安装Zookeeper 3.3.6,下载地址为: https://www.php.cn/link/908e7269a79d86b43f0eaf58b11dbb12 。 3、将conf/zoo_sample.cfg重命名为conf/zoo.cfg。 4、编辑conf/zoo.cfg文件,修改dataDir路径为D:\zookeeper-3.3.6\data\。 立即学习 “ go语言免费学习笔记(深入) ”; 5、运行bin/zkServer.cmd启动Zookeeper。 启动结果如下: 安装Kafka: 1、访问链接: https://www.php.cn/link/b686adaf81d4411bdd309a48fcea9954 2.1.2版本。 2、打开config目录下的server.properties文件,修改log.dirs路径为D:\kafka_logs。 通义灵码 windows版 通义灵码 0.8.0 是一款面向智能开发场景的轻量级集成开发环境。该版本聚焦效率与协作,提供代码智能补全、实时语法检查与版本管理功能,并优化了插件扩展能力,适配主流编程语言。0.8.0 版本进一步提升了启动速度与界面响应流畅度,内置任务运行器与调试工具,帮助开发者更快捷地完成项目构建与问题定位。简洁、现代的设计让初学者与专业团队都能快速上手。 下载 3、修改advertised.host.name为服务器的IP地址。 4、启动Kafka,运行./bin/windows/kafka-server-start.bat ./config/server.properties。 Kafka与Zookeeper的连接: Kafka提供了一个命令行消费者,用于接收消息并打印到标准输出。
bin/kafka-console-consumer.bat --zookeeper 127.0.0.1:2181 --topic nginx_log
使用Golang向Kafka发送消息的代码(语言:JavaScript,运行次数:0):
Golang运行结果: Kafka接收到的数据:

相关文章