chore: log error

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