From afed6cd4f3204f043e350e001ffbd577de41753e Mon Sep 17 00:00:00 2001 From: lingniu Date: Wed, 1 Jul 2026 12:37:17 +0800 Subject: [PATCH] docs: state kafka-only production channel --- README.md | 2 +- .../lingniu/ingest/historyapp/MavenModuleProfileTest.java | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index 66c88d00..8b9ffee5 100644 --- a/README.md +++ b/README.md @@ -99,7 +99,7 @@ Redis 最新状态查询不在默认 Maven reactor 中；需要时使用 `-Popti ## 核心原则 1. **接入与业务落库分离**：协议接入应用只负责收、解析、校验、规整和投递 Kafka；`vehicle-history-app` 写入 TDengine 历史与 RAW JSON，`vehicle-analytics-app` 将 JT808 `daily_mileage_km` 写入 MySQL `vehicle_stat_metric` -2. **Kafka 唯一消息通道**：生产链路不提供 RabbitMQ、RocketMQ 或其他 MQ 后端；接入、历史、统计统一通过 Kafka Envelope 解耦 +2. **Kafka 唯一消息通道**：生产链路只支持 Kafka；接入、历史、统计统一通过 Kafka Envelope 解耦 3. **协议即插拔**：每个 `protocol-*` / `inbound-*` 都可独立开关（`lingniu.ingest..enabled`） 4. **顺序保证**：同一 VIN 严格有序（Disruptor hash + Kafka 分区 key） 5. **幂等消费**：Envelope 带 `eventId`，下游去重 diff --git a/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/MavenModuleProfileTest.java b/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/MavenModuleProfileTest.java index da0d86e2..e8aebf59 100644 --- a/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/MavenModuleProfileTest.java +++ b/modules/apps/vehicle-history-app/src/test/java/com/lingniu/ingest/historyapp/MavenModuleProfileTest.java @@ -178,12 +178,15 @@ class MavenModuleProfileTest { .contains("vehicle-history-app/ TDengine 历史查询 + RAW JSON") .contains("vehicle-analytics-app/ JT808 每日里程指标消费") .contains("协议接入应用只负责收、解析、校验、规整和投递 Kafka") - .contains("生产链路不提供 RabbitMQ、RocketMQ 或其他 MQ 后端") + .contains("生产链路只支持 Kafka") .contains("`vehicle-analytics-app` 将 JT808 `daily_mileage_km` 写入 MySQL `vehicle_stat_metric`") .contains("mvn -pl :gb32960-ingest-app,:jt808-ingest-app,:yutong-mqtt-app,:vehicle-history-app,:vehicle-analytics-app -am package -Dmaven.test.skip=true") .doesNotContain("Spring Boot 3.4") .doesNotContain("Netty 4.1") .doesNotContain("HiveMQ MQTT Client") + .doesNotContain("RabbitMQ") + .doesNotContain("RocketMQ") + .doesNotContain("其他 MQ 后端") .doesNotContain("mvn clean install -DskipTests") .doesNotContain("-DskipTests") .doesNotContain("Caffeine 内存降级")