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

fix: consume jt808 history topics by default

Browse Source
This commit is contained in:
lingniu
2026-06-29 13:11:25 +08:00
parent feb9552234
commit 5a60b8c43c
2 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -54,6 +54,8 @@ lingniu:
topics: topics:
- ${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.gb32960.v1} - ${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.gb32960.v1}
- ${KAFKA_TOPIC_GB32960_RAW:vehicle.raw.gb32960.v1} - ${KAFKA_TOPIC_GB32960_RAW:vehicle.raw.gb32960.v1}
- ${KAFKA_TOPIC_JT808_EVENT:vehicle.event.jt808.v1}
- ${KAFKA_TOPIC_JT808_RAW:vehicle.raw.jt808.v1}
archive: archive:
enabled: ${SINK_ARCHIVE_ENABLED:true} enabled: ${SINK_ARCHIVE_ENABLED:true}
type: local type: local

8
modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java
View File

@@ -39,7 +39,13 @@ class VehicleHistoryAppDefaultsTest {
"${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.gb32960.v1}") "${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.gb32960.v1}")
.containsEntry( .containsEntry(
"lingniu.ingest.sink.mq.consumer.bindings.eventHistoryEnvelopeConsumerProcessor.topics[1]", "lingniu.ingest.sink.mq.consumer.bindings.eventHistoryEnvelopeConsumerProcessor.topics[1]",
"${KAFKA_TOPIC_GB32960_RAW:vehicle.raw.gb32960.v1}"); "${KAFKA_TOPIC_GB32960_RAW:vehicle.raw.gb32960.v1}")
.containsEntry(
"lingniu.ingest.sink.mq.consumer.bindings.eventHistoryEnvelopeConsumerProcessor.topics[2]",
"${KAFKA_TOPIC_JT808_EVENT:vehicle.event.jt808.v1}")
.containsEntry(
"lingniu.ingest.sink.mq.consumer.bindings.eventHistoryEnvelopeConsumerProcessor.topics[3]",
"${KAFKA_TOPIC_JT808_RAW:vehicle.raw.jt808.v1}");
} }
private static Properties applicationProperties() { private static Properties applicationProperties() {