asve

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

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

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