51 Pull requests merged by 28 people

• 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

• KAFKA-19042: [10/N] Move PlaintextConsumerAssignTest to clients-integration-tests module

  #19773 merged Jun 5, 2025

• MINOR: clean KafkaConsumer tests

  #19669 merged Jun 5, 2025

• KAFKA-16505: Add source raw key and value

  #18739 merged Jun 5, 2025

• MINOR: rackId is Optional#empty if input string is empty

  #19906 merged Jun 5, 2025

• KAFKA-19373: Fix protocol name comparison

  #19903 merged Jun 5, 2025

• KAFKA-19248: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests

  #18325 merged Jun 5, 2025

• KAFKA-18042: Reject the produce request with lower producer epoch early (KIP-890)

  #19844 merged Jun 4, 2025

• KAFKA-19372: StreamsGroup not subscribed to a topic when empty

  #19901 merged Jun 4, 2025

• KAFKA-19044: Handle tasks that are not present in the current topology

  #19722 merged Jun 4, 2025

• KAFKA-17747: [7/N] Add consumer group integration test for rack aware assignment

  #19856 merged Jun 4, 2025

• KAFKA-19347 Deduplicate ACLs when creating

  #19898 merged Jun 4, 2025

• KAFKA-19328: SharePartitionManagerTest testMultipleConcurrentShareFetches doAnswer chaining needs verification

  #19872 merged Jun 4, 2025

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

  #19758 merged Jun 4, 2025

• MINOR: LIST_CONFIG_RESOURCES in security.html

  #19896 merged Jun 4, 2025

• MINOR: replaced DelayedShareFetchTest mockStatic .close functionality with try-with-resources

  #19892 merged Jun 4, 2025

• KAFKA-18573: Add support for OAuth jwt-bearer grant type

  #19754 merged Jun 4, 2025

• MINOR: Add test for kafka-streams-groups.sh list

  #19894 merged Jun 4, 2025

• MINOR: Remove unnecessary checks.

  #19891 merged Jun 4, 2025

• KAFKA-19155: Update docs/security.html for streams-related RPCs

  #19887 merged Jun 4, 2025

• KAFKA-19250 : txnProducer.abortTransaction() API should not return abortable exception

  #19656 merged Jun 4, 2025

• KAFKA-19176: Update Transactional producer to translate retriable into abortable exceptions

  #19522 merged Jun 3, 2025

• KAFKA-17747: [6/N] Replace subscription metadata with metadata hash in share group

  #19796 merged Jun 3, 2025

• MINOR : Handle error for client telemetry push

  #19881 merged Jun 3, 2025

• KAFKA-19353: Upgrade note and initial docs for KIP-932

  #19863 merged Jun 3, 2025

• KAFKA-17747: [5/N] Replace subscription metadata with metadata hash in stream group

  #19802 merged Jun 3, 2025

• KAFKA-19338: Error on read/write of uninitialized share part.

  #19861 merged Jun 3, 2025

• KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy

  #19878 merged Jun 2, 2025

• KAFKA-19349: Move CreateTopicsRequestWithPolicyTest to clients-integration-tests

  #19849 merged Jun 2, 2025

• KAFKA-18904: [4/N] Add ListClientMetricsResources metric if request is v0 ListConfigResources

  #19877 merged Jun 2, 2025

• KAFKA-19320: Added share_consume_bench_test.py system tests

  #19811 merged Jun 2, 2025

• MINOR: Fixing logs and adding exception in response

  #19859 merged Jun 2, 2025

• KAFKA-16894: share.version becomes stable feature for preview

  #19831 merged Jun 2, 2025

• KAFKA-19321: Added share_consumer_performance.py and related system tests

  #19836 merged Jun 2, 2025

• MINOR: fix failed StreamsBrokerBounceTest e2e tests

  #19839 merged Jun 2, 2025

• MINOR: Refactor awaitNonEmptyRecords to remove dead code and improve clarity

  #19868 merged Jun 2, 2025

31 Pull requests opened by 22 people

• KAFKA-19340: Move DelayedRemoteFetch to the storage module

  #19876 opened Jun 2, 2025

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

  #19880 opened Jun 2, 2025

• KAFKA-18967: Added additional MetadataSchemaCheckerTool tests

  #19882 opened Jun 2, 2025

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

  #19884 opened Jun 3, 2025

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

  #19885 opened Jun 3, 2025

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

  #19886 opened Jun 3, 2025

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

  #19893 opened Jun 4, 2025

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

  #19895 opened Jun 4, 2025

• MINOR: Safe update dependencies

  #19897 opened Jun 4, 2025

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

  #19899 opened Jun 4, 2025

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

  #19904 opened Jun 4, 2025

• KAFKA-19306: Migrate LogCompactionTester to tools module

  #19905 opened Jun 4, 2025

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

  #19908 opened Jun 5, 2025

• MINOR: ELR release note for 4.1

  #19909 opened Jun 5, 2025

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

  #19910 opened Jun 6, 2025

• MINOR: Use `pollUntilTrue` instead of `waitForCondition`

  #19911 opened Jun 6, 2025

• KAFKA-19381: add ConfigDef.ConfigKey.Builder

  #19912 opened Jun 6, 2025

• KAFKA-10357 accidental repartition handling

  #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-19386: Correcting ExpirationReaper thread names from Purgatory

  #19918 opened Jun 7, 2025

• KAFKA-19382:Upgrade junit from 5.10 to 5.13

  #19919 opened Jun 7, 2025

• KAFKA-18834: Fix LoggingResourceTest#testSetLevelDefaultScope

  #19920 opened Jun 7, 2025

• KAFKA-18501: Fix thread leak issue in ClientQuotasRequestTest

  #19921 opened Jun 7, 2025

• KAFKA-18486:Remove ReplicaManager#becomeLeaderOrFollower in `testVerificationErrorConversions`

  #19923 opened Jun 8, 2025

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

  #19924 opened Jun 8, 2025

• MINOR: Cleanup simplify set initialization with Set.of

  #19925 opened Jun 8, 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

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

  #19928 opened Jun 8, 2025

65 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-19315: Move ControllerMutationQuotaManager to server module

  #19807 commented on Jun 6, 2025 • 15 new comments

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

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

• KAFKA-19282: Update quotaTypesEnabled on quota removal in ClientQuotaManager

  #19742 commented on Jun 5, 2025 • 9 new comments

• KAFKA-19325 improve forceComplete() in DelayedOperation

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

• KAFKA-18681 Created GetReplicaLogInfo* RPCs

  #19664 commented on Jun 4, 2025 • 8 new comments

• MINOR: Remove unused code from storage classes

  #19853 commented on Jun 8, 2025 • 8 new comments

• MINOR: Refactor createResponseConfig to avoid collection copy and conversion

  #19867 commented on Jun 7, 2025 • 7 new comments

• KAFKA-14830: Illegal state error in transactional producer

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

• KAFKA-19239 Rewrite IntegrationTestUtils by java

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

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

  #19814 commented on Jun 6, 2025 • 5 new comments

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

  #19854 commented on Jun 3, 2025 • 5 new comments

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

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

• MINOR: Cleanup Connect Module (1/n)

  #19869 commented on Jun 5, 2025 • 5 new comments

• KAFKA-19255: KRaft request manager should support one in-flight request per request type

  #19668 commented on Jun 5, 2025 • 5 new comments

• MINOR: Update stream RPCs security guide in developer documentation

  #19799 commented on Jun 5, 2025 • 3 new comments

• KAFKA-19221: Propagate IOException on LogSegment#close

  #19607 commented on Jun 5, 2025 • 3 new comments

• KAFKA-14145; Faster KRaft HWM replication

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

• KAFKA-16913 - Support external schemas in JSONConverter

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

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

  #19577 commented on Jun 5, 2025 • 2 new comments

• KAFKA-19144 Move DelayedProduce to server module

  #19793 commented on Jun 8, 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

• MINOR: Cleanup JMH-Benchmarks Module

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

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

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

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

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

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

  #16381 commented on Jun 3, 2025 • 0 new comments

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

  #19804 commented on Jun 5, 2025 • 0 new comments

• MINOR: Make InternalStreamsBuilder#addGraphNode public

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

• Update README.md

  #19819 commented on Jun 3, 2025 • 0 new comments

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

  #19820 commented on Jun 4, 2025 • 0 new comments

• (wip )KAFKA-19042 consumer bounce test

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

• KAFKA-19086: Add support for microsecond precision for Connect

  #19845 commented on Jun 5, 2025 • 0 new comments

• KAFKA-19193 Support rack-aware partitioning for Kafka producer

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

• MINOR: Cleanup KafkaApisTest `asJava` conversions

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

• MINOR: Cleanup ShareFetchAcknowledgeRequestTest

  #19852 commented on Jun 7, 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-17037:KIP-919 supports for `describeClientQuotas` and `alterClientQuotas`

  #17339 commented on Jun 5, 2025 • 0 new comments

• KAFKA-17834 Improvement the Dockerfile

  #17554 commented on Jun 3, 2025 • 0 new comments

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

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

• Kafka-16505: Adding dead letter queue in Kafka Streams

  #17942 commented on Jun 5, 2025 • 0 new comments

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

  #17993 commented on Jun 3, 2025 • 0 new comments

• KAFKA-18356 Explicitly setting up instrumentation for inline mocking (Java 21+)

  #18339 commented on Jun 3, 2025 • 0 new comments

• KAFKA-18600 Cleanup NetworkClient zk related logging

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

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

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

• Nilmadhab/co grouped windowed aggrgation

  #19014 commented on Jun 3, 2025 • 0 new comments

• KAFKA-18854:Move DynamicConfig to server module

  #19019 commented on Jun 4, 2025 • 0 new comments

• KAFKA-3987: Replace MD5 for FIPS 140-3 compliance in Log Cleaner.

  #19035 commented on Jun 6, 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

• MINOR: Disable failing "Load Test Catalog" job on public forks

  #19073 commented on Jun 3, 2025 • 0 new comments

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

  #19157 commented on Jun 3, 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 6, 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 5, 2025 • 0 new comments

• KAFKA-19026: AlterConfigPolicy incompatibility between ZK mode and KR…

  #19263 commented on Jun 2, 2025 • 0 new comments

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

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

• KAFKA-19140 ConnectAssignor#performAssignment parameter can be replace to ConnectProtocolCompatibility

  #19476 commented on Jun 5, 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

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

  #19527 commented on Jun 3, 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 8, 2025 • 0 new comments

• KAFKA-19203 Replace `ApiError#exception` by `Error#exception` for KafkaAdminClient

  #19623 commented on Jun 3, 2025 • 0 new comments

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

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