在windows系統(tǒng)下安裝zookeeper和kafka,并使用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é)果如下:
安裝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é)果:
Kafka接收到的數(shù)據(jù):