From 4ec01fcf1d9c585fe91a6929eca75d1563245a85 Mon Sep 17 00:00:00 2001 From: yangzhen Date: Sun, 12 Feb 2023 21:17:54 +0800 Subject: [PATCH] no require return the painc behind --- pkg/common/kafka/consumer.go | 2 -- pkg/common/kafka/producer.go | 1 - 2 files changed, 3 deletions(-) diff --git a/pkg/common/kafka/consumer.go b/pkg/common/kafka/consumer.go index f794a244c..4e701276d 100644 --- a/pkg/common/kafka/consumer.go +++ b/pkg/common/kafka/consumer.go @@ -28,14 +28,12 @@ func NewKafkaConsumer(addr []string, topic string) *Consumer { consumer, err := sarama.NewConsumer(p.addr, consumerConfig) if err != nil { panic(err.Error()) - return nil } p.Consumer = consumer partitionList, err := consumer.Partitions(p.Topic) if err != nil { panic(err.Error()) - return nil } p.PartitionList = partitionList diff --git a/pkg/common/kafka/producer.go b/pkg/common/kafka/producer.go index 1df0e0ed8..d18875f23 100644 --- a/pkg/common/kafka/producer.go +++ b/pkg/common/kafka/producer.go @@ -37,7 +37,6 @@ func NewKafkaProducer(addr []string, topic string) *Producer { producer, err := sarama.NewSyncProducer(p.addr, p.config) //Initialize the client if err != nil { panic(err.Error()) - return nil } p.producer = producer return &p