Hi Kafka community,
we are currently using kafka client version 1.1.0 in our production. I'm
working on upgrade it to kafka version 2.0.0.
I see there are some metrics which are present in version 1.1.1 are removed
in kafka version 2.0.0.
S# version 1.1.1 2.0.0
1
kafka.producer:type=ProducerRequ
I've have kafka producer running same code from 3 different linux servers
sending messages to same kafka cluster topic. Below is the sample code -
KafkaProducer producer = new KafkaProducer(props);
Map metrics = producer.metrics();
System.out.println(metrics.keySet());
The sample of