在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。
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接收到的数据:
以上就是Golang之发送消息至kafka的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号