func consume(ctx context.Context) {
// initialize a new reader with the brokers and topic
// the groupID identifies the consumer and prevents
// it from receiving duplicate messages
r := kafka.NewReader(kafka.ReaderConfig{
Brokers: []
func consume(ctx context.Context) {
// initialize a new reader with the brokers and topic
// the groupID identifies the consumer and prevents
// it from receiving duplicate messages
r := kafka.NewReader(kafka.ReaderConfig{
Brokers: []名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号
