golang怎么连接kafka

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

1 下载，配置，启动 kafka

配置修改

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

启动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 mainimport ("fmt""time""github.com/Shopify/sarama")func main() {config:=sarama.NewConfig()// 生产者配置config.Producer.RequiredAcks=sarama.WaitForAllconfig.Producer.Partitioner=sarama.NewRandomPartitionerconfig.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)// 连接kafkaclient,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”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注编程网网站，小编会继续努力为大家带来更多实用的文章！