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
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
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