diff --git a/common/component/kafka/consumer.go b/common/component/kafka/consumer.go index 5c1aebdbd1..b7ea51240c 100644 --- a/common/component/kafka/consumer.go +++ b/common/component/kafka/consumer.go @@ -53,7 +53,6 @@ func notifyRecover(consumer *consumer, message *sarama.ConsumerMessage, session return err } return nil - } }