Skip to content

Commit

Permalink
Merge pull request #132 from chensanle/master
Browse files Browse the repository at this point in the history
fix(consumer): remove no used placeholder of "%v"
  • Loading branch information
shabicheng authored Aug 30, 2021
2 parents e084cf3 + df4bfa5 commit f1670fc
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion consumer/worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -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() {
Expand Down

0 comments on commit f1670fc

Please sign in to comment.