diff --git a/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/ConsumerWorker.java b/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/ConsumerWorker.java
index 63b766e6..fda4a011 100644
--- a/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/ConsumerWorker.java
+++ b/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/ConsumerWorker.java
@@ -116,7 +116,7 @@ public class ConsumerWorker implements Runnable {
         Object value = record.value();
         String topic = record.topic();
 
-//        logger.info("offset={},topic={},value={}", record.offset(), topic,value);
+        logger.info("offset={},topic={},value={}", record.offset(), topic,value);
         EsGpsInfo esGpsInfo;
         JSONObject jsonObject;
         try {
diff --git a/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java b/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java
index 84c7356d..3d3c639d 100644
--- a/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java
+++ b/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java
@@ -97,9 +97,9 @@ public class RealConsumer implements CommandLineRunner {
             logger.info("Security prepare success.");
         }
 
-        /*kafkaProp.put("security.protocol", "SASL_PLAINTEXT");
+        kafkaProp.put("security.protocol", "SASL_PLAINTEXT");
         kafkaProp.put("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"rsoft\" password=\"rsoft-2024\";");
-        kafkaProp.put("sasl.mechanism", "SCRAM-SHA-256");*/
+        kafkaProp.put("sasl.mechanism", "SCRAM-SHA-256");
         KafkaConsumerRunnable runnable = new KafkaConsumerRunnable(kafkaProp,dtpExecutor2,cityCode);
         executorService.execute(runnable);
     }
diff --git a/stwzhj-modules/stwzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java b/stwzhj-modules/stwzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java
index 632133a2..17bc52d3 100644
--- a/stwzhj-modules/stwzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java
+++ b/stwzhj-modules/stwzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java
@@ -43,6 +43,7 @@ public class RedisOnlineUserSchedule {
             }
             EsGpsInfoVO2 vo2 = BeanUtil.toBean(job, EsGpsInfoVO2.class);
             if (1 == vo2.getOnline() && DateUtil.between(vo2.getGpsTime(), new Date(), DateUnit.SECOND) > 1800L){
+                vo2.setOnline(0);
                 gpsInfoVO2s.add(vo2);
             }
         }