百度消息服务是分布式、高可扩展、高通量的托管消息队列服务。完全兼容开源Kafka。本样例展示如何使用sarama客户端访问百度消息服务。
准备工作的细节请参考BCE官网帮助文档
- 在管理控制台中创建好主题，并获取主题名称topic_name。
- 在管理控制台中下载您的kafka-key.zip，包含Go程序使用的
client.pem，client.key，ca.pem。 - 用上一步的文件替换样例代码中的
client.pem、client.key以及ca.pem。
go get github.com/IBM/sarama
将samples加入GOPATH，分别在consumer、producer目录下执行：
go build
在consumer目录下
consumer -topic=topic_name
在producer目录下
producer -topic=topic_name