Golang发送消息到Kafka教程
在Windows系统下安装Zookeeper和Kafka,并使用Golang向Kafka发送消息的步骤如下:1、安装JAVA-JDK,从Oracle网站下载最新版本的SDK(我使用的是1.8版本)。2、下载并安装Zookeeper3.3.6,下载地址为:http://apache.fayea.com/zookeeper/。3、将conf/zoo_sample.cfg重命名为conf/zoo.cfg。4、编辑conf/zoo.cfg文件,修改dataDir路径为D:\zookeeper-3.3.6\dat
在Windows系统下安装Zookeeper和Kafka,并使用Golang向Kafka发送消息的步骤如下:
1、安装JAVA-JDK,从Oracle网站下载最新版本的SDK(我使用的是1.8版本)。
2、下载并安装Zookeeper 3.3.6,下载地址为:http://apache.fayea.com/zookeeper/。
3、将conf/zoo_sample.cfg重命名为conf/zoo.cfg。
4、编辑conf/zoo.cfg文件,修改dataDir路径为D:\zookeeper-3.3.6\data\。
5、运行bin/zkServer.cmd启动Zookeeper。
启动结果如下:

安装Kafka:
1、访问链接:http://kafka.apache.org/downloads.html,下载Kafka 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接收到的数据:

Windows 10 是一款微软推出的经典操作系统,拥有硬件兼容性与多任务处理能力。它更偏向把系统状态查看和常用调节动作放在一起,适合需要持续观察和微调设备状态的场景。
极度公式是一款跨平台专业LaTeX公式识别编辑软件,支持OCR公式识别和多平台编辑。和使用说明,避免使用,享受完整功能与稳定支持。做扫描整理、文字提取和表格转换时,它能把识别后的处理步骤接得更顺,资料录入这类场景会省下不少时间。
















