From 46ab3531061ca61a18b242bad4347e199b43bb29 Mon Sep 17 00:00:00 2001
From: leiyun <leiyun@home.com>
Date: Fri, 3 Jul 2026 17:12:33 +0800
Subject: [PATCH] asve

---
 isolated/.env.example                   | 3 +++
 isolated/profiles/emp-test/.env.example | 3 +++
 isolated/profiles/emp-uat/.env.example  | 3 +++
 3 files changed, 9 insertions(+)

diff --git a/isolated/.env.example b/isolated/.env.example
index 1320281..f9005a5 100644
--- a/isolated/.env.example
+++ b/isolated/.env.example
@@ -84,6 +84,9 @@ KAFKA_GROUP_ID=ecmp-data-group-v2
 KAFKA_TOPIC=vehicle-data
 KAFKA_USER=
 KAFKA_PWD=
+# emp-data Kafka listener 消费线程数，建议不超过 topic partition 数；多实例时看总并发。
+SPRING_KAFKA_LISTENER_CONCURRENCY=8
+SPRING_KAFKA_CONSUMER_MAX_POLL_RECORDS=500
 
 SIMULATOR_KAFKA_BROKERS=kafka:9092
 SIMULATOR_KAFKA_TOPIC=vehicle-data
diff --git a/isolated/profiles/emp-test/.env.example b/isolated/profiles/emp-test/.env.example
index bb31290..f47f9cf 100644
--- a/isolated/profiles/emp-test/.env.example
+++ b/isolated/profiles/emp-test/.env.example
@@ -51,6 +51,9 @@ KAFKA_GROUP_ID=emp-test-data-group
 KAFKA_TOPIC=YuanJing-test-vehicle-mock-data
 KAFKA_USER=
 KAFKA_PWD=
+# emp-data Kafka listener 消费线程数，profiles/docker-compose.yml 会映射为 Spring Kafka concurrency。
+EMP_DATA_KAFKA_CONCURRENCY=10
+EMP_DATA_KAFKA_MAX_POLL_RECORDS=500
 
 SIMULATOR_KAFKA_BROKERS=ip-cld.cn:29362
 SIMULATOR_KAFKA_TOPIC=test-vehicle-real-data
diff --git a/isolated/profiles/emp-uat/.env.example b/isolated/profiles/emp-uat/.env.example
index 0e33442..02f4abe 100644
--- a/isolated/profiles/emp-uat/.env.example
+++ b/isolated/profiles/emp-uat/.env.example
@@ -51,6 +51,9 @@ KAFKA_GROUP_ID=emp-uat-data-group
 KAFKA_TOPIC=YuanJing-uat-vehicle-mock-data
 KAFKA_USER=
 KAFKA_PWD=
+# emp-data Kafka listener 消费线程数，profiles/docker-compose.yml 会映射为 Spring Kafka concurrency。
+EMP_DATA_KAFKA_CONCURRENCY=10
+EMP_DATA_KAFKA_MAX_POLL_RECORDS=500
 
 SIMULATOR_KAFKA_BROKERS=ip-cld.cn:29362
 SIMULATOR_KAFKA_TOPIC=uat-vehicle-real-data