chore: log error

huantt · huantt · commit 34b351a3d37b · 2023-12-04T15:29:42.000+07:00
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)
 		},

Original file line number	Diff line number	Diff line change
`@@ -7,6 +7,7 @@ import (`
`7`	`7`	`"github.com/huantt/kafka-dump/pkg/kafka_utils"`
`8`	`8`	`"github.com/huantt/kafka-dump/pkg/log"`
`9`	`9`	`"github.com/spf13/cobra"`
	`10`	`+ "log/slog"`
`10`	`11`	`"time"`
`11`	`12`	`)`
`12`	`13`
`@@ -85,7 +86,8 @@ func CreateStreamCmd() (*cobra.Command, error) {`
`85`	`86`	`)`
`86`	`87`	`transferredCount, err := streamer.Run()`
`87`	`88`	`if err != nil {`
`88`		`- panic(err)`
	`89`	`+ slog.Error(err.Error())`
	`90`	`+ return`
`89`	`91`	`}`
`90`	`92`	`log.Infof("Transferred %d messages from %s to %s", transferredCount, fromTopic, toTopic)`
`91`	`93`	`},`