百度消息服务Golang样例

百度消息服务是分布式、高可扩展、高通量的托管消息队列服务。完全兼容开源Kafka。本样例展示如何使用sarama客户端访问百度消息服务。

环境要求

• Go 1.8, 1.7
• sarama 1.10以上(支持kafka 0.10)

准备工作

准备工作的细节请参考BCE官网帮助文档

1. 在管理控制台中创建好主题，并获取主题名称topic_name。
2. 在管理控制台中下载您的kafka-key.zip，包含Go程序使用的client.pem，client.key，ca.pem。
3. 用上一步的文件替换样例代码中的client.pem、client.key以及ca.pem。

运行样例代码

安装sarama及其依赖

go get github.com/IBM/sarama

构建与执行

将samples加入GOPATH，分别在consumer、producer目录下执行：

go build

运行样例代码

在consumer目录下

consumer -topic=topic_name

在producer目录下

producer -topic=topic_name

参考链接

• 百度消息服务产品介绍
• Kafka
• sarama
• Go Getting Started