go-queue
go-queue copied to clipboard
kq如何订阅多个主题
conf.MustLoad("config.json", &c)只能配置一个,要订阅多个难道只有定义多个配置文件?
conf.MustLoad("config.json", &c)只能配置一个,要订阅多个难道只有定义多个配置文件?
我也有这个疑问 一个 consumer 不能订阅多个 topic 吗? 我看底层的 kafka-go 是可以的啊
这个容易,你new多个consumer就好了,然后用ServiceGroup包一下即可。
现在也是启动多个 consumer ,就是配置文件略显繁琐