in src/main/java/com/epam/eco/commons/kafka/AdminClientUtils.java [1057:1075]
public static Map<String, String> configToMap(
Config config,
boolean ignoreDefaultConfigs,
boolean ignoreReadOnlyConfigs) {
Validate.notNull(config, "Config is null");
Collection<ConfigEntry> entries = config.entries();
Map<String, String> configMap = new HashMap<>((int) (entries.size() / 0.75));
for (ConfigEntry entry : entries) {
if (entry.isDefault() && ignoreDefaultConfigs) {
continue;
}
if (entry.isReadOnly() && ignoreReadOnlyConfigs) {
continue;
}
configMap.put(entry.name(), entry.value());
}
return configMap;
}