In ProducerPerformance class we use CSVMetricsReporter for metrics
reporting.
Which I think is actually started with the help of below function:
KafkaMetricsReporter.startReporters(verifiableProps)
Similarly I wrote my own producer and I have a custom implementation of
KafkaMetricsReporter.
But
Never mind. I found the issue.
Thanks,
Ravi
On Fri, Oct 10, 2014 at 11:47 AM, ravi singh rrs120...@gmail.com wrote:
In ProducerPerformance class we use CSVMetricsReporter for metrics
reporting.
Which I think is actually started with the help of below function:
