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

SUPPORT-8507: fix for review (1.2)

Browse source
This commit is contained in:
Рауф Латыпов 2024-09-17 09:24:39 +03:00
parent 4fafc87547
commit 31f674332b
2 changed files with 14 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/ru/micord/ervu/av/kafka/config/output/OutputKafkaConsumerConfig.java
View file

@ -31,9 +31,9 @@ public class OutputKafkaConsumerConfig {
private String jaasConfig; private String jaasConfig;
@Value("${spring.kafka.properties.sasl.mechanism}") @Value("${spring.kafka.properties.sasl.mechanism}")
private String saslMechanism; private String saslMechanism;
@Value("${spring.kafka.consumer.enable-auto-commit}") @Value("${spring.kafka.out.consumer.enable-auto-commit}")
private String enableAutoCommit; private String enableAutoCommit;
@Value("${spring.kafka.listener.ack-mode}") @Value("${spring.kafka.out.listener.ack-mode}")
private String ackMode; private String ackMode;
@Bean @Bean

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

@ -6,6 +6,7 @@ spring.kafka.admin.properties.sasl.mechanism=SCRAM-SHA-256
# kafka out servers for admin bean # kafka out servers for admin bean
#host1:port1, host2:port2 #host1:port1, host2:port2
spring.kafka.bootstrap-servers=${OUT_KAFKA_SERVERS} spring.kafka.bootstrap-servers=${OUT_KAFKA_SERVERS}
#
# kafka in consumer # kafka in consumer
#host1:port1, host2:port2 #host1:port1, host2:port2
spring.kafka.consumer.bootstrap-servers=${IN_KAFKA_SERVERS} spring.kafka.consumer.bootstrap-servers=${IN_KAFKA_SERVERS}
@ -16,13 +17,19 @@ spring.kafka.consumer.properties.sasl.mechanism=SCRAM-SHA-256
# #
spring.kafka.consumer.enable-auto-commit=false spring.kafka.consumer.enable-auto-commit=false
spring.kafka.consumer.group-id=file-to-upload-consumers spring.kafka.consumer.group-id=file-to-upload-consumers
# kafka in listeners
spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE
#
# kafka out consumer # kafka out consumer
spring.kafka.out.consumer.group-id=response-consumers
# kafka out servers for consumer # kafka out servers for consumer
#host1:port1, host2:port2 #host1:port1, host2:port2
spring.kafka.out.bootstrap-servers=${OUT_KAFKA_SERVERS} spring.kafka.out.bootstrap-servers=${OUT_KAFKA_SERVERS}
# listeners #
spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE spring.kafka.out.consumer.enable-auto-commit=false
spring.kafka.out.consumer.group-id=response-consumers
# kafka out listeners
spring.kafka.out.listener.ack-mode=MANUAL_IMMEDIATE
#
# kafka out producer # kafka out producer
#host1:port1, host2:port2 #host1:port1, host2:port2
spring.kafka.producer.bootstrap-servers=${OUT_KAFKA_SERVERS} spring.kafka.producer.bootstrap-servers=${OUT_KAFKA_SERVERS}
@ -30,7 +37,8 @@ spring.kafka.producer.security.protocol=SASL_PLAINTEXT
#login password to set #login password to set
spring.kafka.producer.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${OUT_KAFKA_USERNAME}" password="${OUT_KAFKA_PASSWORD}"; spring.kafka.producer.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${OUT_KAFKA_USERNAME}" password="${OUT_KAFKA_PASSWORD}";
spring.kafka.producer.properties.sasl.mechanism=SCRAM-SHA-256 spring.kafka.producer.properties.sasl.mechanism=SCRAM-SHA-256
# kafka general #
# kafka out general
spring.kafka.properties.security.protocol=SASL_PLAINTEXT spring.kafka.properties.security.protocol=SASL_PLAINTEXT
#login password to set #login password to set
spring.kafka.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${OUT_KAFKA_USERNAME}" password="${OUT_KAFKA_PASSWORD}"; spring.kafka.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${OUT_KAFKA_USERNAME}" password="${OUT_KAFKA_PASSWORD}";