golang連接kafka的小例子-創(chuàng)新互聯(lián)

package main

import (
	"fmt"
	"github.com/Shopify/sarama"
)

// kafka消費小

func main() {consumer, err := sarama.NewConsumer([]string{"127.0.0.1:9092"}, nil)
	if err != nil {fmt.Println("failed to start consumer err ", err)
		return
	}
	partitionList, err := consumer.Partitions("web_log") //根據(jù)topic取到所有的分區(qū)
	if err != nil {fmt.Println("fail to get list of partition:err", err)
		return
	}
	fmt.Println(partitionList)
	//  遍歷所有分區(qū)
	for partition := range partitionList {pc, err := consumer.ConsumePartition("web_log", int32(partition), sarama.OffsetNewest)
		if err != nil {	fmt.Println("failed to start consumer for partition ", partition, err)
			return
		}
		defer pc.AsyncClose()
		//	異步從每個分區(qū)消費信息
		go func(sarama.Partitioner) {	for msg := range pc.Messages() {		fmt.Println("Partition ", msg.Partition, msg.Offset, msg.Key, msg.Value)
			}
		}(pc)
	}
}

package main

import (
	"fmt"
	"github.com/Shopify/sarama"
)

// kafka消費小

func main() {consumer, err := sarama.NewConsumer([]string{"127.0.0.1:9092"}, nil)
	if err != nil {fmt.Println("failed to start consumer err ", err)
		return
	}
	partitionList, err := consumer.Partitions("web_log") //根據(jù)topic取到所有的分區(qū)
	if err != nil {fmt.Println("fail to get list of partition:err", err)
		return
	}
	fmt.Println(partitionList)
	//  遍歷所有分區(qū)
	for partition := range partitionList {pc, err := consumer.ConsumePartition("web_log", int32(partition), sarama.OffsetNewest)
		if err != nil {	fmt.Println("failed to start consumer for partition ", partition, err)
			return
		}
		defer pc.AsyncClose()
		//	異步從每個分區(qū)消費信息
		go func(sarama.PartitionConsumer) {	for msg := range pc.Messages() {		fmt.Println("Partition ", msg.Partition, msg.Offset, msg.Key, msg.Value)
			}
		}(pc)
	}
}

你是否還在尋找穩(wěn)定的海外服務器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機房具備T級流量清洗系統(tǒng)配攻擊溯源，準確流量調(diào)度確保服務器高可用性，企業(yè)級服務器適合批量采購，新人活動首月15元起，快前往官網(wǎng)查看詳情吧

創(chuàng)新互聯(lián)建站專注于益陽企業(yè)網(wǎng)站建設,成都響應式網(wǎng)站建設公司,商城網(wǎng)站建設。益陽網(wǎng)站建設公司,為益陽等地區(qū)提供建站服務。全流程按需設計，專業(yè)設計，全程項目跟蹤，創(chuàng)新互聯(lián)建站專業(yè)和態(tài)度為您提供的服務

網(wǎng)站名稱：golang連接kafka的小例子-創(chuàng)新互聯(lián)
瀏覽路徑：http://muchs.cn/article2/dhijic.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站營銷、電子商務、網(wǎng)站改版、網(wǎng)站設計公司、小程序開發(fā)、網(wǎng)站維護

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)