in src/main/java/com/amazonaws/mskdatagen/core/Context.java [270:286]
private void addAttrConfig(Config config, AttrConfig attrConfig) {
Optional.ofNullable(config.getConfigs()).ifPresent(t -> {
String join = String.join(".", t);
switch (join) {
case "null.rate":
attrConfig.setNullRate(Double.parseDouble(config.getValue()));
break;
case "matching.rate":
attrConfig.setMatchingRate(Double.parseDouble(config.getValue()));
break;
default:
String message = String.format("Unrecognized topic configuration: %s", config.getOriginalKey());
throw new IllegalArgumentException(message);
}
});
}