Need help regarding missing kafka producer metrics while upgrade from 1.1.0 to 2.0.0

2020-05-14 Thread Rajkumar Natarajan
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

What is the node-id tag in kafka producer MetricName ?

2019-12-03 Thread Rajkumar Natarajan
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

kafka core unit test failing

2019-02-05 Thread Rajkumar Natarajan
Hi, I've cloned the kafka project. Below is the latest commit I'm using. commit e942e294f0a700cdc2f94bb7f967c2e9bcb1a271 (HEAD -> trunk, origin/trunk, origin/HEAD) When I run the command `gradle core:test` one of the tests failed. kafka.api.ConsumerBounceTest > testConsumerReceivesFatalExceptio

[jira] [Created] (KAFKA-7377) update metrics module from yammer to dropwizrd

2018-09-04 Thread RAJKUMAR NATARAJAN (JIRA)
RAJKUMAR NATARAJAN created KAFKA-7377: - Summary: update metrics module from yammer to dropwizrd Key: KAFKA-7377 URL: https://issues.apache.org/jira/browse/KAFKA-7377 Project: Kafka Issue