updates

src/main/java/com/example/zxweb/utils/KafkaUtil.java

@@ -68,7 +68,7 @@ public class KafkaUtil {
 
         properties.setProperty("enable.auto.commit", "true");
         properties.setProperty("auto.commit.interval.ms", "1000");
-        properties.setProperty("session.timeout.ms", "30000");
+        properties.setProperty("session.timeout.ms", "5000");
         properties.setProperty("auto.offset.reset", "earliest");
         properties.setProperty("ssl.endpoint.identification.algorithm", "");
         return properties;