diff --git a/src/main/java/com/dispose/controller/kafkaController.java b/src/main/java/com/dispose/controller/kafkaController.java
index 082154a5..231a188a 100644
--- a/src/main/java/com/dispose/controller/kafkaController.java
+++ b/src/main/java/com/dispose/controller/kafkaController.java
@@ -52,8 +52,6 @@ public class kafkaController {
     /**
      * The Kafka configuration.
      */
-//    final private KafkaConfiguration kafkaConfiguration =
-//            SpringBootBeanUtil.getBean(com.dispose.config.KafkaConfiguration.class);
     @Resource
     private KafkaConfiguration kafkaConfiguration;
 
@@ -92,17 +90,4 @@ public class kafkaController {
         rspInfo.setMessage(new String[]{ErrorCode.ERR_OK.getMsg()});
         return ProtocolRespDTO.result(ErrorCode.ERR_OK, rspInfo);
     }
-
-
-//    @KafkaListener(topics = {"ddos-vip-customer-ck"})
-//    public void kafkaListen(ConsumerRecord<String, String> consumerRecord) {
-//        //判断消息是否为null
-//        Optional<String> kafkaMessage = Optional.ofNullable(consumerRecord.value());
-//        log.info(">>>>>>>>>>> record = " + kafkaMessage);
-//        if (kafkaMessage.isPresent()) {
-//            String consumerMsg = kafkaMessage.get();
-//            log.info("消费消息：" + consumerMsg);
-//        }
-//    }
-
 }