文件名称：go_kafka:去卡夫卡
文件大小：24KB
文件格式：ZIP
更新时间：2024-07-30 12:12:01
Go
kafka - Go 中 Kafka 的发布者和消费者 Kafka 是一个分布式发布订阅消息系统：（ ） Go语言：（ ） 分叉自： : 。 变化 4/13 - 从 apache 存储库合并回来并应用了 jira 的未完成补丁 启动并运行 安装 go（版本 1）： 有关更多信息，请参阅： : 确保正确设置您的 GOROOT ( )。 还要适当地设置你的 GOPATH： ://weekly.golang.org/doc/code.html#tmp_13 从源代码构建： make kafka 制作工具（发布者和消费者） make tools 启动zookeeper、Kafka服务器有关 Kafka 的更多信息，请参阅： : 工具 启动一个消费者： $GOPATH/bin/consumer -topic test -consumeforever Consu
【文件预览】：
go_kafka-master
----publisher.go(2KB)
----message.go(6KB)
----kafka_test.go(9KB)
----consumer.go(6KB)
----.travis.yml(26B)
----LICENSE(11KB)
----tools()
--------consumer()
--------publisher()
--------offsets()
----request.go(3KB)
----README.md(2KB)
----Makefile(307B)
----payload_codec.go(3KB)
----converts.go(1KB)
----timing.go(1KB)
----.gitignore(357B)
----kafka.go(3KB)