This is an automated email from the ASF dual-hosted git repository.

arnold pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/fineract.git


The following commit(s) were added to refs/heads/develop by this push:
     new 6cb8ae0ed FINERACT-1724  - fix bootstrap server config
6cb8ae0ed is described below

commit 6cb8ae0ed38c50b0702c9dee9e4d2d1e99367868
Author: Peter Bagrij <[email protected]>
AuthorDate: Fri Oct 20 15:37:53 2023 +0200

    FINERACT-1724
     - fix bootstrap server config
---
 .../event/external/config/KafkaExternalEventTopicConfig.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/config/KafkaExternalEventTopicConfig.java
 
b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/config/KafkaExternalEventTopicConfig.java
index 0d5e4562d..72e4cc7d8 100644
--- 
a/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/config/KafkaExternalEventTopicConfig.java
+++ 
b/fineract-provider/src/main/java/org/apache/fineract/infrastructure/event/external/config/KafkaExternalEventTopicConfig.java
@@ -42,7 +42,7 @@ public class KafkaExternalEventTopicConfig {
     public KafkaAdmin admin() {
         Map<String, Object> props = new HashMap<>(
                 
fineractProperties.getEvents().getExternal().getProducer().getKafka().getAdmin().getExtraPropertiesMap());
-        props.put(BOOTSTRAP_SERVERS_CONFIG, 
fineractProperties.getRemoteJobMessageHandler().getKafka().getBootstrapServers());
+        props.put(BOOTSTRAP_SERVERS_CONFIG, 
fineractProperties.getEvents().getExternal().getProducer().getKafka().getBootstrapServers());
         return new KafkaAdmin(props);
     }
 

Reply via email to