diff --git a/consumer/worker.go b/consumer/worker.go index 2a1d8ccc..8167a789 100644 --- a/consumer/worker.go +++ b/consumer/worker.go @@ -48,7 +48,7 @@ func (consumerWorker *ConsumerWorker) StopAndWait() { consumerWorker.workerShutDownFlag.Store(true) consumerWorker.consumerHeatBeat.shutDownHeart() consumerWorker.waitGroup.Wait() - level.Info(consumerWorker.Logger).Log("msg", "consumer worker %v stopped", "consumer name", consumerWorker.client.option.ConsumerName) + level.Info(consumerWorker.Logger).Log("msg", "consumer worker stopped", "consumer name", consumerWorker.client.option.ConsumerName) } func (consumerWorker *ConsumerWorker) run() {