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