fix: update log

huantt · Dec 4, 2023 · ea2216c · ea2216c
1 parent 34b351a
commit ea2216c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/cmd/streamer.go b/cmd/streamer.go
@@ -7,7 +7,6 @@ import (
 	"github.com/huantt/kafka-dump/pkg/kafka_utils"
 	"github.com/huantt/kafka-dump/pkg/log"
 	"github.com/spf13/cobra"
-	"log/slog"
 	"time"
 )
 
@@ -86,7 +85,7 @@ func CreateStreamCmd() (*cobra.Command, error) {
 			)
 			transferredCount, err := streamer.Run()
 			if err != nil {
-				slog.Error(err.Error())
+				log.Error(err.Error())
 				return
 			}
 			log.Infof("Transferred %d messages from %s to %s", transferredCount, fromTopic, toTopic)