FINERACT-1724
- fix bootstrap server config
This commit is contained in:
committed by
Arnold Gálovics
parent
5ab2b19ae4
commit
6cb8ae0ed3
+1
-1
@@ -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);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user