micord/ervu-lkrp-av
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-9500: add consumer concurrency param

Browse source
This commit is contained in:
gulnaz 2025-10-24 11:12:00 +03:00
parent 6462703bed
commit 4bc09d751c
3 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
micord.env
View file

@ -6,6 +6,7 @@ AV_KAFKA_PASSWORD=Blfi9d2OFG
AV_KAFKA_GROUP_ID=file-to-upload-consumers
AV_KAFKA_TOPIC_NAME=file-to-upload
AV_KAFKA_STATUS_TOPIC_NAME=ervu.lkrp.av-fileupload-status
AV_KAFKA_TOPIC_CONSUMER_CONCURRENCY=1
ERVU_KAFKA_BOOTSTRAP_SERVERS=10.10.31.11:32609
ERVU_KAFKA_SECURITY_PROTOCOL=SASL_PLAINTEXT

3
src/main/java/ru/micord/ervu/av/kafka/config/input/InputKafkaConsumerConfig.java
View file

@ -35,6 +35,8 @@ public class InputKafkaConsumerConfig {
private String enableAutoCommit;
@Value("${spring.kafka.listener.ack.mode}")
private String ackMode;
@Value("${spring.kafka.consumer.concurrency:1}")
private int consumerConcurrency;
@Bean
public ConsumerFactory<String, String> inputConsumerFactory() {
@ -59,6 +61,7 @@ public class InputKafkaConsumerConfig {
new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(inputConsumerFactory());
factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATE);
factory.setConcurrency(consumerConcurrency);
return factory;
}
}

1
src/main/resources/application.properties
View file

@ -11,6 +11,7 @@ spring.kafka.consumer.properties.sasl.mechanism=${AV_KAFKA_SASL_MECHANISM:SCRAM-
#
spring.kafka.consumer.enable.auto.commit=false
spring.kafka.consumer.group.id=${AV_KAFKA_GROUP_ID:file-to-upload-consumers}
spring.kafka.consumer.concurrency=${AV_KAFKA_TOPIC_CONSUMER_CONCURRENCY}
# kafka in listeners
spring.kafka.listener.ack.mode=MANUAL_IMMEDIATE
# kafka in producer (with possibility for default bean)