Merge pull request #167 from askuy/feature/fixbugreadmessage

fix read message nil ctx bug
gotomicro · Dec 15, 2021 · 4ad98a8 · 4ad98a8
2 parents cd620c9 + 72814e0
commit 4ad98a8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/ekafka/consumer.go b/ekafka/consumer.go
@@ -125,7 +125,8 @@ func (r *Consumer) ReadLag(ctx context.Context) (lag int64, err error) {
 
 func (r *Consumer) ReadMessage(ctx context.Context) (msg Message, ctxOutput context.Context, err error) {
 	err = r.processor(func(ctx context.Context, msgs Messages, c *cmd) error {
-		msg, err = r.r.ReadMessage(ctxOutput)
+		msg, err = r.r.ReadMessage(ctx)
+		// 在后面才解析了header
 		ctxOutput = r.getCtx(ctx, msg)
 		logCmd(r.logMode, c, "ReadMessage", cmdWithRes(msg), cmdWithMsg(msg))
 		return err