From 399a8429a76fd1d9c0f68ae9512b1f3949f586d8 Mon Sep 17 00:00:00 2001 From: zhouwentao <1577701412@qq.com> Date: Wed, 20 Sep 2023 19:10:13 +0800 Subject: [PATCH] updates --- src/main/java/com/example/zxweb/utils/KafkaUtil.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/example/zxweb/utils/KafkaUtil.java b/src/main/java/com/example/zxweb/utils/KafkaUtil.java index a6ae2ee..5ec9dae 100644 --- a/src/main/java/com/example/zxweb/utils/KafkaUtil.java +++ b/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;