From 5deadd06afd496d45e0b2de7078d8fccd42f1352 Mon Sep 17 00:00:00 2001 From: lingniu Date: Wed, 1 Jul 2026 16:22:11 +0800 Subject: [PATCH] chore: trim history kafka topic defaults --- .../vehicle-history-app/src/main/resources/application.yml | 4 ---- .../ingest/historyapp/VehicleHistoryAppDefaultsTest.java | 2 ++ 2 files changed, 2 insertions(+), 4 deletions(-) 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"); }