修改消费线程数

This commit is contained in:
zren25
2025-05-15 16:55:08 +08:00
parent 2032f59ce0
commit aeacdd9ef8

View File

@@ -46,8 +46,7 @@ public class NameplateKafkaConsumer {
@KafkaListener(topics = "${analyticCenterKafka.consumer.topic}",
groupId = "${analyticCenterKafka.consumer.group}" ,
containerFactory = "analyticCenterConsumerFactory",
concurrency = "3")
containerFactory = "analyticCenterConsumerFactory")
public void listen(String recordMessages, Acknowledgment ack) {
long startTime = System.currentTimeMillis();