golang連接kafka的示例代碼
更新時間：2023年04月17日 09:23:16 作者：摔跤吧兒
本文主要介紹了golang連接kafka的示例代碼，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
1 下載，配置，啟動 kafka
配置修改
在config目錄下的server文件和zookeeper文件，其中分別修改kafka的日志保存路徑和zookeeper的數(shù)據(jù)保存路徑。
啟動kafka
先啟動kafka自帶的zookeeper，在kafka的根目錄下打開終端，使用配置文件啟動
./bin/windows/zookeeper-server-start.bat config/zookeeper.properties
同樣在kafka目錄的根目錄下啟動kafka
./bin/windows/kafka-server-start.bat config/server.properties
2 使用golang的github.com/Shopify/sarama庫連接kafka
package main
import (
"fmt"
"time"
"github.com/Shopify/sarama"
)
func main() {
config:=sarama.NewConfig()
// 生產(chǎn)者配置
config.Producer.RequiredAcks=sarama.WaitForAll
config.Producer.Partitioner=sarama.NewRandomPartitioner
config.Producer.Return.Successes=true
// 封裝消息
msg:=&sarama.ProducerMessage{}
msg.Topic="shopping"
time_str:=time.Now().Format("2006-01-02 15:04:05")
msg.Value=sarama.StringEncoder("0413 test log!"+time_str)
// 連接kafka
client,err:=sarama.NewSyncProducer([]string{"127.0.0.1:9092"}, config)
if err!=nil {
fmt.Println("producer closed", err)
return
}
defer client.Close()
// 發(fā)送消息
partition,offset,err:=client.SendMessage(msg)
if err!=nil {
fmt.Println("send failed", err)
return
}
fmt.Printf("partition:%v offset:%v", partition, offset)
}
這段代碼實現(xiàn)了模擬生產(chǎn)者向kafka發(fā)送消息的過程，包含：配置生產(chǎn)者，封裝消息，消息類型是 *sarama.ProducerMessage，連接kafka，默認端口是9092，發(fā)送消息，返回消息存儲的partition和offset日志偏移量。
3 確認生產(chǎn)者發(fā)送成功
使用kafka自帶的命令行消費者客戶端查看kafka中的數(shù)據(jù)
在kafka的根目錄下
bin/windows/kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic shopping --from-beginning
這里的topic和代碼中的topic一致，均為shopping
終端會輸出之前發(fā)送的數(shù)據(jù)。
到此這篇關于golang連接kafka的示例代碼的文章就介紹到這了,更多相關golang連接kafka內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要給大家介紹了關于Golang的命名規(guī)范及最佳實踐的相關資料,命名規(guī)則涉及變量、常量、全局函數(shù)、結構、接口、方法等的命名,文中介紹的非常詳細,需要的朋友可以參考下2023-10-10
golang的時區(qū)和神奇的time.Parse的使用方法
這篇文章主要介紹了golang的時區(qū)和神奇的time.Parse的使用方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-04-04
這篇文章主要介紹了go日志系統(tǒng)logrus顯示文件和行號的操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-11-11
golang?MySQL實現(xiàn)對數(shù)據(jù)庫表存儲獲取操作示例
這篇文章主要為大家介紹了golang?MySQL實現(xiàn)對數(shù)據(jù)庫表存儲獲取操作示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-11-11
這篇文章主要介紹了Go語言中的流程控制結構和函數(shù)詳解,本文詳細講解了if、goto、for、switch等控制語句,同時對函數(shù)相關知識做了講解,需要的朋友可以參考下2014-10-10
這篇文章主要介紹了快速排序算法的原理及其Go語言版實現(xiàn),文中對于快速算法的過程和效率有較為詳細的說明,需要的朋友可以參考下2016-04-04
對于無類型常量，可能大家是第一次聽說，但我們每天都在用，每天都有無數(shù)潛在的坑被埋下。本文就來和大家聊聊它的相關注意事項吧，希望對大家有所幫助2023-03-03
這篇文章主要介紹了go module使用本地包的方法示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-03-03
本文主要介紹了Golang爬蟲及正則表達式的實現(xiàn)示例，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-12-12
這篇文章主要給大家介紹了關于golang利用pprof與go-torch如何做性能分析的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2018-07-07