perf: nsq uses common log (#6)

JieTrancender · May 19, 2022 · b1b323a · b1b323a
1 parent 509ec03
commit b1b323a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/nsqconsumer/manager.go b/internal/nsqconsumer/manager.go
@@ -121,6 +121,7 @@ func (m *manager) updateTopics() {
 			log.Errorf("nsq.NewConsumer fail: %v", err)
 			continue
 		}
+		nsqConsumer.SetLogger(log.StdInfoLogger(), nsq.LogLevelInfo)
 		consumer := &Consumer{
 			topic:    topic,
 			consumer: nsqConsumer,