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") //根據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") //根據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)新互聯www.cdcxhl.cn海外機房具備T級流量清洗系統(tǒng)配攻擊溯源，準確流量調度確保服務器高可用性，企業(yè)級服務器適合批量采購，新人活動首月15元起，快前往官網查看詳情吧

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

網站名稱：golang連接kafka的小例子-創(chuàng)新互聯
瀏覽路徑：http://chinadenli.net/article2/dhijic.html

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

廣告

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