main
周文涛 2 years ago
parent be8d266095
commit d4c39b42db

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

Loading…
Cancel
Save