35 Pull requests merged by 21 people

• KAFKA-18954: Add ELR election rate metric

  #19180 merged Mar 20, 2025

• KAFKA-18845: Fix flaky QuorumControllerTest#testUncleanShutdownBrokerElrEnabled

  #19240 merged Mar 20, 2025

• KAFKA-15931: Cancel RemoteLogReader gracefully

  #19197 merged Mar 20, 2025

• KAFKA-18329; [1/3] Delete old group coordinator (KIP-848)

  #19243 merged Mar 20, 2025

• MINOR: Add 4.0.0 to core system tests

  #19238 merged Mar 20, 2025

• KAFKA-18946: Move BrokerReconfigurable and DynamicProducerStateManagerConfig to server module

  #19174 merged Mar 20, 2025

• KAFKA-806: Index may not always observe log.index.interval.bytes (#18012)

  #18842 merged Mar 20, 2025

• KAFKA-18989 Optimize FileRecord#searchForOffsetWithSize

  #19214 merged Mar 20, 2025

• KAFKA-18819 StreamsGroupHeartbeat API and StreamsGroupDescribe API check topic describe

  #19183 merged Mar 19, 2025

• KAFKA-18975: Move clients-integration-test out of core module

  #19217 merged Mar 19, 2025

• KAFKA-18953: [1/N] Add broker side handling for 2 PC (KIP-939)

  #19193 merged Mar 19, 2025

• KAFKA-17431: Support invalid static configs for KRaft so long as dynamic configs are valid

  #18949 merged Mar 18, 2025

• MINOR: Add 4.0.0 to deps

  #19229 merged Mar 18, 2025

• MINOR Fixup develocity report

  #19179 merged Mar 18, 2025

• MINOR: Bump to 4.0.1-SNAPSHOT

  #19224 merged Mar 18, 2025

• MINOR: Update docker_scan.yml with 4.0.0

  #19225 merged Mar 18, 2025

• KAFKA-18969: Rewrite ShareConsumerTest#setup and move to clients-integration-tests module

  #19202 merged Mar 18, 2025

• KAFKA-18955: Fix infinite loop and standardize options in MetadataSchemaCheckerTool

  #19165 merged Mar 17, 2025

• KAFKA-18808: add test to ensure the name=<default> is not equal to default quota

  #18966 merged Mar 17, 2025

• MINOR: Rewrite unchecked operations in Mock API

  #19071 merged Mar 17, 2025

• KAFKA-17171: Add test cases for STATIC_BROKER_CONFIGin kraft mode

  #18463 merged Mar 17, 2025

• KAFKA-17565: Move MetadataCache interface to metadata module

  #18801 merged Mar 17, 2025

• KAFKA-18736: Do not send fields if not needed

  #19181 merged Mar 16, 2025

• KAFKA-18990: Avoid redundant MetricName creation in BaseQuotaTest#produceUntilThrottled

  #19215 merged Mar 16, 2025

• MINOR: Clean up metadata module

  #19069 merged Mar 15, 2025

• KAFKA-18859: honor the error message of UnregisterBrokerResponse

  #19027 merged Mar 15, 2025

• KAFKA-18993: Remove confusing notable change section from upgrade.html

  #19212 merged Mar 15, 2025

• KAFKA-18703: Remove unused class PayloadKeyType

  #19129 merged Mar 15, 2025

• KAFKA-18915: Rewrite AdminClientRebootstrapTest to cover the current scenario

  #19187 merged Mar 15, 2025

• KAFKA-18924 Running the storage module tests produces a storage/storage.log file

  #19147 merged Mar 14, 2025

• KAFKA-18781: Extend RefreshRetriableException related exceptions

  #19136 merged Mar 14, 2025

• KAFKA-18606: Flaky test DeleteSegmentsByRetentionTimeTest#executeTieredStorageTest

  #18861 merged Mar 14, 2025

• KAFKA-18843: Fix MirrorMaker2 workerId is not unique, but use the sam…

  #18994 merged Mar 14, 2025

• KAFKA-17516: Synonyms for client metrics configs

  #17264 merged Mar 14, 2025

• KAFKA-18927: Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

  #19134 merged Mar 14, 2025

41 Pull requests opened by 27 people

• KAFKA-18980: OffsetMetadataManager#cleanupExpiredOffsets should record the number of records rather than topic partitions

  #19207 opened Mar 14, 2025

• KAFKA-18913[WIP]: Removal of code guarded by the negation of _state.u…

  #19208 opened Mar 14, 2025

• KAFKA-17715: Remove argument force_use_zk_connection from e2e

  #19209 opened Mar 14, 2025

• MINOR; Improve error message for the storage format command

  #19210 opened Mar 14, 2025

• KAFKA-18984: Reset interval.ms By Using kafka-client-metrics.sh

  #19213 opened Mar 15, 2025

• KAFKA-14486: Move LogCleanerManager to storage module

  #19216 opened Mar 16, 2025

• KAFKA-7952: use in memory stores for KTable test [WIP]

  #19218 opened Mar 17, 2025

• KAFKA-19001: Use streams group-level configurations in heartbeat

  #19219 opened Mar 17, 2025

• KAFKA-18679: KafkaRaftMetrics metrics are exposing doubles instead of integers

  #19220 opened Mar 17, 2025

• KAFKA-17078: Add SecurityManagerCompatibility shim (#16522)

  #19221 opened Mar 17, 2025

• (WIP) KAFKA-18390: Use LinkedHashMap instead of Map in creating MetricName and SensorBuilder

  #19222 opened Mar 17, 2025

• KAFKA-18991: FetcherThread should match leader epochs between fetch request and fetch state

  #19223 opened Mar 18, 2025

• KAFKA-19004:Move DelayedDeleteRecords to server-common module

  #19226 opened Mar 18, 2025

• KAFKA-18999: Remove BrokerMetadata

  #19227 opened Mar 18, 2025

• [WIP]KAFKA-19000 Flaky test report should use absolute time for links

  #19228 opened Mar 18, 2025

• KAFKA-18736: Handle errors in the Streams group heartbeat request manager

  #19230 opened Mar 18, 2025

• KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread.

  #19231 opened Mar 18, 2025

• KAFKA-17573: Move KRaftMetadataCache to metadata module

  #19232 opened Mar 18, 2025

• KAFKA-18736: Add pollOnClose() and maximumTimeToWait()

  #19233 opened Mar 18, 2025

• Add FunctionalInterface Annotation to most of the interfaces primarily used by Lambdas

  #19234 opened Mar 19, 2025

• MINOR: Run CI with Java 24 and update documentation (instead of 23)

  #19235 opened Mar 19, 2025

• KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch

  #19236 opened Mar 19, 2025

• KAFKA-6333 java.awt.headless should not be on commandline

  #19237 opened Mar 19, 2025

• MINOR: Add 4.0.0 to streams system tests

  #19239 opened Mar 19, 2025

• KAFKA-19008 Remove scala version from artifacts

  #19241 opened Mar 19, 2025

• KAFKA-19013 Reformat PR body to 72 characters

  #19242 opened Mar 19, 2025

• MINOR: Add doc for configuration parameters to keep the format consistent

  #19244 opened Mar 19, 2025

• MINOR: refactoring periodic tasks to wrap a ControllerWriteOperation

  #19245 opened Mar 19, 2025

• KAFKA-15599: Move MetadataLogConfig to raft module

  #19246 opened Mar 19, 2025

• KAFKA-18796: Added more information to error message when assertion fails for acquisition lock timeout

  #19247 opened Mar 19, 2025

• MINOR Mar 19 flaky tests

  #19248 opened Mar 19, 2025

• KAFKA-6416: Helm chart for deploying Kafka to Kubernetes

  #19249 opened Mar 19, 2025

• MINOR: Specify 2.1 as the minimum broker version for clients

  #19250 opened Mar 19, 2025

• KAFKA-18329; [2/3] Delete old group coordinator (KIP-848)

  #19251 opened Mar 20, 2025

• MINOR: add log4j2.yaml to clients-integration-tests module

  #19252 opened Mar 20, 2025

• [MINOR] UnifiedLog topic-partition as attribute as it is stable

  #19253 opened Mar 20, 2025

• KAFKA-19017: Changed consumer.config to command-config in verifiable_share_consumer.py

  #19254 opened Mar 20, 2025

• KAFKA-18329; [3/3] Delete old group coordinator (KIP-848)

  #19255 opened Mar 20, 2025

• KAFKA-17806: remove this-escape suppress warnings in AclCommand

  #19256 opened Mar 20, 2025

• MINOR: Move FileRecord JavaDoc to comment

  #19257 opened Mar 20, 2025

• MINOR: Move inner test classes out of CoordinatorRuntimeTest

  #19258 opened Mar 20, 2025

72 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests

  #18987 commented on Mar 20, 2025 • 18 new comments

• KAFKA-18613: Improve test coverage for missing topics

  #19189 commented on Mar 17, 2025 • 14 new comments

• KAFKA-18988: Connect Multiversion Support (Updates to status and metrics)

  #17988 commented on Mar 20, 2025 • 9 new comments

• KAFKA-18613: Add StreamsGroupHeartbeat handler in the group coordinator

  #19114 commented on Mar 17, 2025 • 8 new comments

• KAFKA-18827: Initialize share group state group coordinator impl. [3/N]

  #19026 commented on Mar 14, 2025 • 7 new comments

• KAFKA-18893: KIP-877 Add support for ReplicaSelector

  #19064 commented on Mar 20, 2025 • 7 new comments

• KAFKA-16616: refactor mergeWith and updatePartitionLeadership

  #19199 commented on Mar 20, 2025 • 7 new comments

• KAFKA-18332: fix ClassDataAbstractionCoupling problem in KafkaRaftClientTest(1/2)

  #18926 commented on Mar 17, 2025 • 6 new comments

• Kafka-18914 Migrate ConsumerRebootstrapTest to use new test infra

  #19154 commented on Mar 20, 2025 • 6 new comments

• KAFKA-18982: Allow ClusterTests to ignore specific thread leaks

  #19206 commented on Mar 17, 2025 • 3 new comments

• KAFKA-18966: Change controller_num_nodes_override to override_num_isolated_controllers

  #19194 commented on Mar 19, 2025 • 3 new comments

• KAFKA-18935: Ensure brokers do not return null records in FetchResponse

  #19167 commented on Mar 20, 2025 • 2 new comments

• MINOR: Fix upgrade finalization flag

  #19198 commented on Mar 17, 2025 • 2 new comments

• MINOR Capture heap dump after OOM on CI

  #19031 commented on Mar 19, 2025 • 2 new comments

• KAFKA-18576: Convert ConfigType to Enum

  #18711 commented on Mar 20, 2025 • 2 new comments

• KAFKA-18962: Fix onBatchRestored call in GlobalStateManagerImpl

  #19188 commented on Mar 18, 2025 • 1 new comment

• MINOR: Revert migrate LogFetchInfo, Assignment and RequestAndCompletionHandler to java record

  #19177 commented on Mar 15, 2025 • 1 new comment

• MINOR: describeTopics should pass the timeout to the describeCluster call

  #19203 commented on Mar 18, 2025 • 1 new comment

• [WIP] KAFKA-18279: add JDK 11 check and test for clients and streams module

  #19196 commented on Mar 20, 2025 • 1 new comment

• KAFKA-18607: Update jfreechart dependency

  #19074 commented on Mar 16, 2025 • 0 new comments

• KAFKA-18892: KIP-877 Add support for ClientQuotaCallback

  #19068 commented on Mar 19, 2025 • 0 new comments

• KAFKA-17651: Implement `describeUserScramCredentials`

  #19066 commented on Mar 20, 2025 • 0 new comments

• MINOR: redundant gradle expression is removed

  #19200 commented on Mar 14, 2025 • 0 new comments

• KAFKA-18276 Migrate ProducerRebootstrapTest to new test infra

  #19046 commented on Mar 17, 2025 • 0 new comments

• KAFKA-18841: Enable to test docker image locally

  #19028 commented on Mar 16, 2025 • 0 new comments

• Fix IllegalStateException for Transaction Producer

  #19204 commented on Mar 18, 2025 • 0 new comments

• KAFKA-4650: Add unit tests for GraphNode class

  #18951 commented on Mar 18, 2025 • 0 new comments

• KAFKA-17830: Cover unit tests for TBRLMM init failure scenarios

  #19076 commented on Mar 16, 2025 • 0 new comments

• KAFKA-17014: ScramFormatter should not use String for password

  #19082 commented on Mar 14, 2025 • 0 new comments

• [MINOR] Cleanup Server Common Module

  #19085 commented on Mar 18, 2025 • 0 new comments

• KAFKA-18424: Consider splitting PlaintextAdminIntegrationTest#testConsumerGroups

  #19093 commented on Mar 20, 2025 • 0 new comments

• KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol

  #19110 commented on Mar 18, 2025 • 0 new comments

• KAFKA-18923: resource leak in RSM fetchIndex inputStream

  #19111 commented on Mar 16, 2025 • 0 new comments

• KAFKA-18778 Fix the inconsistent lastest supported version in StorageTool.scala and FutureCommand

  #19157 commented on Mar 14, 2025 • 0 new comments

• MINOR: Use readable interface to parse requests

  #19163 commented on Mar 20, 2025 • 0 new comments

• Add a SelectorProvider that reuses custom provider implementations.

  #19186 commented on Mar 19, 2025 • 0 new comments

• KAFKA-18899: Improve handling of timeouts for commitAsync() in ShareConsumer.

  #19192 commented on Mar 14, 2025 • 0 new comments

• KAFKA-18760: Deprecate Optional<String> and return String from public EndPoint#listenerName (wip)

  #19191 commented on Mar 17, 2025 • 0 new comments

• KAFKA-18209 Cleanup `__transaction_state` config logic

  #18201 commented on Mar 14, 2025 • 0 new comments

• KAFKA-18201: testGroupMetadataMessageFormatter fails for new consumer protocol

  #18198 commented on Mar 16, 2025 • 0 new comments

• KAFKA-17871: avoid blocking the herder thread when producer flushing hangs

  #18142 commented on Mar 20, 2025 • 0 new comments

• MINOR: Refactored default resource type based auth

  #18130 commented on Mar 19, 2025 • 0 new comments

• MINOR: Improvements for consumer package

  #18107 commented on Mar 17, 2025 • 0 new comments

• KAFKA-17821: the set of configs displayed by `logAll` could be invalid

  #17993 commented on Mar 16, 2025 • 0 new comments

• KAFKA-7025: Some Android compatibility for kafka-client

  #17950 commented on Mar 18, 2025 • 0 new comments

• KAFKA-18125: mirrormaker 2, restrict the number of checkpoint connector tasks

  #17911 commented on Mar 18, 2025 • 0 new comments

• KAFKA-16758: Extend Consumer#close with an option to leave the group or not

  #17614 commented on Mar 20, 2025 • 0 new comments

• Support keystore with multiple alias entries

  #17560 commented on Mar 19, 2025 • 0 new comments

• KAFKA-17834 Improvement the Dockerfile

  #17554 commented on Mar 18, 2025 • 0 new comments

• KAFKA-17747: Trigger rebalance on rack topology changes

  #17444 commented on Mar 19, 2025 • 0 new comments

• KAFKA-16907: Fix RaftUtil's type complexity

  #16831 commented on Mar 20, 2025 • 0 new comments

• KAFKA-17075: Use new health check endpoint in Connect system tests to verify worker readiness

  #16520 commented on Mar 17, 2025 • 0 new comments

• [Don't Merge] Test

  #16463 commented on Mar 20, 2025 • 0 new comments

• KAFKA-16959: ConfigCommand should allow to define both `entity-default` and `entity-name`

  #16381 commented on Mar 18, 2025 • 0 new comments

• KAFKA-10551: Add topic id support to produce request and response

  #15968 commented on Mar 17, 2025 • 0 new comments

• MINOR: Cleanup metadata module

  #18937 commented on Mar 16, 2025 • 0 new comments

• KAFKA-17662: config.providers configuration missing from the docs

  #18930 commented on Mar 20, 2025 • 0 new comments

• [WIP] JWT bearer grant type support

  #18912 commented on Mar 15, 2025 • 0 new comments

• KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties.

  #18828 commented on Mar 19, 2025 • 0 new comments

• KAFKA-16505: Fix lost source raw key and value in store caches and buffers

  #18739 commented on Mar 17, 2025 • 0 new comments

• MINOR: Fix the CLIENT_QUOTA_CALLBACK_CLASS_CONFIG document

  #18713 commented on Mar 21, 2025 • 0 new comments

• KAFKA-18602: Incorrect FinalizedVersionLevel reported for dynamic KRaft quorum

  #18685 commented on Mar 16, 2025 • 0 new comments

• KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol

  #18600 commented on Mar 20, 2025 • 0 new comments

• [WIP]KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread

  #18489 commented on Mar 20, 2025 • 0 new comments

• KAFKA-18613: Unit tests for usage of incorrect RPCs

  #18383 commented on Mar 17, 2025 • 0 new comments

• [WIP] KIP-891: Multiversioning in Kafka Connect - Connector Multiversion Integration Test

  #18360 commented on Mar 17, 2025 • 0 new comments

• KAFKA-18149: Docs improvement for dynamic kraft quorum

  #18350 commented on Mar 16, 2025 • 0 new comments

• [WIP] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests

  #18326 commented on Mar 17, 2025 • 0 new comments

• [WIP] KIP-891: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests

  #18325 commented on Mar 17, 2025 • 0 new comments

• KAFKA-17554: Flaky testFutureCompletionOutsidePoll in ConsumerNetworkClientTest

  #18298 commented on Mar 20, 2025 • 0 new comments

• KAFKA-16260: Deprecate window.size.ms and window.inner.class.serde in StreamsConfig

  #18297 commented on Mar 16, 2025 • 0 new comments

• KAFKA-10730: KafkaApis#handleProduceRequest should use auto-generated protocol

  #18216 commented on Mar 16, 2025 • 0 new comments