From de11c1bc47ab5c7dbb0282e970238871b3aa99c6 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Mon, 25 Jan 2021 12:41:39 +0000 Subject: [PATCH] Reduce logging --- internal/consumers.go | 1 - 1 file changed, 1 deletion(-) diff --git a/internal/consumers.go b/internal/consumers.go index 63dd1d9c7..3a4e0b7f8 100644 --- a/internal/consumers.go +++ b/internal/consumers.go @@ -107,7 +107,6 @@ func (c *ContinualConsumer) StartOffsets() ([]sqlutil.PartitionOffset, error) { go c.consumePartition(pc) if c.Process != nil { c.Process.ComponentStarted() - logrus.Infof("Started consumer for %q topic %q", c.ComponentName, c.Topic) go func(pc sarama.PartitionConsumer) { <-c.Process.WaitForShutdown() _ = pc.Close()