diff --git a/src/kafka/src/ConsumerManager.php b/src/kafka/src/ConsumerManager.php
index a69e86b6d..70d37023f 100644
--- a/src/kafka/src/ConsumerManager.php
+++ b/src/kafka/src/ConsumerManager.php
@@ -15,6 +15,7 @@ namespace Hyperf\Kafka;
 use Hyperf\Contract\ConfigInterface;
 use Hyperf\Contract\StdoutLoggerInterface;
 use Hyperf\Di\Annotation\AnnotationCollector;
+use Hyperf\Kafka\AbstractConsumer;
 use Hyperf\Kafka\Annotation\Consumer as ConsumerAnnotation;
 use Hyperf\Kafka\Event\AfterConsume;
 use Hyperf\Kafka\Event\BeforeConsume;
@@ -34,6 +35,7 @@ use longlang\phpkafka\Socket\SwooleSocket;
 use Psr\Container\ContainerInterface;
 use Psr\EventDispatcher\EventDispatcherInterface;
 
+
 class ConsumerManager
 {
     /**