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

SUPPORT-8507: fix for review (1)

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

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

@ -23,13 +23,13 @@ import org.springframework.kafka.listener.ContainerProperties;
@Configuration @Configuration
@EnableKafka @EnableKafka
public class OutputKafkaConsumerConfig { public class OutputKafkaConsumerConfig {
@Value("${spring.kafka.bootstrap-servers}") @Value("${spring.kafka.out.bootstrap-servers}")
private List<String> bootstrapAddress; private List<String> bootstrapAddress;
@Value("${spring.kafka.consumer.security.protocol}") @Value("${spring.kafka.properties.security.protocol}")
private String securityProtocol; private String securityProtocol;
@Value("${spring.kafka.consumer.properties.sasl.jaas.config}") @Value("${spring.kafka.properties.sasl.jaas.config}")
private String jaasConfig; private String jaasConfig;
@Value("${spring.kafka.consumer.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.consumer.enable-auto-commit}")
private String enableAutoCommit; private String enableAutoCommit;

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

@ -1,11 +1,12 @@
# kafka out admin bean settings
spring.kafka.admin.security.protocol=SASL_PLAINTEXT spring.kafka.admin.security.protocol=SASL_PLAINTEXT
#login password to set #login password to set
spring.kafka.admin.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${OUT_KAFKA_USERNAME}" password="${OUT_KAFKA_PASSWORD}"; spring.kafka.admin.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${OUT_KAFKA_USERNAME}" password="${OUT_KAFKA_PASSWORD}";
spring.kafka.admin.properties.sasl.mechanism=SCRAM-SHA-256 spring.kafka.admin.properties.sasl.mechanism=SCRAM-SHA-256
# # 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
#host1:port1, host2:port2 #host1:port1, host2:port2
spring.kafka.consumer.bootstrap-servers=${IN_KAFKA_SERVERS} spring.kafka.consumer.bootstrap-servers=${IN_KAFKA_SERVERS}
spring.kafka.consumer.security.protocol=SASL_PLAINTEXT spring.kafka.consumer.security.protocol=SASL_PLAINTEXT
@ -15,17 +16,21 @@ 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 out consumer
spring.kafka.out.consumer.group-id=response-consumers spring.kafka.out.consumer.group-id=response-consumers
# # kafka out servers for consumer
#host1:port1, host2:port2
spring.kafka.out.bootstrap-servers=${OUT_KAFKA_SERVERS}
# listeners
spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE
# # 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}
spring.kafka.producer.security.protocol=SASL_PLAINTEXT 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
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}";