Abhi Tiwari
Abhi Tiwari
Deprecated Variable StreamsConfig#TOPOLOGY_OPTIMIZATION is removed ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status -...
I have renamed the Mode enum to ConnectionMode in the clients to improve clarity. The previous name, Mode, was undocumented and ambiguous. This made it unclear whether the connection was...
Deprecated Variable StreamsConfig#TOPOLOGY_OPTIMIZATION is removed ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status -...
This PR addresses an issue with the evictWhile method where a ConcurrentModificationException was being thrown due to modifications made to sortedMap during iteration. The following changes have been made: -...
Documented all the socket-server-metrics Ticket Description - There are a bunch of broker JMX metrics in the "socket-server-metrics" space that are not documented on kafka.apache.org/documentation MBean: kafka.server:type=socket-server-metrics,listener=,networkProcessor= From KIP-188: https://cwiki.apache.org/confluence/display/KAFKA/KIP-188+-+Add+new+metrics+to+support+health+checks...