redis add get message

3 years ago · 4571a3b50b
parent b48197c8aa
commit 4571a3b50b
1 changed files with 1 additions and 0 deletions
--- a/internal/msg_transfer/logic/online_history_msg_handler.go
+++ b/internal/msg_transfer/logic/online_history_msg_handler.go
@ -479,6 +479,7 @@ func (och *OnlineHistoryConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupS
 				cMsg = make([]*sarama.ConsumerMessage, 0, 1000)
 				log.Debug(triggerID, "timer trigger msg consumer end", len(cMsg))
 			}
 		default:
 		}
 		//log.NewDebug("", "online kafka get info to mongo", "msgTopic", msg.Topic, "msgPartition", msg.Partition, "online", msg.Offset, claim.HighWaterMarkOffset())