update queue consumer args

zeromicro · Jun 15, 2023 · e558d4d · e558d4d
1 parent 56979d5
commit e558d4d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/docs/tutorials/queue/kafka.md b/docs/tutorials/queue/kafka.md
@@ -258,7 +258,7 @@ func main() {
     serviceGroup := service.NewServiceGroup()
     defer serviceGroup.Stop()
 
-    for _, mq := range mqs.Consumers(ctx, svcCtx) {
+    for _, mq := range mqs.Consumers(c,ctx, svcCtx) {
         serviceGroup.Add(mq)
     }