MBean metrics difference for API Requests in Kafka Broker

2021-05-01 Thread Martin Schneppenheim
I'm trying to measure the number of requests that my Broker serve and I found various MBeans that report a metric for that. However I looked at them and they all seem to be report very different numbers. I'm clueless why they are so different. For clarification: I export the `Count` attribute s

Identify clients that leak fetch sessions in a Kafka cluster

2021-04-30 Thread Martin Schneppenheim
In one of our Kafka clusters we noticed that fetch sessions are being evicted and lots of clients print `FETCH_SESSION_ID_NOT_FOUND` log messages. We tried to increase max.incremental.fetch.session.cache.slots from 1k to 10k in the brokers but the slots were immediately used up again and slots

Identify clients that leak fetch sessions in a Kafka cluster

2021-04-30 Thread Martin Schneppenheim
In one of our Kafka clusters we noticed that fetch sessions are being evicted and lots of clients print `FETCH_SESSION_ID_NOT_FOUND` log messages. We tried to increase max.incremental.fetch.session.cache.slots from 1k to 10k in the brokers but the slots were immediately used up again and slots w