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 80eeba3f..88e2c1d5 100644 --- a/modules/apps/vehicle-history-app/src/main/resources/application.yml +++ b/modules/apps/vehicle-history-app/src/main/resources/application.yml @@ -33,10 +33,6 @@ lingniu: kafka: enabled: true bootstrap-servers: ${KAFKA_BROKERS:114.55.58.251:9092} - topics: - realtime: ${KAFKA_TOPIC_GB32960_EVENT:vehicle.event.gb32960.v1} - raw-archive: ${KAFKA_TOPIC_GB32960_RAW:vehicle.raw.gb32960.v1} - dlq: ${KAFKA_TOPIC_GB32960_DLQ:vehicle.dlq.gb32960.v1} consumer: enabled: ${KAFKA_CONSUMER_ENABLED:true} client-id-prefix: ${KAFKA_CONSUMER_CLIENT_ID_PREFIX:vehicle-history} 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 facb6bdf..1a9432d2 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 @@ -106,6 +106,7 @@ class VehicleHistoryAppDefaultsTest { .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state.")) .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat.")) .noneMatch(name -> name.startsWith("lingniu.ingest.sink.archive.")) + .noneMatch(name -> name.startsWith("lingniu.ingest.sink.kafka.topics.")) .noneMatch(name -> name.startsWith("lingniu.ingest.event-file-store.")) .noneMatch(name -> name.startsWith("lingniu.ingest.event-history.api.")); assertThat(properties.stringPropertyNames()) @@ -113,6 +114,7 @@ class VehicleHistoryAppDefaultsTest { assertThat(applicationYaml()) .doesNotContain("\n archive:\n") .doesNotContain("sink.archive") + .doesNotContain("raw-archive: ${KAFKA_TOPIC_GB32960_RAW") .doesNotContain("EVENT_HISTORY_SPECIALIZED_API_ENABLED") .doesNotContain("KAFKA_ENABLED"); }