Golang之發(fā)送消息至kafka

windows系統(tǒng)下安裝zookeeperkafka,并使用golang向kafka發(fā)送消息的步驟如下:

1、安裝Java-JDK,從oracle網(wǎng)站下載最新版本的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。

啟動結(jié)果如下:

Golang之發(fā)送消息至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發(fā)送消息的代碼(語言:JavaScript,運行次數(shù):0):


Golang運行結(jié)果:

Golang之發(fā)送消息至kafka

Kafka接收到的數(shù)據(jù):

Golang之發(fā)送消息至kafka

? 版權(quán)聲明
THE END
喜歡就支持一下吧
點贊12 分享