fix

2026-05-08 19:16:35 +08:00 · 2024-12-27 17:19:46 +08:00
parent df063d29ac
commit 030c4493dc
3 changed files with 19 additions and 10 deletions
@@ -116,7 +116,7 @@ func NewOnlineHistoryRedisConsumerHandler(ctx context.Context, client discovery.
 	och.redisMessageBatches = b
 	och.historyConsumerGroup = historyConsumerGroup

-	return &och, err
+	return &och, nil
 }
 func (och *OnlineHistoryRedisConsumerHandler) do(ctx context.Context, channelID int, val *batcher.Msg[sarama.ConsumerMessage]) {
 	ctx = mcontext.WithTriggerIDContext(ctx, val.TriggerID())