diff --git a/src/main/java/com/example/zxweb/controller/KafkaController.java b/src/main/java/com/example/zxweb/controller/KafkaController.java
index 6a7fa0b..6450ae1 100644
--- a/src/main/java/com/example/zxweb/controller/KafkaController.java
+++ b/src/main/java/com/example/zxweb/controller/KafkaController.java
@@ -63,6 +63,7 @@ public class KafkaController {
         consumer.subscribe(Collections.singletonList(topic));
         ConsumerRecords<String, String> records = consumer.poll(100);
         JSONArray jsonArray=new JSONArray();
+        System.out.println("records.count:"+records.count());
         for (ConsumerRecord<String, String> consumerRecord : records) {
             String kfkContent = consumerRecord.value();
             System.out.println(kfkContent);