15 Pull requests merged by 13 people

• MINOR: Re-add pageview demo to :streams:examples and remove dependency on :connect:json

  #20239 merged Jul 25, 2025

• MINOR: Improve Kafka Streams Protocol Upgrade Doc

  #20241 merged Jul 25, 2025

• MINOR: Optimize RemoteLogManager#buildFilteredLeaderEpochMap

  #20205 merged Jul 24, 2025

• KAFKA-19400: Update AddRaftVoterRequest RPC to version 1

  #19982 merged Jul 24, 2025

• KAFKA-19545: Remove MetadataVersionValidator

  #20233 merged Jul 24, 2025

• MINOR: Prevent error message swallow in persister.

  #20238 merged Jul 24, 2025

• KAFKA-19499: Corrected the logger name in PersisterStateManagerHandler

  #20175 merged Jul 24, 2025

• MINOR: typo in javadoc

  #20113 merged Jul 24, 2025

• KAFKA-17645: KIP-1052: Enable warmup in producer performance test

  #17340 merged Jul 24, 2025

• KAFKA-18265: Move inflight batch and state classes from SharePartition (2/N)

  #20230 merged Jul 23, 2025

• KAFKA-18265: Move acquisition lock classes from share partition (1/N)

  #20227 merged Jul 23, 2025

• KAFKA-19523: Gracefully handle error while building remoteLogAuxState

  #20201 merged Jul 23, 2025

• MINOR: Declare inner RocksDBDualCFRangeIterator class as static

  #20220 merged Jul 23, 2025

• KAFKA-19525: Refactor TopicBasedRLMM implementation to remove unused code

  #20204 merged Jul 23, 2025

• MINOR: Fix flaky tests in Tools modules

  #20225 merged Jul 23, 2025

11 Pull requests opened by 10 people

• MINOR: Fix duplicate 'to' in ExactlyOnceMessageProcessor javadoc

  #20228 opened Jul 23, 2025

• MINOR: Optimize map lookup efficiency with getOrDefault

  #20229 opened Jul 23, 2025

• Refactor metrics management with AbstractMetricsManager

  #20232 opened Jul 24, 2025

• KAFKA-19539: Kafka Streams should also purge internal topics based on user commit requests

  #20234 opened Jul 24, 2025

• MINOR: `kafka-consumer-groups.sh` should not fail when partition offline

  #20235 opened Jul 24, 2025

• KAFKA-19531 Add an end-to-end integration test for the DLQ feature

  #20236 opened Jul 24, 2025

• MINOR: improve the min.insync.replicas doc

  #20237 opened Jul 24, 2025

• KAFKA-19537 StreamsGroupCommand should return exit code

  #20240 opened Jul 25, 2025

• KAFKA-19479 Topic replay code does not handle creation and deletion properly if it occurs in the same batch

  #20242 opened Jul 25, 2025

• KAFKA-19518: Remove the usage of KafkaMetricsGroup(Class<?> klass)

  #20243 opened Jul 26, 2025

• KAFKA-19550 Integration test for Streams-related Admin APIs[1/N]

  #20244 opened Jul 26, 2025

35 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.

• [Experimental] Add `rewrite` support for `RemoveUnusedPrivateMethods` & `RemoveUnusedImports`

  #20219 commented on Jul 25, 2025 • 10 new comments

• MINOR: Cleanup Tools Module (2/n)

  #20096 commented on Jul 25, 2025 • 7 new comments

• KAFKA-19354: KRaft observer should fetch from leader after rediscovery

  #19854 commented on Jul 25, 2025 • 7 new comments

• KAFKA-19530 RemoteLogManager should record lag stats when remote storage is offline

  #20218 commented on Jul 23, 2025 • 6 new comments

• KAFKA-19425: Stop the server when fail to initialize to avoid local segment never got deleted.

  #20007 commented on Jul 25, 2025 • 5 new comments

• MINOR: Migrate EligibleLeaderReplicasIntegrationTestto use new test infra

  #20199 commented on Jul 25, 2025 • 5 new comments

• KAFKA-12281: Deprecate BrokerNotFoundException

  #20192 commented on Jul 24, 2025 • 4 new comments

• MINOR: Reword warning message when internal deprecated properties are used

  #20224 commented on Jul 25, 2025 • 4 new comments

• MINOR: Cleanup Server Module

  #20180 commented on Jul 25, 2025 • 2 new comments

• KAFKA-19426: TopicBasedRemoteLogMetadataManager's initial should happen after the broker ready.

  #20203 commented on Jul 25, 2025 • 2 new comments

• KAFKA-19306: Migrate LogCompactionTester to tools module

  #19905 commented on Jul 24, 2025 • 2 new comments

• KAFKA-19498: Add include argument to ConsumerPerformance tool

  #20221 commented on Jul 25, 2025 • 2 new comments

• KAFKA-16717 [3/N]: Add AdminClient.alterShareGroupOffsets

  #19820 commented on Jul 24, 2025 • 1 new comment

• KAFKA-19489: storage tool should check controller.quorum.voters is not set alongside a dynamic quorum flag when formatting

  #20136 commented on Jul 24, 2025 • 1 new comment

• [WIP] KAFKA-19012: Messages ending up on the wrong topic

  #20146 commented on Jul 25, 2025 • 1 new comment

• MINOR: Remove duplicate renewTimePeriodOpt in DelegationTokenCommand validation

  #20177 commented on Jul 23, 2025 • 1 new comment

• MINOR: Cleanup Trogdor Module

  #20214 commented on Jul 23, 2025 • 0 new comments

• MINOR:Extract public code

  #20198 commented on Jul 26, 2025 • 0 new comments

• [chore] Add project icon for `IntelliJ IDEA`

  #20215 commented on Jul 24, 2025 • 0 new comments

• Feature/openj9 integration

  #20197 commented on Jul 26, 2025 • 0 new comments

• KAFKA-19524: Fix UnsupportedOperationException in connect-plugin-path

  #20222 commented on Jul 25, 2025 • 0 new comments

• Revert "MINOR: Cleanup metadata module"

  #20226 commented on Jul 24, 2025 • 0 new comments

• KAFKA-19516: Added a request timeout of 120000ms to CreateTopics in ShareFetchAcknolwedgeRequestTest methods

  #20184 commented on Jul 24, 2025 • 0 new comments

• MINOR: fix e2e docs for test that cannot be run directly

  #20145 commented on Jul 25, 2025 • 0 new comments

• KAFKA-19276: Trigger rebalance for streams config update

  #19967 commented on Jul 23, 2025 • 0 new comments

• KAFKA-19395 - Updated Junit and mockito version and license information in NOTICE-binary for Jakarta RESTful Web Services Project

  #19943 commented on Jul 24, 2025 • 0 new comments

• KAFKA-19357: AsyncConsumer#close hangs as commitAsync never completes when coordinator is missing

  #19914 commented on Jul 26, 2025 • 0 new comments

• KAFKA-19078: Implement automatic controller addition to cluster metadata partition

  #19589 commented on Jul 24, 2025 • 0 new comments

• [Work in progress] [KAFKA-19174] Gradle version upgrade 8 -->> 9

  #19513 commented on Jul 26, 2025 • 0 new comments

• KAFKA-18960: The default type of ssh key used by vagrant is disabled …

  #19264 commented on Jul 25, 2025 • 0 new comments

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

  #19236 commented on Jul 24, 2025 • 0 new comments

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

  #18360 commented on Jul 26, 2025 • 0 new comments

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

  #18326 commented on Jul 26, 2025 • 0 new comments

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

  #18142 commented on Jul 25, 2025 • 0 new comments

• KAFKA-13468: Consumers may hang because IOException in Log#<init> does not trigger KafkaStorageException

  #11520 commented on Jul 25, 2025 • 0 new comments