From 329f106e3c8febe26b30990669253102de4020da Mon Sep 17 00:00:00 2001 From: lingniu Date: Wed, 1 Jul 2026 15:16:12 +0800 Subject: [PATCH] chore: simplify analytics stat binding --- .../vehicle-analytics-app/src/main/resources/application.yml | 2 +- .../ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/apps/vehicle-analytics-app/src/main/resources/application.yml b/modules/apps/vehicle-analytics-app/src/main/resources/application.yml index 2024c976..25b455ba 100644 --- a/modules/apps/vehicle-analytics-app/src/main/resources/application.yml +++ b/modules/apps/vehicle-analytics-app/src/main/resources/application.yml @@ -49,7 +49,7 @@ lingniu: max-poll-interval-millis: ${KAFKA_CONSUMER_MAX_POLL_INTERVAL_MILLIS:900000} bindings: vehicleStatEnvelopeConsumerProcessor: - enabled: ${VEHICLE_STAT_ENABLED:true} + enabled: true group-id: ${KAFKA_GROUP_STAT:vehicle-stat} topics: - ${KAFKA_TOPIC_JT808_EVENT:vehicle.event.jt808.v1} diff --git a/modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java b/modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java index f6f953a3..f87e64be 100644 --- a/modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java +++ b/modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java @@ -30,7 +30,7 @@ class VehicleAnalyticsAppDefaultsTest { .containsEntry("lingniu.ingest.sink.kafka.consumer.enabled", "${KAFKA_CONSUMER_ENABLED:true}") .containsEntry( "lingniu.ingest.sink.kafka.consumer.bindings.vehicleStatEnvelopeConsumerProcessor.enabled", - "${VEHICLE_STAT_ENABLED:true}") + true) .containsEntry( "lingniu.ingest.sink.kafka.consumer.bindings.vehicleStatEnvelopeConsumerProcessor.group-id", "${KAFKA_GROUP_STAT:vehicle-stat}")