remove logging

fwidjaya20 · Dec 25, 2023 · 2487c03 · 2487c03
1 parent f82ca07
commit 2487c03
Showing 1 changed file with 0 additions and 7 deletions.
diff --git 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
 	}