diff --git a/consumer/shard_monitor.go b/consumer/shard_monitor.go index eb739bd9..cf8f4f1b 100644 --- a/consumer/shard_monitor.go +++ b/consumer/shard_monitor.go @@ -8,6 +8,7 @@ import ( sls "github.com/aliyun/aliyun-log-go-sdk" "github.com/aliyun/aliyun-log-go-sdk/internal" "github.com/go-kit/kit/log" + "github.com/go-kit/kit/log/level" ) type MonitorMetrics struct { @@ -68,7 +69,7 @@ func (m *ShardMonitor) shouldReport() bool { func (m *ShardMonitor) reportByLogger(logger log.Logger) { m.lastReportTime = time.Now() metrics := m.getAndResetMetrics() - logger.Log("msg", "report status", + level.Info(logger).Log("msg", "report status", "fetchFailed", metrics.fetchReqFailedCount.Load(), "logRawSize", metrics.logRawSize.Load(), "processFailed", metrics.processFailedCount.Load(), diff --git a/producer/monitor.go b/producer/monitor.go index 10f645fa..0f416252 100644 --- a/producer/monitor.go +++ b/producer/monitor.go @@ -6,6 +6,7 @@ import ( "github.com/aliyun/aliyun-log-go-sdk/internal" "github.com/go-kit/kit/log" + "github.com/go-kit/kit/log/level" ) type ProducerMetrics struct { @@ -74,7 +75,7 @@ func (m *ProducerMonitor) reportThread(reportInterval time.Duration, logger log. ticker := time.NewTicker(reportInterval) for range ticker.C { metrics := m.getAndResetMetrics() - logger.Log("msg", "report status", + level.Info(logger).Log("msg", "report status", "sendBatch", metrics.sendBatch.String(), "retryCount", metrics.retryCount.Load(), "createBatch", metrics.createBatch.Load(),