From 2487c030e2ce4080679a625b7c5a54c422a61f44 Mon Sep 17 00:00:00 2001 From: Fredrick Widjaya Date: Mon, 25 Dec 2023 21:50:47 +0700 Subject: [PATCH] remove logging --- event/kafka_driver.go | 7 ------- 1 file changed, 7 deletions(-) diff --git a/event/kafka_driver.go b/event/kafka_driver.go index c2bc36f..704d408 100644 --- a/event/kafka_driver.go +++ b/event/kafka_driver.go @@ -7,7 +7,6 @@ import ( "reflect" "sync" - "github.com/Shopify/sarama" "github.com/ThreeDotsLabs/watermill" "github.com/ThreeDotsLabs/watermill-kafka/v2/pkg/kafka" "github.com/ThreeDotsLabs/watermill/message" @@ -146,12 +145,6 @@ func (d *KafkaDriver) providePublisher() error { } func (d *KafkaDriver) provideSubscriber() error { - d.Logger.WithFields(logrus.Fields{ - "Offset": d.InitialOffset, - "To Sarama Offset": d.InitialOffset.SaramaOffset(), - "Sarama Offset": sarama.OffsetOldest, - }).Info("FIND THIS") - if d.subscriber != nil { return nil }