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

chore: trim history kafka topic defaults

Browse Source
This commit is contained in:
lingniu
2026-07-01 16:22:11 +08:00
parent ccf77b4596
commit 5deadd06af
2 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -33,10 +33,6 @@ lingniu:
kafka: kafka:
enabled: true enabled: true
bootstrap-servers: ${KAFKA_BROKERS:114.55.58.251:9092} 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: consumer:
enabled: ${KAFKA_CONSUMER_ENABLED:true} enabled: ${KAFKA_CONSUMER_ENABLED:true}
client-id-prefix: ${KAFKA_CONSUMER_CLIENT_ID_PREFIX:vehicle-history} client-id-prefix: ${KAFKA_CONSUMER_CLIENT_ID_PREFIX:vehicle-history}

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

@@ -106,6 +106,7 @@ class VehicleHistoryAppDefaultsTest {
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state.")) .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-state."))
.noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat.")) .noneMatch(name -> name.startsWith("lingniu.ingest.vehicle-stat."))
.noneMatch(name -> name.startsWith("lingniu.ingest.sink.archive.")) .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-file-store."))
.noneMatch(name -> name.startsWith("lingniu.ingest.event-history.api.")); .noneMatch(name -> name.startsWith("lingniu.ingest.event-history.api."));
assertThat(properties.stringPropertyNames()) assertThat(properties.stringPropertyNames())
@@ -113,6 +114,7 @@ class VehicleHistoryAppDefaultsTest {
assertThat(applicationYaml()) assertThat(applicationYaml())
.doesNotContain("\n archive:\n") .doesNotContain("\n archive:\n")
.doesNotContain("sink.archive") .doesNotContain("sink.archive")
.doesNotContain("raw-archive: ${KAFKA_TOPIC_GB32960_RAW")
.doesNotContain("EVENT_HISTORY_SPECIALIZED_API_ENABLED") .doesNotContain("EVENT_HISTORY_SPECIALIZED_API_ENABLED")
.doesNotContain("KAFKA_ENABLED"); .doesNotContain("KAFKA_ENABLED");
} }