From a5f5cc94ee11f3ca8eec5f16981123373c0e7d5b Mon Sep 17 00:00:00 2001
From: lingniu <lingniu@lingnius-Mac-mini.local>
Date: Wed, 1 Jul 2026 02:25:35 +0800
Subject: [PATCH] refactor: drop xinda history consumer wiring

---
 .../VehicleHistoryKafkaConsumerConfiguration.java           | 4 +---
 .../ingest/historyapp/VehicleHistoryAppDefaultsTest.java    | 6 ------
 2 files changed, 1 insertion(+), 9 deletions(-)

diff --git a/modules/apps/vehicle-history-app/src/main/java/com/lingniu/ingest/historyapp/VehicleHistoryKafkaConsumerConfiguration.java b/modules/apps/vehicle-history-app/src/main/java/com/lingniu/ingest/historyapp/VehicleHistoryKafkaConsumerConfiguration.java
index b66239a5..ac993058 100644
--- a/modules/apps/vehicle-history-app/src/main/java/com/lingniu/ingest/historyapp/VehicleHistoryKafkaConsumerConfiguration.java
+++ b/modules/apps/vehicle-history-app/src/main/java/com/lingniu/ingest/historyapp/VehicleHistoryKafkaConsumerConfiguration.java
@@ -73,12 +73,10 @@ public class VehicleHistoryKafkaConsumerConfiguration {
                         "eventHistoryGb32960EnvelopeConsumerProcessor", processor,
                         "eventHistoryJt808EnvelopeConsumerProcessor", processor,
                         "eventHistoryYutongMqttEnvelopeConsumerProcessor", processor,
-                        "eventHistoryXindaPushEnvelopeConsumerProcessor", processor,
                         "eventHistoryRawEnvelopeConsumerProcessor", rawProcessor,
                         "eventHistoryGb32960RawEnvelopeConsumerProcessor", rawProcessor,
                         "eventHistoryJt808RawEnvelopeConsumerProcessor", rawProcessor,
-                        "eventHistoryYutongMqttRawEnvelopeConsumerProcessor", rawProcessor,
-                        "eventHistoryXindaPushRawEnvelopeConsumerProcessor", rawProcessor),
+                        "eventHistoryYutongMqttRawEnvelopeConsumerProcessor", rawProcessor),
                 props);
         if (workers.isEmpty()) {
             throw new IllegalStateException("no vehicle history kafka consumer workers created; check consumer bindings");
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 3e5600e1..8155f1c3 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
@@ -102,12 +102,6 @@ class VehicleHistoryAppDefaultsTest {
                 .containsEntry(
                         "lingniu.ingest.sink.mq.consumer.bindings.eventHistoryYutongMqttRawEnvelopeConsumerProcessor.topics[0]",
                         "${KAFKA_TOPIC_YUTONG_MQTT_RAW:vehicle.raw.mqtt-yutong.v1}");
-
-        assertThat(properties)
-                .doesNotContainKey(
-                        "lingniu.ingest.sink.mq.consumer.bindings.eventHistoryXindaPushEnvelopeConsumerProcessor.enabled")
-                .doesNotContainKey(
-                        "lingniu.ingest.sink.mq.consumer.bindings.eventHistoryXindaPushRawEnvelopeConsumerProcessor.enabled");
     }
 
     private static Properties applicationProperties() {