This commit is contained in:
wangchuxiao 2022-09-09 02:05:04 +08:00
parent f41cebe776
commit 5ae9b84cce

View File

@ -79,6 +79,7 @@ func (pc *PersistentConsumerHandler) handleChatWs2Mysql(cMsg *sarama.ConsumerMes
return return
} }
if config.Config.Prometheus.Enable { if config.Config.Prometheus.Enable {
log.NewDebug(msgFromMQ.OperationID, utils.GetSelfFuncName(), "inc msgInsertMysqlProcessed")
msgInsertMysqlProcessed.Inc() msgInsertMysqlProcessed.Inc()
} }
} }