From 6b34b8e966ede56b4cd14c5916c8552ad8f37743 Mon Sep 17 00:00:00 2001 From: raffis Date: Mon, 25 Oct 2021 14:19:56 +0200 Subject: [PATCH] use error instead panic (#6) --- kafka/connection.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/kafka/connection.go b/kafka/connection.go index fba4ef4..9db1d88 100644 --- a/kafka/connection.go +++ b/kafka/connection.go @@ -3,12 +3,13 @@ package kafka import ( "context" "fmt" - "github.com/pkg/errors" - k "github.com/segmentio/kafka-go" "math" "net" "strconv" "time" + + "github.com/pkg/errors" + k "github.com/segmentio/kafka-go" ) const ( @@ -192,7 +193,7 @@ func (c *Connection) GetTopic(name string) (*Topic, error) { partitions, err := conn.ReadPartitions() if err != nil { - panic(err.Error()) + return nil, err } var numberOfPartitions int64 = 0