Golang之发送消息至kafka

windows系统下安装zookeeperkafka,并使用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.6data。

立即学习go语言免费学习笔记(深入)”;

5、运行bin/zkServer.cmd启动Zookeeper。

启动结果如下:

Golang之发送消息至kafka

安装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运行结果:

Golang之发送消息至kafka

Kafka接收到的数据:

Golang之发送消息至kafka

© 版权声明
THE END
喜欢就支持一下吧
点赞12 分享