consumer(ticdc): set one log to debug level, to reduce alloc memory s…

…pace (#12012) close #12016
pingcap · Jan 21, 2025 · ddbfbf2 · ddbfbf2
1 parent ef96454
commit ddbfbf2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cmd/kafka-consumer/event_group.go b/cmd/kafka-consumer/event_group.go
@@ -46,7 +46,7 @@ func (g *eventsGroup) Append(row *model.RowChangedEvent, offset kafka.Offset) {
 	if row.CommitTs > g.highWatermark {
 		g.highWatermark = row.CommitTs
 	}
-	log.Info("DML event received",
+	log.Debug("DML event received",
 		zap.Int32("partition", g.partition),
 		zap.Any("offset", offset),
 		zap.Uint64("commitTs", row.CommitTs),

diff --git a/cmd/kafka-consumer/main.go b/cmd/kafka-consumer/main.go
@@ -87,7 +87,7 @@ func main() {
 		wg.Add(1)
 		go func() {
 			defer wg.Done()
-			if err = http.ListenAndServe("127.0.0.1:6060", nil); err != nil {
+			if err = http.ListenAndServe(":6060", nil); err != nil {
 				log.Panic("cannot start the pprof", zap.Error(err))
 			}
 		}()