kafka golang github.com/Shopify/sarama

https://github.com/Shopify/sarama
https://godoc.org/github.com/Shopify/sarama

看官网,跑例子

bash1: bin/zookeeper-server-start.sh config/zookeeper.properties
bash2: bin/kafka-server-start.sh config/server.properties
# 这里的important是github.com/Shopify/sarama里example的topic名字
bash3: bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic important --from-beginning

http://kafka.apache.org/quickstart

go get github.com/Shopify/sarama
cd $GOPATH/github.com/Shopify/sarama/example
go build
./http_server -brokers 127.0.0.1:9092[,other brokers]

3的那个例子默认跑在8080端口,访问http://IP:8080/?age=18
就可以从步骤1里的bash3里看到age=18

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容