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 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); }