diff --git a/docs/operations/current-ecs-deployment.md b/docs/operations/current-ecs-deployment.md
index 3c2c3ce8..2a432b7c 100644
--- a/docs/operations/current-ecs-deployment.md
+++ b/docs/operations/current-ecs-deployment.md
@@ -60,13 +60,21 @@
 
 | Topic | 生产者 | 消费者 | 内容 |
 | --- | --- | --- | --- |
-| `vehicle.raw.gb32960.v1` | `gateway` | `history-writer`、`stat-writer` | GB32960 完整 RAW 记录 |
-| `vehicle.raw.jt808.v1` | `gateway` | `history-writer`、`stat-writer` | JT808 完整 RAW 记录 |
-| `vehicle.raw.yutong-mqtt.v1` | `gateway` | `history-writer`、`stat-writer` | 宇通 MQTT 完整 RAW 记录 |
-| `vehicle.event.unified.v1` | `gateway` | `realtime-api` | 三类协议统一事件，用于 Redis 实时状态 |
+| `vehicle.raw.go.gb32960.v1` | `gateway` | `history-writer`、`stat-writer` | GB32960 完整 RAW 记录 |
+| `vehicle.raw.go.jt808.v1` | `gateway` | `history-writer`、`stat-writer` | JT808 完整 RAW 记录 |
+| `vehicle.raw.go.yutong-mqtt.v1` | `gateway` | `history-writer` | 宇通 MQTT 完整 RAW 记录 |
+| `vehicle.event.go.unified.v1` | `gateway` | `realtime-api` | 三类协议统一事件，用于 Redis 实时状态 |
 
 `gateway` 配置了 Kafka retry；生产 env 中启用 `KAFKA_SPOOL_DIR` 时，本地 spool 可在 Kafka 短暂不可用后回放。
 
+Kafka 消费组：
+
+| Consumer Group | Topic | 当前验证 |
+| --- | --- | --- |
+| `go-history-writer` | 三个 `vehicle.raw.go.*` topic | 2026-07-02 验证 lag 为 `0` |
+| `go-stat-writer` | `vehicle.raw.go.gb32960.v1`、`vehicle.raw.go.jt808.v1` | 2026-07-02 验证 lag 为 `0` |
+| `go-realtime-api` | `vehicle.event.go.unified.v1` | 2026-07-02 验证 lag 为 `0` |
+
 ## TDengine 数据层
 
 默认数据库：`lingniu_vehicle_ts`
@@ -105,7 +113,7 @@ daily_total_mileage_km = 当日最大 total_mileage_km
 
 ## Redis 实时层
 
-`realtime-api` 消费 `vehicle.event.unified.v1`，按 VIN/vehicle key 维护准实时快照。主要能力：
+`realtime-api` 消费 `vehicle.event.go.unified.v1`，按 VIN/vehicle key 维护准实时快照。主要能力：
 
 | API | 说明 |
 | --- | --- |
diff --git a/docs/operations/go-vehicle-gateway-verification.md b/docs/operations/go-vehicle-gateway-verification.md
index 80ec5e09..ef88e4ce 100644
--- a/docs/operations/go-vehicle-gateway-verification.md
+++ b/docs/operations/go-vehicle-gateway-verification.md
@@ -78,13 +78,25 @@ ss -lntp | egrep ':(808|32960|20210)\b'
 
 ```bash
 kafka-console-consumer --bootstrap-server 172.17.111.56:9092 \
-  --topic vehicle.raw.jt808.v1 --max-messages 1 --timeout-ms 10000
+  --topic vehicle.raw.go.jt808.v1 --max-messages 1 --timeout-ms 10000
 
 kafka-console-consumer --bootstrap-server 172.17.111.56:9092 \
-  --topic vehicle.raw.gb32960.v1 --max-messages 1 --timeout-ms 10000
+  --topic vehicle.raw.go.gb32960.v1 --max-messages 1 --timeout-ms 10000
 
 kafka-console-consumer --bootstrap-server 172.17.111.56:9092 \
-  --topic vehicle.event.unified.v1 --max-messages 1 --timeout-ms 10000
+  --topic vehicle.raw.go.yutong-mqtt.v1 --max-messages 1 --timeout-ms 10000
+
+kafka-console-consumer --bootstrap-server 172.17.111.56:9092 \
+  --topic vehicle.event.go.unified.v1 --max-messages 1 --timeout-ms 10000
+
+kafka-consumer-groups --bootstrap-server 172.17.111.56:9092 \
+  --describe --group go-history-writer
+
+kafka-consumer-groups --bootstrap-server 172.17.111.56:9092 \
+  --describe --group go-stat-writer
+
+kafka-consumer-groups --bootstrap-server 172.17.111.56:9092 \
+  --describe --group go-realtime-api
 ```
 
 ## TDengine 验证