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() {