diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 5165cad..63b6dd8 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -8,11 +8,11 @@ spring.kafka.admin.properties.sasl.jaas.config=org.apache.kafka.common.security. spring.kafka.admin.properties.sasl.mechanism=SCRAM-SHA-256 # kafka out servers for admin bean #host1:port1, host2:port2 -spring.kafka.bootstrap.servers=${OUT_KAFKA_SERVERS} +spring.kafka.bootstrap.servers=${ERVU_KAFKA_BOOTSTRAP_SERVERS} # # kafka in consumer (with possibility for default bean) #host1:port1, host2:port2 -spring.kafka.consumer.bootstrap.servers=${AV_KAFKA_SERVERS} +spring.kafka.consumer.bootstrap.servers=${AV_KAFKA_BOOTSTRAP_SERVERS} spring.kafka.consumer.security.protocol=SASL_PLAINTEXT #login password to set spring.kafka.consumer.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${AV_KAFKA_USERNAME}" password="${AV_KAFKA_PASSWORD}"; @@ -25,7 +25,7 @@ spring.kafka.listener.ack.mode=MANUAL_IMMEDIATE # # kafka out producer (with possibility for default bean) #host1:port1, host2:port2 -spring.kafka.producer.bootstrap.servers=${ERVU_KAFKA_SERVERS} +spring.kafka.producer.bootstrap.servers=${ERVU_KAFKA_BOOTSTRAP_SERVERS} spring.kafka.producer.security.protocol=SASL_PLAINTEXT #login password to set spring.kafka.producer.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${ERVU_KAFKA_USERNAME}" password="${ERVU_KAFKA_PASSWORD}"; @@ -40,7 +40,7 @@ spring.kafka.properties.sasl.mechanism=SCRAM-SHA-256 # # kafka out consumer (not for default bean creation by spring) #host1:port1, host2:port2 -spring.kafka.out.consumer.bootstrap.servers=${ERVU_KAFKA_SERVERS} +spring.kafka.out.consumer.bootstrap.servers=${ERVU_KAFKA_BOOTSTRAP_SERVERS} spring.kafka.out.consumer.security.protocol=SASL_PLAINTEXT #login password to set spring.kafka.out.consumer.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="${ERVU_KAFKA_USERNAME}" password="${ERVU_KAFKA_PASSWORD}"; diff --git a/test.env b/test.env index 8d3216d..5eb72ec 100644 --- a/test.env +++ b/test.env @@ -1,8 +1,8 @@ -AV_KAFKA_SERVERS=10.10.31.11:32609 +AV_KAFKA_BOOTSTRAP_SERVERS=10.10.31.11:32609 AV_KAFKA_USERNAME=user1 AV_KAFKA_PASSWORD=Blfi9d2OFG AV_KAFKA_TOPIC_NAME=file-to-upload -ERVU_KAFKA_SERVERS=10.10.31.11:32609 +ERVU_KAFKA_BOOTSTRAP_SERVERS=10.10.31.11:32609 ERVU_KAFKA_USERNAME=user1 ERVU_KAFKA_PASSWORD=Blfi9d2OFG ERVU_KAFKA_ERROR_TOPIC_NAME=ervu.lkrp.download.request