20 Pull requests merged by 15 people

• MINOR: Add test coverage for StorageTool format command feature validation

  #20303 merged Aug 12, 2025

• Revert "MINOR: Update apacheds to 2.0.0.AM26 (#19565)"

  #20341 merged Aug 12, 2025

• MINOR: Remove unnecessary checks in TopicDelta

  #20337 merged Aug 12, 2025

• MINOR: Update apacheds to 2.0.0.AM26

  #19565 merged Aug 12, 2025

• KAFKA-19592: testGenerateAssignmentWithBootstrapServer uses wrong JSON format

  #20336 merged Aug 11, 2025

• KAFKA-19580: Upgrade to spotbugs 4.9.4

  #20333 merged Aug 10, 2025

• KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete method

  #20280 merged Aug 10, 2025

• MINOR: Remove SPAM URL in Streams Documentation

  #20321 merged Aug 8, 2025

• MINOR: Improve RLMM doc

  #20306 merged Aug 8, 2025

• KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close

  #20290 merged Aug 7, 2025

• KAFKA-18068: Document deprecation of PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG

  #20322 merged Aug 7, 2025

• KAFKA-19476: Correcting max delivery on write state failure and lock timeout

  #20310 merged Aug 7, 2025

• MINOR: Cleanup Trogdor Module

  #20214 merged Aug 7, 2025

• KAFKA-18265: Move persister call outside of the lock (3/N)

  #20316 merged Aug 7, 2025

• KAFKA-19464: Remove unnecessary update for find next fetch offset

  #20315 merged Aug 7, 2025

• KAFKA-18068: Fix the typo PARTITIONER_ADPATIVE_PARTITIONING_ENABLE in ProducerConfig

  #20317 merged Aug 7, 2025

• KAFKA-19573: Update num.recovery.threads.per.data.dir configs

  #20299 merged Aug 7, 2025

• MINOR: retry upon missing source topic

  #20284 merged Aug 6, 2025

• MINOR: Fix the link for the heading Errant Record Reporter in connect.html

  #20313 merged Aug 6, 2025

• MINOR: cleanup in QuotaFactory

  #20312 merged Aug 6, 2025

25 Pull requests opened by 20 people

• PoC: Add `rewrite` support for `RemoveUnusedImports`

  #20314 opened Aug 6, 2025

• KAFKA-16926: Optimize BeginQuorumEpoch heartbeat

  #20318 opened Aug 7, 2025

• KAFKA-19582 the current assignments shown by ReassignPartitionsCommand should include the log directories

  #20319 opened Aug 7, 2025

• MINOR: Deflake streams admin api describe streams group with short timeout

  #20320 opened Aug 7, 2025

• KAFKA-19296: Revise AsyncKafkaConsumer event wakeup approach

  #20323 opened Aug 7, 2025

• KAFKA-19589: Reduce number of events generated in AsyncKafkaConsumer.updateFetchPositions()

  #20324 opened Aug 8, 2025

• MINOR: Expose internal topic creation errors to the user

  #20325 opened Aug 8, 2025

• KAFKA-10357 Refactor makeReady to reduce complexity and support upcoming KIP-698 changes

  #20326 opened Aug 8, 2025

• KAFKA-19591 solving issues with `gradlew` content: an old template version was being referenced

  #20327 opened Aug 8, 2025

• MINOR Metrics: use String.intern() to reduce duplicate metric names and tags

  #20328 opened Aug 8, 2025

• KAFKA-15307: Kafka Streams configuration docs outdated

  #20329 opened Aug 8, 2025

• KAFKA-19553: Add comprehensive unit tests for TemperatureDemo streams example

  #20330 opened Aug 9, 2025

• KAFKA-19586 Kafka broker freezes and gets fenced during rolling resta…

  #20331 opened Aug 9, 2025

• MINOR: Cleanups in Test Module (3/n)

  #20332 opened Aug 10, 2025

• [WIP] KAFKA-19112 Unifying LIST-Type Configuration Validation and Default Values

  #20334 opened Aug 10, 2025

• KAFKA-19447: Replace PartitionState with PartitionRegistration in makeFollower/makeLeader

  #20335 opened Aug 11, 2025

• KAFKA-19384: The passing of BrokerRegistrationRequestTest is a false positive

  #20338 opened Aug 11, 2025

• KAFKA-19042: Move AdminClientWithPoliciesIntegrationTest to clients-integration-tests module

  #20339 opened Aug 11, 2025

• KAFKA-19596: Improve visibility when topic auto-creation fails

  #20340 opened Aug 12, 2025

• KAFKA-19597: Stop the RSM after closing the remote-log reader threads to handle requests gracefully

  #20342 opened Aug 12, 2025

• MINOR: Update apacheds to 2.0.0.AM25

  #20343 opened Aug 12, 2025

• MINOR Use new Develocity secret for flaky test report

  #20344 opened Aug 12, 2025

• KAFKA-19599: Reduce the frequency of ReplicaNotAvailableException thrown to clients when RLMM is not ready

  #20345 opened Aug 12, 2025

• MINOR: Cleanup Metadata Module

  #20346 opened Aug 12, 2025

• MINOR: Port RestoreIntegrationTest to the new protocol

  #20347 opened Aug 12, 2025

61 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-19078: Automatic controller addition to cluster metadata partition

  #19589 commented on Aug 12, 2025 • 13 new comments

• KAFKA-18884: Move TransactionMetadata to transaction-coordinator module

  #19699 commented on Aug 11, 2025 • 11 new comments

• MINOR: Cleanup Connect Module (3/n)

  #20156 commented on Aug 12, 2025 • 10 new comments

• MINOR: Migrate EligibleLeaderReplicasIntegrationTest to use new test infra

  #20199 commented on Aug 11, 2025 • 5 new comments

• KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry

  #20144 commented on Aug 7, 2025 • 4 new comments

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

  #19914 commented on Aug 11, 2025 • 3 new comments

• KAFKA-17019: Producer TimeoutException should include root cause

  #20159 commented on Aug 11, 2025 • 2 new comments

• KAFKA-19301: Move and rewrite partition state classes to Java in org.apache.kafka.storage.internals.log

  #20083 commented on Aug 6, 2025 • 1 new comment

• KAFKA-18105 Fix flaky PlaintextAdminIntegrationTest#testElectPreferredLeaders

  #20068 commented on Aug 6, 2025 • 1 new comment

• KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes

  #20213 commented on Aug 7, 2025 • 1 new comment

• KAFKA-19574: Improve producer and consumer config files

  #20302 commented on Aug 12, 2025 • 0 new comments

• KAFKA-19544: Improve `MetadataVersion.fromVersionString()` to take an enableUnstableFeature flag

  #20248 commented on Aug 11, 2025 • 0 new comments

• KAFKA-19020: Handle strict max fetch records in share fetch

  #20246 commented on Aug 6, 2025 • 0 new comments

• PoC: Add `rewrite` support for `errorprone.refasterrules`

  #20219 commented on Aug 6, 2025 • 0 new comments

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

  #20203 commented on Aug 11, 2025 • 0 new comments

• Feature/openj9 integration

  #20197 commented on Aug 9, 2025 • 0 new comments

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

  #20184 commented on Aug 11, 2025 • 0 new comments

• MINOR: Cleanup Server Module

  #20180 commented on Aug 12, 2025 • 0 new comments

• KAFKA-19011: Improve EndToEndLatency Tool with argument parser and message key/header support

  #20301 commented on Aug 12, 2025 • 0 new comments

• KAFKA-16768: SocketServer leaks accepted SocketChannel instances due to race condition

  #20300 commented on Aug 12, 2025 • 0 new comments

• KAFKA-19481: Fix flaky test testConsumerGroupHeartbeatWithRegex

  #20298 commented on Aug 10, 2025 • 0 new comments

• Kafka streams api enhanced

  #20296 commented on Aug 10, 2025 • 0 new comments

• KAFKA-19537: Improve Exit Code Handling in StreamsGroupCommand

  #20293 commented on Aug 9, 2025 • 0 new comments

• KAFKA-13152: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"

  #20292 commented on Aug 9, 2025 • 0 new comments

• KAFKA-19571: Race condition between log segment flush and file deletion causing log dir to go offline

  #20289 commented on Aug 9, 2025 • 0 new comments

• KAFKA-19479: at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees

  #20285 commented on Aug 8, 2025 • 0 new comments

• MINOR: Note KS broker replication factor limitation

  #20279 commented on Aug 8, 2025 • 0 new comments

• MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable

  #20271 commented on Aug 8, 2025 • 0 new comments

• KAFKA-19564: Close Consumer in ConsumerPerformance only after metrics displayed

  #20267 commented on Aug 12, 2025 • 0 new comments

• KAFKA-19565 Integration test for Streams-related Admin APIs[2/N]

  #20266 commented on Aug 6, 2025 • 0 new comments

• KAFKA-17876/ KAFKA-19150 Rename AssignmentsManager and RemoteStorageThreadPool metrics

  #20265 commented on Aug 8, 2025 • 0 new comments

• Kafka 16801 FIx Streams upgrade :test target doesn't find any junit tests

  #20260 commented on Aug 7, 2025 • 0 new comments

• fix(windows): replace deprecated wmic command on Windows 11

  #20257 commented on Aug 6, 2025 • 0 new comments

• KAFKA-15038: Replace topicIdByPartitionMap with MetadataCache instance in RemoteLogManager

  #20256 commented on Aug 12, 2025 • 0 new comments

• KAFKA-17339: LocalLogManager should support RaftClient#schedulePreparedAppend

  #17544 commented on Aug 10, 2025 • 0 new comments

• KAFKA-18744: reuse LoginCallbackHandler on kerberos re-login

  #18589 commented on Aug 10, 2025 • 0 new comments

• KAFKA-18171: Unexpected Change in bootstrap.servers Behavior After Upgrade to 3.8.0

  #18706 commented on Aug 7, 2025 • 0 new comments

• KAFKA-18836 Make ConsumerGroupMetadata an interface

  #18977 commented on Aug 7, 2025 • 0 new comments

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

  #18987 commented on Aug 6, 2025 • 0 new comments

• Clarification of topic configuration 'retention.bytes'

  #19051 commented on Aug 9, 2025 • 0 new comments

• KAFKA-17651: Implement `describeUserScramCredentials`

  #19066 commented on Aug 11, 2025 • 0 new comments

• Fix IllegalStateException for Transaction Producer

  #19204 commented on Aug 7, 2025 • 0 new comments

• KAFKA-17573: Move KRaftMetadataCache to metadata module

  #19232 commented on Aug 7, 2025 • 0 new comments

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

  #19236 commented on Aug 12, 2025 • 0 new comments

• KAFKA-18185: remove internal.leave.group.on.close config

  #19400 commented on Aug 11, 2025 • 0 new comments

• KAFKA-19039: The refresh_collaborators.py script messes .asf.yaml

  #19459 commented on Aug 7, 2025 • 0 new comments

• KAFKA-18752: Fix the warning of no-operation caused by slf4j in building kafka

  #19501 commented on Aug 11, 2025 • 0 new comments

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

  #19513 commented on Aug 12, 2025 • 0 new comments

• KAFKA-15283:[1/N] Client support for OffsetCommit with topic ID

  #19577 commented on Aug 11, 2025 • 0 new comments

• KAFKA-18996 Expose addReadOnlyStateStore in DSL (StreamsBuilder)

  #19621 commented on Aug 10, 2025 • 0 new comments

• Refactored DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation

  #19636 commented on Aug 12, 2025 • 0 new comments

• MINOR: Fix some Request toString methods (#19655)

  #19695 commented on Aug 11, 2025 • 0 new comments

• MINOR: Fix some Request toString methods (#19655)

  #19710 commented on Aug 12, 2025 • 0 new comments

• MINOR: Fix some Request toString methods (#19655)

  #19711 commented on Aug 12, 2025 • 0 new comments

• KAFKA-19299: Fix race condition in RemoteIndexCacheTest

  #19927 commented on Aug 7, 2025 • 0 new comments

• Bump requests from 2.31.0 to 2.32.4 in /tests

  #19940 commented on Aug 7, 2025 • 0 new comments

• KAFKA-18193 Refactor Kafka Streams CloseOptions to Fluent API Style

  #19955 commented on Aug 6, 2025 • 0 new comments

• KAFKA-19259: Async consumer fetch intermittent delays on console consumer

  #19980 commented on Aug 12, 2025 • 0 new comments

• KAFKA-10357 Refactor makeReady to reduce complexity and support upcoming KIP-698 changes

  #20063 commented on Aug 8, 2025 • 0 new comments

• MINOR: Upgrade log4j to version 2.25.1

  #20132 commented on Aug 8, 2025 • 0 new comments

• KAFKA-19492: Add logging in deleteRecordsOnLocalLog for out of range …

  #20141 commented on Aug 12, 2025 • 0 new comments