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(AbstractConfig.java:60)
at
org.apache.kafka.common.config.AbstractConfig.getClass(AbstractConfig.java:91)
at
org.apache.kafka.common.config.AbstractConfig.getConfiguredInstances(AbstractConfig.java:147)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:105)
at
org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:94)
AbstractConfig.getClass throws an exception because it cannot find any
definition of ServoReporter.class.getName() but I cannot add custom class
definition because the class name is not defined in the key set of
properties.
Do you have any idea?
Thank you
Best, Jae