diff --git a/cmd/kafka-consumer/event_group.go b/cmd/kafka-consumer/event_group.go index c5e4b908dd7..3611aa0ac4d 100644 --- 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 index ac008e9679e..580a31fba52 100644 --- 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)) } }()