diff --git a/internal/msgtransfer/init.go b/internal/msgtransfer/init.go index 9b5b4b6cc..dd154a3c4 100644 --- a/internal/msgtransfer/init.go +++ b/internal/msgtransfer/init.go @@ -67,6 +67,7 @@ func (m *MsgTransfer) initPrometheus() { func (m *MsgTransfer) Start(prometheusPort int) error { var wg sync.WaitGroup wg.Add(4) + fmt.Println("start msg transfer", "prometheusPort:", prometheusPort) if config.Config.ChatPersistenceMysql { go m.persistentCH.persistentConsumerGroup.RegisterHandleAndConsumer(m.persistentCH) } else {