本文讲一下如何在 go-zero 连接 kafka 并引入若干个消费者。 我们先来看一下 go-zero 中的 kafka 配置项： github.com\zeromicro\go-queue@v1.2.2\kq\config.go package kq import "github.com/zeromicro/go-zero/core/…