shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: simplify analytics stat binding

Browse Source
This commit is contained in:
lingniu
2026-07-01 15:16:12 +08:00
parent 15c57c33b9
commit 329f106e3c
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
modules/apps/vehicle-analytics-app/src/main/resources/application.yml
View File

@@ -49,7 +49,7 @@ lingniu:
max-poll-interval-millis: ${KAFKA_CONSUMER_MAX_POLL_INTERVAL_MILLIS:900000} max-poll-interval-millis: ${KAFKA_CONSUMER_MAX_POLL_INTERVAL_MILLIS:900000}
bindings: bindings:
vehicleStatEnvelopeConsumerProcessor: vehicleStatEnvelopeConsumerProcessor:
enabled: ${VEHICLE_STAT_ENABLED:true} enabled: true
group-id: ${KAFKA_GROUP_STAT:vehicle-stat} group-id: ${KAFKA_GROUP_STAT:vehicle-stat}
topics: topics:
- ${KAFKA_TOPIC_JT808_EVENT:vehicle.event.jt808.v1} - ${KAFKA_TOPIC_JT808_EVENT:vehicle.event.jt808.v1}

2
modules/apps/vehicle-analytics-app/src/test/java/com/lingniu/ingest/analyticsapp/VehicleAnalyticsAppDefaultsTest.java
View File

@@ -30,7 +30,7 @@ class VehicleAnalyticsAppDefaultsTest {
.containsEntry("lingniu.ingest.sink.kafka.consumer.enabled", "${KAFKA_CONSUMER_ENABLED:true}") .containsEntry("lingniu.ingest.sink.kafka.consumer.enabled", "${KAFKA_CONSUMER_ENABLED:true}")
.containsEntry( .containsEntry(
"lingniu.ingest.sink.kafka.consumer.bindings.vehicleStatEnvelopeConsumerProcessor.enabled", "lingniu.ingest.sink.kafka.consumer.bindings.vehicleStatEnvelopeConsumerProcessor.enabled",
"${VEHICLE_STAT_ENABLED:true}") true)
.containsEntry( .containsEntry(
"lingniu.ingest.sink.kafka.consumer.bindings.vehicleStatEnvelopeConsumerProcessor.group-id", "lingniu.ingest.sink.kafka.consumer.bindings.vehicleStatEnvelopeConsumerProcessor.group-id",
"${KAFKA_GROUP_STAT:vehicle-stat}") "${KAFKA_GROUP_STAT:vehicle-stat}")