Kafka10.1 heartbeat.interval.ms, session.timeout.ms and max.poll.interval.ms

Kafka10.1 heartbeat.interval.ms, session.timeout.ms and max.poll.interval.ms

I am using kafka 0.10.1.1 and confused with the following 3 properties.
heartbeat.interval.ms
session.timeout.ms
max.poll.interval.ms

heartbeat.interval.ms – This was added in 0.10.1 and it will send heartbeat between polls.
session.timeout.ms … Read more

Enable JMX on Kafka Brokers

Enable JMX on Kafka Brokers

I enabled JMX on Kafka brokers by adding
`KAFKA_JMX_OPTS=”-Dcom.sun.management.jmxremote=true
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
-Djava.rmi.server.hostname=
-Djava.net.preferIPv4Stack=true`“.

However, when I use ‘kafka.tools.JmxTool’ to get the metrics, it outputs Unix time stamps which are not … Read more

Topics, partitions and keys

Topics, partitions and keys

I am looking for some clarification on the subject.
In Kafka documentations I found the following:
Kafka only provides a total order over messages within a partition, not between different partitions … Read more