From c3b16aa678a2b66d2783988bfc1b065d1955d32b Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Wed, 10 May 2023 17:21:58 +0800 Subject: [PATCH] ctx --- internal/msgtransfer/online_history_msg_handler.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/msgtransfer/online_history_msg_handler.go b/internal/msgtransfer/online_history_msg_handler.go index 208791475..f3585a66d 100644 --- a/internal/msgtransfer/online_history_msg_handler.go +++ b/internal/msgtransfer/online_history_msg_handler.go @@ -286,7 +286,7 @@ func (och *OnlineHistoryRedisConsumerHandler) ConsumeClaim(sess sarama.ConsumerG rwLock.Unlock() split := 1000 ctx := mcontext.NewCtx(utils.OperationIDGenerator()) - ctx = mcontext.WithTriggerIDContext(context.Background(), utils.OperationIDGenerator()) + ctx = mcontext.WithTriggerIDContext(ctx, utils.OperationIDGenerator()) log.ZDebug(ctx, "timer trigger msg consumer start", "length", len(ccMsg)) for i := 0; i < len(ccMsg)/split; i++ { //log.Debug()