kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
[KIP-1170: Unify cluster metadata bootstrapping](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1170%3A+Unify+cluster+metadata+bootstrapping). Currently the zero checkpoint (`00000000000000000000-0000000000.checkpoint`) contains the starting state for KRaft while `bootstrap.checkpoint` contains the starting state for the cluster metadata. This KIP/PR unifies these...
Prologue: https://github.com/apache/kafka/pull/19513#discussion_r2365708218 Release notes for Shadow plugin: - https://gradleup.com/shadow/changes/#930-2025-12-05 I did some testing, and results look just fine :white_check_mark:: - gradle builds `./gradlew :jmh-benchmarks:shadowJar` and `./gradlew releaseTarGz` are successful -...
Add more information to doc to explain how to parallelize per topic with Kafka Streams jira:https://issues.apache.org/jira/browse/KAFKA-19963 - The architecture page: - The Streams DSL page: - The Running Streams Applications...
KAFKA-19893: Reduce tiered storage redundancy with delayed upload (Topic-level feature) (KIP-1241)
[JIRA:19893](https://issues.apache.org/jira/browse/KAFKA-19893) [KIP:1241](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1241%3A+Reduce+tiered+storage+redundancy+with+delayed+upload) Currently, Kafka uploads all non-active local log segments to remote storage even when they are still within the local retention period, resulting in redundant storage of the same...
The intention of the `Consumer` API is that after `close()`, `metrics()` should return an empty map of metrics. The lifecycle management of the various metrics managers in the consumer is...
Caffeine cache currently only uses size-based eviction with frequency buckets. Within same frequency bucket, larger entries are always evicted. This causes old (smaller) index files to stay in cache indefinitely...
In previous implementation, the `ClientQuotasImage#describe` goes through all `ClientQuotaEntity` and checks whether entity type and entity name are matched the filter. In this PR, it goes through all `ClientQuotaEntity#entries` in...
*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...
In this PR, we corrected the argument order in assertEquals within the test-common package.
