chore: fix unit tests

zeromicro · Jul 15, 2024 · 6d208e8 · 6d208e8
1 parent ee8828d
commit 6d208e8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kq/queue.go b/kq/queue.go
@@ -160,9 +160,9 @@ func newKafkaQueue(c KqConf, handler ConsumeHandler, options queueOptions) queue
 		errorHandler:     options.errorHandler,
 	}
 	q.commitRunner = threading.NewStableRunner(func(msg kafka.Message) kafka.Message {
-		if err := q.consumeOne(string(msg.Key), string(msg.Value)); err != nil {
+		if err := q.consumeOne(context.Background(), string(msg.Key), string(msg.Value)); err != nil {
 			if q.errorHandler != nil {
-				q.errorHandler(msg, err)
+				q.errorHandler(context.Background(), msg, err)
 			}
 		}