From e5a166d4a30a7965f3ff163c98a4c675fb54866d Mon Sep 17 00:00:00 2001 From: luyya Date: Wed, 10 Sep 2025 09:27:05 +0800 Subject: [PATCH] =?UTF-8?q?=E7=9C=81=E5=8E=85=E4=BD=8D=E7=BD=AE=E6=B1=87?= =?UTF-8?q?=E8=81=9A=E5=8F=91=E9=80=81kafka=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/dromara/data2kafka/consumer/ConsumerWorker.java | 2 +- .../java/org/dromara/data2kafka/consumer/RealConsumer.java | 4 ++-- .../org/dromara/data2es/schedule/RedisOnlineUserSchedule.java | 1 + 3 files changed, 4 insertions(+), 3 deletions(-) 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); } }