From d54cb26a23b94e06c7b0d137ff4e917b8149dca1 Mon Sep 17 00:00:00 2001 From: kennyaz <115052215+kennyaz@users.noreply.github.com> Date: Fri, 14 Jul 2023 14:20:38 -0400 Subject: [PATCH] Clean Up Code Signed-off-by: kennyaz <115052215+kennyaz@users.noreply.github.com> --- cmd/ingester/app/consumer/consumer.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/cmd/ingester/app/consumer/consumer.go b/cmd/ingester/app/consumer/consumer.go index a9a385c92f1..7d9080b68df 100644 --- a/cmd/ingester/app/consumer/consumer.go +++ b/cmd/ingester/app/consumer/consumer.go @@ -15,7 +15,6 @@ package consumer import ( - "fmt" "sync" "time" @@ -97,9 +96,7 @@ func (c *Consumer) Start() { func (c *Consumer) Close() error { // Close the internal consumer, which will close each partition consumers' message and error channels. c.logger.Info("Closing parent consumer") - // close(c.internalConsumer.Partitions()) err := c.internalConsumer.Close() - fmt.Println(err) c.logger.Debug("Closing deadlock detector") c.deadlockDetector.close()