From 5a60b8c43ca63477e8d2fbe032bd9726d4af9dd2 Mon Sep 17 00:00:00 2001 From: lingniu Date: Mon, 29 Jun 2026 13:11:25 +0800 Subject: [PATCH] fix: consume jt808 history topics by default --- .../src/main/resources/application.yml | 2 ++ .../ingest/historyapp/VehicleHistoryAppDefaultsTest.java | 8 +++++++- 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/modules/apps/vehicle-history-app/src/main/resources/application.yml b/modules/apps/vehicle-history-app/src/main/resources/application.yml index 41312393..aef384ca 100644 --- a/modules/apps/vehicle-history-app/src/main/resources/application.yml +++ b/modules/apps/vehicle-history-app/src/main/resources/application.yml @@ -54,6 +54,8 @@ lingniu: topics: - ${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.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: enabled: ${SINK_ARCHIVE_ENABLED:true} type: local diff --git a/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java b/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java index 463cc328..9a7cafe3 100644 --- a/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java +++ b/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/VehicleHistoryAppDefaultsTest.java @@ -39,7 +39,13 @@ class VehicleHistoryAppDefaultsTest { "${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.gb32960.v1}") .containsEntry( "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() {