test

internal/msg_transfer/logic/offline_history_msg_handler.go

@@ -105,7 +105,7 @@ func (mc *OfflineHistoryConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupS
 	//}
 	for msg := range claim.Messages() {
 		if GetOnlineTopicStatus() == OnlineTopicVacancy {
-			log.NewDebug("", "kafka get info to mongo", "msgTopic", msg.Topic, "msgPartition", msg.Partition, "msg", string(msg.Value))
+			log.NewDebug("", "offline kafka get info to mongo", "msgTopic", msg.Topic, "msgPartition", msg.Partition, "msg", string(msg.Value))
 			mc.msgHandle[msg.Topic](msg.Value, string(msg.Key))
 			sess.MarkMessage(msg, "")
 		} else {

internal/msg_transfer/logic/online_history_msg_handler.go

@@ -137,7 +137,7 @@ func (och *OnlineHistoryConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupS
 	for msg := range claim.Messages() {
 		SetOnlineTopicStatus(OnlineTopicBusy)
 		//och.TriggerCmd(OnlineTopicBusy)
-		log.NewDebug("", "kafka get info to mongo", "msgTopic", msg.Topic, "msgPartition", msg.Partition, "online", msg.Offset, claim.HighWaterMarkOffset())
+		log.NewDebug("", "online kafka get info to mongo", "msgTopic", msg.Topic, "msgPartition", msg.Partition, "online", msg.Offset, claim.HighWaterMarkOffset())
 		och.msgHandle[msg.Topic](msg.Value, string(msg.Key))
 		sess.MarkMessage(msg, "")
 		if claim.HighWaterMarkOffset()-msg.Offset <= 1 {