kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
FYI: https://github.com/apache/kafka/pull/20175/files#r2572693459
This change addresses high GC pressure by allocating tiered storage fetch buffers in direct (off-heap) memory instead of the JVM heap. When direct memory is exhausted, the system gracefully falls...
In this PR, we corrected the argument order in assertEquals within the server package. Ticket : https://issues.apache.org/jira/browse/KAFKA-19986 Part of : https://issues.apache.org/jira/browse/KAFKA-19097
Move KRaftClusterTest from core module to server module. Rewrite - testCreateClusterAndCreateListDeleteTopic - testCreateClusterAndCreateAndManyTopics - testClientQuotas - testDefaultClientQuotas - testCreateClusterWithAdvertisedPortZero - testCreateClusterWithAdvertisedHostAndPortDifferentFromSocketServer - testUnregisterBroker
Delete this text and replace it with a detailed description of your change. The PR title and body will become the squashed commit message. If you would like to tag...
Add topic ID support to OffsetForLeader - ServerAndProtocol
This commit updates the existing Kafka definition to a more precise, technically grounded, and documentation-ready description. The new version provides clearer context on Kafka’s purpose, core capabilities, and role in...
Jira : https://issues.apache.org/jira/browse/KAFKA-19308 This PR adds unit tests for OAuthBearerRefreshingLogin. - Increased coverage from 0% → 95% (line), 91% (branch), and 100% (method). - Covers edge cases for token refresh,...
Fixes https://issues.apache.org/jira/browse/KAFKA-18967 Added additional tests for verification of: 1. Evolution between different schemas (parent schema has version 0-1, child schema has version 0-2). 2. Fix for the infinite loop bug...
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...
