49 Pull requests merged by 32 people

• KAFKA-19237: add dynamic config remote.log.manager.follower.thread.pool.size

  #19809 merged Jun 13, 2025

• MINOR: Fixing client telemetry validate request

  #19959 merged Jun 12, 2025

• MINOR: Add comment why we use thread-id filtering when registering metrics for KIP-1076

  #19957 merged Jun 12, 2025

• KAFKA-19153: Add OAuth integration tests

  #19938 merged Jun 12, 2025

• KAFKA-19367: Fix InitProducerId with TV2 double-increments epoch if ongoing transaction is aborted

  #19910 merged Jun 12, 2025

• KAFKA-18117; KAFKA-18729: Use assigned topic IDs to avoid full metadata requests on broker-side regex

  #19814 merged Jun 12, 2025

• KAFKA-17089: Incorrect JWT parsing in OAuthBearerUnsecuredJws

  #19946 merged Jun 12, 2025

• KAFKA-18961: Time-based refresh for server-side RE2J regex

  #19904 merged Jun 12, 2025

• Fixed ZooKeeper delete commands

  #19953 merged Jun 12, 2025

• MINOR: Bump commons beanutils39

  #19949 merged Jun 12, 2025

• KAFKA-18486: Migrate testPartitionMetadataFile to use applyDelta in place of deprecated becomeLeaderOrFollower

  #19947 merged Jun 12, 2025

• KAFKA-18486 Update testClearPurgatoryOnBecomingFollower etc with KRaft mechanism in ReplicaManagerTest

  #19924 merged Jun 11, 2025

• KAFKA-18486:Remove ReplicaManager#becomeLeaderOrFollower in testVerificationErrorConversions

  #19923 merged Jun 11, 2025

• MINOR: Cleanup simplify set initialization with Set.of

  #19925 merged Jun 11, 2025

• MINOR: Bump trunk to 4.2.0-SNAPSHOT

  #19944 merged Jun 11, 2025

• KAFKA-19359: force bump commons-beanutils for CVE-2025-48734

  #19939 merged Jun 11, 2025

• MINOR: Update opentelemetry-proto dependency

  #19945 merged Jun 10, 2025

• KAFKA-19221: Propagate IOException on LogSegment#close

  #19607 merged Jun 10, 2025

• KAFKA-19389: Fix memory consumption for completed share fetch requests

  #19928 merged Jun 10, 2025

• MINOR: Remove unused code from storage classes

  #19853 merged Jun 10, 2025

• KAFKA-19244: Add support for kafka-streams-groups.sh options (delete offsets) [4/N]

  #19895 merged Jun 10, 2025

• MINOR: Improve the prompt in committer-tools/reviewers.py

  #19942 merged Jun 10, 2025

• KAFKA-19376: Throw an error message if any unsupported feature is used with KIP-1071

  #19908 merged Jun 10, 2025

• KAFKA-19392: Fix metadata.log.segment.ms not being applied

  #19936 merged Jun 10, 2025

• KAFKA-19382:Upgrade junit from 5.10 to 5.13

  #19919 merged Jun 10, 2025

• KAFKA-18486 Remove becomeLeaderOrFollower from readFromLogWithOffsetOutOfRange and other related methods.

  #19929 merged Jun 10, 2025

• KAFKA-19283: Update transaction exception handling documentation

  #19931 merged Jun 10, 2025

• MINOR: ELR release note for 4.1

  #19909 merged Jun 10, 2025

• KAFKA-19271: allow intercepting internal method call

  #19832 merged Jun 9, 2025

• MINOR: Safe update dependencies

  #19897 merged Jun 9, 2025

• KAFKA-19386: Correcting ExpirationReaper thread names from Purgatory

  #19918 merged Jun 9, 2025

• MINOR: Use pollUntilTrue instead of waitForCondition

  #19911 merged Jun 9, 2025

• KAFKA-19334 MetadataShell execution unintentionally deletes lock file

  #19817 merged Jun 9, 2025

• MINOR: Follow up KAFKA-19080 MetadataLogConfig

  #19842 merged Jun 8, 2025

• KAFKA-18486:Remove ReplicaManager#becomeLeaderOrFollower in testReplicaAlterLogDirs

  #19922 merged Jun 8, 2025

• KAFKA-19042: [12/N] Move PlaintextConsumerSubscriptionTest to client-integration-tests module

  #19827 merged Jun 7, 2025

• KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds

  #19883 merged Jun 7, 2025

• KAFKA-18486: Update activeProducerState wih KRaft mechanism in ReplicaManagerTest

  #19890 merged Jun 7, 2025

• KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java

  #19879 merged Jun 7, 2025

• KAFKA-19295: Remove AsyncKafkaConsumer event ID generation

  #19915 merged Jun 7, 2025

• MINOR: Rename ambiguous method name

  #19875 merged Jun 6, 2025

• KAFKA-18202: Add rejection for non-zero sequences in TV2 (KIP-890)

  #19902 merged Jun 6, 2025

• KAFKA-19309 : Add transaction client template code in kafka examples

  #15913 merged Jun 6, 2025

• KAFKA-19369: Add group.share.assignors config and integration test

  #19900 merged Jun 6, 2025

• KAFKA-19290: Exploit mapKey optimisation in protocol requests and responses

  #19815 merged Jun 6, 2025

• KAFKA-18913: Start state updater in task manager

  #19889 merged Jun 6, 2025

• MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer

  #19888 merged Jun 6, 2025

• KAFKA-19370: Create JMH benchmark for share group assignor

  #19907 merged Jun 6, 2025

• MINOR: Cleanup Core Module- Scala Modules (4/n)

  #19805 merged Jun 6, 2025

25 Pull requests opened by 24 people

• KAFKA-19381: add ConfigDef.ConfigKey.Builder

  #19912 opened Jun 6, 2025

• KAFKA-10357: Add explicit internal topic initialization for Kafka Streams

  #19913 opened Jun 6, 2025

• KAFKA-19357: AsyncConsumer#close hangs during closing because the commitAsync request never completes due to a missing coordinator

  #19914 opened Jun 6, 2025

• KAFKA-19383: Handle the deleted topics when applying ClearElrRecord

  #19916 opened Jun 6, 2025

• KAFKA-19297: Refactor AsyncKafkaConsumer's use of Java Streams APIs in critical sections

  #19917 opened Jun 6, 2025

• KAFKA-18834: Fix LoggingResourceTest#testSetLevelDefaultScope

  #19920 opened Jun 7, 2025

• KAFKA-18501: Fix thread leak issue in ClientQuotasRequestTest

  #19921 opened Jun 7, 2025

• MINOR: Fix duplicate IPv6 entries in ducker-ak

  #19926 opened Jun 8, 2025

• KAFKA-19299: Fix race condition in RemoteIndexCacheTest

  #19927 opened Jun 8, 2025

• MINOR: Update Protocol Buffers documentation URLs

  #19930 opened Jun 9, 2025

• MINOR: add lower case lister name integration test

  #19932 opened Jun 9, 2025

• KAFKA-14895: [2/N] Move AddPartitionsToTxnManager files to java

  #19933 opened Jun 9, 2025

• Update EndToEndLatency.java

  #19934 opened Jun 9, 2025

• KAFKA-7699: Anchored punctuation

  #19937 opened Jun 9, 2025

• Bump requests from 2.31.0 to 2.32.4 in /tests

  #19940 opened Jun 10, 2025

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

  #19943 opened Jun 10, 2025

• MINOR: rename exception `e` to `swallow` where appropriate

  #19948 opened Jun 11, 2025

• KAFKA-19402: Typo in EventAccumulator.java

  #19951 opened Jun 12, 2025

• KAFKA-18486: Migrate ReplicaManagerTest to use applyDelta

  #19952 opened Jun 12, 2025

• KAFKA-18486: Migrate ReplicaManagerTest to use applyDelta

  #19954 opened Jun 12, 2025

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

  #19955 opened Jun 12, 2025

• MINOR: Revert initial transactional state store semantics commit

  #19956 opened Jun 12, 2025

• Cherry Pick KAFKA-19367 to 4.0

  #19958 opened Jun 12, 2025

• KAFKA-18486: Migrate ReplicaManagerTest RemoteFetchExpiresPerSecMetric and RemoteLogReaderMetrics with applyDelta

  #19960 opened Jun 12, 2025

• KAFKA-19390: Call AbstractIndex.safeForceUnmap() in AbstractIndex.resize() on Linux to prevent stale index file memory mappings

  #19961 opened Jun 13, 2025

64 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-14830: Illegal state error in transactional producer

  #17022 commented on Jun 12, 2025 • 12 new comments

• KAFKA-19244: Add support for kafka-streams-groups.sh options (reset-offsets) [1/N]

  #19646 commented on Jun 12, 2025 • 11 new comments

• KAFKA-15599: Move KafkaMetadataLog to the raft module

  #19762 commented on Jun 11, 2025 • 8 new comments

• KAFKA-18627: Deprecated "org.apache.kafka.disallowed.login.modules"

  #18683 commented on Jun 13, 2025 • 8 new comments

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

  #19400 commented on Jun 9, 2025 • 7 new comments

• KAFKA-19239 Rewrite IntegrationTestUtils by java

  #19776 commented on Jun 12, 2025 • 6 new comments

• KAFKA-19324: Make org.apache.kafka.common.test.TestUtils package-private to prevent cross-module access

  #19884 commented on Jun 12, 2025 • 5 new comments

• KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.1.3

  #19880 commented on Jun 12, 2025 • 4 new comments

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

  #18930 commented on Jun 12, 2025 • 3 new comments

• [WIP]KAFKA-18896 add KIP-877 support for Login

  #19527 commented on Jun 11, 2025 • 3 new comments

• KAFKA-14145; Faster KRaft HWM replication

  #19800 commented on Jun 12, 2025 • 2 new comments

• MINOR: Refactor createResponseConfig to avoid collection copy and conversion

  #19867 commented on Jun 11, 2025 • 2 new comments

• KAFKA-16913 - Support external schemas in JSONConverter

  #19449 commented on Jun 6, 2025 • 2 new comments

• KAFKA-19144 Move DelayedProduce to server module

  #19793 commented on Jun 9, 2025 • 1 new comment

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

  #19699 commented on Jun 11, 2025 • 1 new comment

• MINOR: Update stream RPCs security guide in developer documentation

  #19799 commented on Jun 10, 2025 • 1 new comment

• KAFKA-19350 Don't propagate the error caused by CreateTopicPolicy to FatalFaultHandler

  #19857 commented on Jun 7, 2025 • 1 new comment

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

  #19854 commented on Jun 9, 2025 • 1 new comment

• KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo

  #19803 commented on Jun 10, 2025 • 0 new comments

• MINOR: Make InternalStreamsBuilder#addGraphNode public

  #19816 commented on Jun 6, 2025 • 0 new comments

• MINOR: Cleanup JMH-Benchmarks Module

  #19791 commented on Jun 11, 2025 • 0 new comments

• KAFKA-19262 Add a test to verify all metrics naming pattern

  #19720 commented on Jun 12, 2025 • 0 new comments

• (wip )KAFKA-19042 consumer bounce test

  #19822 commented on Jun 13, 2025 • 0 new comments

• MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits

  #19837 commented on Jun 12, 2025 • 0 new comments

• MINOR: Cleanup ShareFetchAcknowledgeRequestTest

  #19852 commented on Jun 11, 2025 • 0 new comments

• KAFKA-19048: Minimal movement replica balancing algorithm for reassignment

  #19858 commented on Jun 7, 2025 • 0 new comments

• KAFKA-19010: Added JVM argument to default configuration

  #19870 commented on Jun 8, 2025 • 0 new comments

• MINOR: Cleanup Connect Module (2/n)

  #19871 commented on Jun 8, 2025 • 0 new comments

• KAFKA-18995: Add bidirectional replication check

  #19874 commented on Jun 9, 2025 • 0 new comments

• KAFKA-19340: Move DelayedRemoteFetch to the storage module

  #19876 commented on Jun 13, 2025 • 0 new comments

• KAFKA-18967: Added additional MetadataSchemaCheckerTool tests

  #19882 commented on Jun 10, 2025 • 0 new comments

• KAFKA-15283:[2/2] Client support for OffsetFetch with topic ID

  #19885 commented on Jun 13, 2025 • 0 new comments

• KAFKA-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer

  #19886 commented on Jun 12, 2025 • 0 new comments

• KAFKA-19244: Add support for kafka-streams-groups.sh options (delete internal topics) [3/N]

  #19893 commented on Jun 6, 2025 • 0 new comments

• When a broker restarts, it should not attempt to create the __remote_log_metadata topic if it already exists.

  #19899 commented on Jun 11, 2025 • 0 new comments

• KAFKA-19306: Migrate LogCompactionTester to tools module

  #19905 commented on Jun 12, 2025 • 0 new comments

• KAFKA-15615: Improve handling of fetching during metadata updates

  #15647 commented on Jun 10, 2025 • 0 new comments

• Kafka-16355: Fix ConcurrentModificationException in evictWhile Method

  #16554 commented on Jun 11, 2025 • 0 new comments

• KIP-1028: AK 3.8.0 Docker Official Image Assets

  #16768 commented on Jun 10, 2025 • 0 new comments

• KAFKA-17259: Support to override serverProperties and restart cluster in ClusterTestExtensions

  #16808 commented on Jun 12, 2025 • 0 new comments

• KAFKA-18024 ConcurrentModificationException in Kafka OffsetFetcher - Proposal for Thread-Safety Fix - Update OffsetFetcher.java

  #17826 commented on Jun 11, 2025 • 0 new comments

• KAFKA-18166: Indefinite timeout when publishing events to RLMM (RemoteLogMetadataManager)

  #18097 commented on Jun 12, 2025 • 0 new comments

• KAFKA-18209 Cleanup `__transaction_state` config logic

  #18201 commented on Jun 13, 2025 • 0 new comments

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

  #18489 commented on Jun 11, 2025 • 0 new comments

• KAFKA-18600 Cleanup NetworkClient zk related logging

  #18644 commented on Jun 9, 2025 • 0 new comments

• DRAFT KAFKA-18692: Consider to unify KStreamImpl "repartitionRequired" with GraphNode "keyChangingOperation"

  #18800 commented on Jun 12, 2025 • 0 new comments

• KAFKA-10844: groupBy without shuffling

  #18811 commented on Jun 10, 2025 • 0 new comments

• KAFKA-10789: Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest

  #18816 commented on Jun 11, 2025 • 0 new comments

• Clarification of topic configuration 'retention.bytes'

  #19051 commented on Jun 7, 2025 • 0 new comments

• KAFKA-17651: Implement `describeUserScramCredentials`

  #19066 commented on Jun 6, 2025 • 0 new comments

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

  #19082 commented on Jun 13, 2025 • 0 new comments

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

  #19157 commented on Jun 10, 2025 • 0 new comments

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

  #19231 commented on Jun 7, 2025 • 0 new comments

• KAFKA-17573: Move KRaftMetadataCache to metadata module

  #19232 commented on Jun 11, 2025 • 0 new comments

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

  #19236 commented on Jun 7, 2025 • 0 new comments

• KAFKA-19008 Remove scala version from artifacts

  #19241 commented on Jun 12, 2025 • 0 new comments

• KAFKA-18913: Removing _state.updater.enabled_ flag through the Stream…

  #19275 commented on Jun 10, 2025 • 0 new comments

• KAFKA-19070:: Adding task number to user provided client id to ensure each consumer has a unique client ID to avoid metric registration conflicts.

  #19341 commented on Jun 13, 2025 • 0 new comments

• KAFKA-18894: Add KIP-877 support for ConfigProvider

  #19397 commented on Jun 7, 2025 • 0 new comments

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

  #19501 commented on Jun 6, 2025 • 0 new comments

• MINOR: Update apacheds to 2.0.0.AM27

  #19565 commented on Jun 7, 2025 • 0 new comments

• KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller

  #19566 commented on Jun 11, 2025 • 0 new comments

• KAFKA-18681 Created GetReplicaLogInfo* RPCs

  #19664 commented on Jun 12, 2025 • 0 new comments

• KAFKA-19246; OffsetFetch API does not return group level errors correctly with version 1

  #19704 commented on Jun 9, 2025 • 0 new comments