文件名称：delay-queue:golang实现github.comShopifysarama实现kafka延迟幅度
文件大小：15KB
文件格式：ZIP
更新时间：2024-04-08 10:51:24
Go
延迟队列 golang实现github.com/Shopify/sarama实现kafka延迟幅度 标记立起来；代码码起来；有时间了整理下代码； 有人关注再贴代码； 部署 docker-compose部署单机kafka
【文件预览】：
delay-queue-main
----conf()
--------conf.go(918B)
----config.yaml(207B)
----deploy()
--------kafka()
----consumer()
--------payload.go(1KB)
--------delay_consumer.go(2KB)
--------conn.go(581B)
--------delay.go(2KB)
----.golangci.yaml(4KB)
----LICENSE(11KB)
----main.go(396B)
----.gitignore(282B)
----go.sum(5KB)
----README.md(227B)
----.editorconfig(438B)
----go.mod(265B)