I added the following ugly reflection code and it's working
try {
Field f = ProducerConfig.class.getDeclaredField("config");
f.setAccessible(true);
ConfigDef config = (ConfigDef) f.get(ConfigDef.class);
config.define(ServoReporter.class.getName(),
Co
Hi
When I set up
props.put("metric.reporters",
Lists.newArrayList(ServoReporter.class.getName()));
I got the following error:
org.apache.kafka.common.config.ConfigException: Unknown configuration
'com.netflix.suro.sink.kafka.ServoReporter'
at org.apache.kafka.common.config.AbstractConfig.get(Ab
