Slackbot
11/02/2022, 10:24 PMGian Merlino
11/02/2022, 11:09 PMdruid.dynamic.config.provider?Gian Merlino
11/02/2022, 11:10 PMObject dynamicConfigProviderJson = consumerProperties.get(KafkaSupervisorIOConfig.DRUID_DYNAMIC_CONFIG_PROVIDER_KEY);
if (dynamicConfigProviderJson != null) {
DynamicConfigProvider dynamicConfigProvider = configMapper.convertValue(dynamicConfigProviderJson, DynamicConfigProvider.class);
Map<String, String> dynamicConfig = dynamicConfigProvider.getConfig();
for (Map.Entry<String, String> e : dynamicConfig.entrySet()) {
properties.setProperty(e.getKey(), e.getValue());
}
}Gian Merlino
11/02/2022, 11:10 PMdruid.dynamic.config.providerGian Merlino
11/02/2022, 11:10 PMDidip Kerabat
11/03/2022, 12:20 AM