golang操作kafka消费消息示例代码

代码语言:golang

所属分类:其他

代码描述:golang操作kafka消费消息示例代码

代码标签: golang 操作 kafka 消费 消息 示例 代码

下面为部分代码预览,完整代码请点击下载或在bfwstudio webide中打开

package main
import (
	"fmt"

	"github.com/Shopify/sarama"
)

func main()  {


    config := sarama.NewConfig()
    config.Consumer.Return.Errors = true


    // consumer
    consumer, err := sarama.NewConsumer([]string{"127.0.0.1:9092"}, config)
    if err != nil {
        fmt.Printf("consumer_test create consumer error %s\n", err.Error())
        return
    }

    defer consumer.Close()

    partition_consumer, err := consumer.ConsumePartition("test", 0, sarama.OffsetOldest)
    if err != .........完整代码请登录后点击上方下载按钮下载查看

网友评论0