diff --git a/internal/msg_transfer/logic/offline_history_msg_handler.go b/internal/msg_transfer/logic/offline_history_msg_handler.go index c4e78f96d..f8fb6f3af 100644 --- a/internal/msg_transfer/logic/offline_history_msg_handler.go +++ b/internal/msg_transfer/logic/offline_history_msg_handler.go @@ -19,6 +19,7 @@ type OfflineHistoryConsumerHandler struct { } func (mc *OfflineHistoryConsumerHandler) Init(cmdCh chan Cmd2Value) { + log.Debug("ts", config.Config.Kafka.ConsumerGroupID.MsgToMongoOffline, config.Config.Kafka.Ws2mschatOffline.Topic) mc.msgHandle = make(map[string]fcb) mc.cmdCh = cmdCh mc.msgHandle[config.Config.Kafka.Ws2mschatOffline.Topic] = mc.handleChatWs2Mongo