in core/src/main/java/org/apache/camel/kafkaconnector/utils/TaskHelper.java [102:117]
public static Map<String, String> combineDefaultAndLoadedProperties(Map<String, String> defaultProps, Map<String, String> loadedProps) {
if (loadedProps == null && defaultProps == null) {
return Collections.emptyMap();
} else if (loadedProps == null) {
return new HashMap<>(defaultProps);
} else if (defaultProps == null) {
return new HashMap<>(loadedProps);
} else {
Map<String, String> result = new HashMap<>(loadedProps);
defaultProps.keySet().stream()
.filter(k -> !stringStartWithOneOfPrefixes(k, loadedProps.keySet()))
.filter(k -> !result.containsKey(k))
.forEach(k -> result.put(k, defaultProps.get(k)));
return result;
}
}