温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

golang怎么连接kafka

发布时间:2023-04-17 10:53:05 来源:亿速云 阅读:85 作者:iii 栏目:开发技术

这篇文章主要介绍“golang怎么连接kafka”,在日常操作中,相信很多人在golang怎么连接kafka问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”golang怎么连接kafka”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!

    1 下载,配置,启动 kafka

    配置修改

    在config目录下的server文件和zookeeper文件,其中分别修改kafka的日志保存路径和zookeeper的数据保存路径。

    golang怎么连接kafka

    启动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()
    	// 生产者配置
    	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()
    	// 发送消息
    	partition,offset,err:=client.SendMessage(msg)
    	if err!=nil {
    		fmt.Println("send failed", err)
    		return
    	}
    	fmt.Printf("partition:%v offset:%v", partition, offset)
    }

    这段代码实现了模拟生产者向kafka发送消息的过程,包含:配置生产者,封装消息,消息类型是 *sarama.ProducerMessage,连接kafka,默认端口是9092,发送消息,返回消息存储的partition和offset日志偏移量。

    3 确认生产者发送成功

    使用kafka自带的命令行消费者客户端查看kafka中的数据
    在kafka的根目录下

    bin/windows/kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic shopping --from-beginning

    这里的topic和代码中的topic一致,均为shopping
    终端会输出之前发送的数据。

    到此,关于“golang怎么连接kafka”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!

    向AI问一下细节

    免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

    AI