diff --git a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaConsumerCFG.java b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaConsumerCFG.java index 74a35be..8d521e5 100644 --- a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaConsumerCFG.java +++ b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaConsumerCFG.java @@ -94,7 +94,7 @@ public Map consumerConfigs() { props.put("sasl.login.callback.handler.class", CustomAuthenticateCallbackHandler.class); props.put("kafka.oauth.tenantId", kafkaPropsCfg.getTenantId()); props.put("kafka.oauth.appId", kafkaPropsCfg.getAppId()); - props.put("kafka.oauth.pfxName", kafkaPropsCfg.getPfxName()); + props.put("kafka.oauth.pfxPathName", kafkaPropsCfg.getPfxPathName()); props.put("kafka.oauth.pwd", kafkaPropsCfg.getPwd()); } diff --git a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaProducerCFG.java b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaProducerCFG.java index ce0d2d2..815d5bd 100644 --- a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaProducerCFG.java +++ b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaProducerCFG.java @@ -76,7 +76,7 @@ public Map producerWithoutTransactionConfigs() { props.put("sasl.login.callback.handler.class", CustomAuthenticateCallbackHandler.class); props.put("kafka.oauth.tenantId", kafkaPropCFG.getTenantId()); props.put("kafka.oauth.appId", kafkaPropCFG.getAppId()); - props.put("kafka.oauth.pfxName", kafkaPropCFG.getPfxName()); + props.put("kafka.oauth.pfxPathName", kafkaPropCFG.getPfxPathName()); props.put("kafka.oauth.pwd", kafkaPropCFG.getPwd()); } diff --git a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaPropertiesCFG.java b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaPropertiesCFG.java index c80b312..ec1769d 100644 --- a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaPropertiesCFG.java +++ b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/KafkaPropertiesCFG.java @@ -24,8 +24,8 @@ public class KafkaPropertiesCFG { @Value("${kafka.oauth.appId}") private String appId; - @Value("${kafka.oauth.pfxName}") - private String pfxName; + @Value("${kafka.oauth.pfxPathName}") + private String pfxPathName; @Value("${kafka.oauth.pwd}") private String pwd; diff --git a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/oauth2/CustomAuthenticateCallbackHandler.java b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/oauth2/CustomAuthenticateCallbackHandler.java index 10cf1ee..5611a3b 100644 --- a/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/oauth2/CustomAuthenticateCallbackHandler.java +++ b/src/main/java/it/finanze/sanita/fse2/ms/gtw/statusmanager/config/kafka/oauth2/CustomAuthenticateCallbackHandler.java @@ -44,7 +44,7 @@ public class CustomAuthenticateCallbackHandler implements AuthenticateCallbackHa private String appId; - private String pfxName; + private String pfxPathName; private String pwd; @@ -63,7 +63,7 @@ public void configure(Map configs, String mechanism, List