no require return the painc behind

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
 

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