35 Pull requests merged by 21 people

• KAFKA-18345; Wait the entire election timeout on election loss

  #19747 merged May 23, 2025

• MINOR: Bugfix in GroupMetadataManager.testShareGroupInitializeSuccess.

  #19795 merged May 23, 2025

• MINOR: Fix the CLIENT_QUOTA_CALLBACK_CLASS_CONFIG document

  #18713 merged May 23, 2025

• KAFKA-19260: Move LoggingController to server module

  #19687 merged May 23, 2025

• HOTFIX: Fix GroupMetadataManager#completeAlterShareGroupOffsets to use InitMapValue in addInitializingTopicsRecords

  #19792 merged May 23, 2025

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

  #18929 merged May 23, 2025

• KAFKA-19069: DumpLogSegments does not dump the LEADER_CHANGE record

  #19729 merged May 23, 2025

• KAFKA-19204: Add timestamp to share state metadata init maps [1/N]

  #19781 merged May 23, 2025

• MINOR: suppress removal warnings for listClientMetricsResources

  #19787 merged May 22, 2025

• KAFKA-19042: [7/N] Move PlaintextConsumerPollTest to client-integration-tests module

  #19582 merged May 22, 2025

• KAFKA-19314: Remove unnecessary code of closing snapshotWriter

  #19763 merged May 22, 2025

• HOTFIX: Fix testDeleteConsumerGroupOffsets

  #19788 merged May 22, 2025

• MINOR: Update Scala to v2.13.16 to support Java 24

  #19782 merged May 22, 2025

• KAFKA-18904: Add Admin#listConfigResources [2/N]

  #19743 merged May 22, 2025

• KAFKA-19291: Increase the timeout of remote storage share fetch requests in purgatory

  #19757 merged May 22, 2025

• KAFKA-4650: Add unit tests for GraphNode class

  #18951 merged May 21, 2025

• KAFKA-19287: document all group coordinator metrics

  #19749 merged May 21, 2025

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

  #19380 merged May 21, 2025

• MINOR: update the gradle version for java 24 support

  #19760 merged May 21, 2025

• MINOR: Add more description to KIP-1148

  #19768 merged May 21, 2025

• MINOR: add 3.9.1 to system tests

  #19772 merged May 21, 2025

• MINOR: Cleanup Shell Module

  #19771 merged May 21, 2025

• MINOR: Update 3.9.1 versions

  #19756 merged May 21, 2025

• KAFKA-18783 : Extend InvalidConfigurationException related exceptions

  #19731 merged May 20, 2025

• MINOR:- Edit test in transaction command

  #19746 merged May 20, 2025

• MINOR Fix: API Responses missing latest version in Kafka protocol guide

  #19769 merged May 20, 2025

• MINOR: Cleanup Share Coordinator

  #19770 merged May 20, 2025

• MINOR: Update the supported tags in docker_scan.yml

  #19766 merged May 20, 2025

• KAFKA-19302: Move ReplicaState and Replica to server module

  #19755 merged May 19, 2025

• KAFKA-19042: [5/N] Move PlaintextConsumerCommitTest to client-integration-tests module

  #19389 merged May 19, 2025

• KAFKA-17747: [3/N] Get rid of TopicMetadata in SubscribedTopicDescriberImpl

  #19611 merged May 19, 2025

• MINOR: Refactor shared-group request handle methods to return CompletableFuture for consistent error handling

  #19724 merged May 18, 2025

• MINOR: Remove unnecessary test conditions where ListOffsetsRequest version is 0

  #19738 merged May 18, 2025

• KAFKA-19202: Enable KIP-1071 in streams_eos_test

  #19700 merged May 17, 2025

• KAFKA-19280: Fix NoSuchElementException in UnifiedLog

  #19717 merged May 17, 2025

31 Pull requests opened by 25 people

• Kafka 18913/cleanup state updater on failure

  #19750 opened May 17, 2025

• KAFKA-15370: Support Participation in 2PC (KIP-939) (K/N)

  #19751 opened May 17, 2025

• KAFKA-18903: update-cache.sh use curl + jq to get sha contains gradle cache instead of gh cli

  #19753 opened May 18, 2025

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

  #19754 opened May 18, 2025

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

  #19758 opened May 19, 2025

• KAFKA-19312: Avoiding concurrent execution of onComplete and tryComplete

  #19759 opened May 19, 2025

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

  #19761 opened May 19, 2025

• KAFKA-15599: Move KafkaMetadataLog to the raft module

  #19762 opened May 19, 2025

• KAFKA-7516: Attempt to dynamically load ManagementFactory

  #19764 opened May 19, 2025

• (WIP) KAFKA-18486: Remove ReplicaManager#becomeLeaderOrFollower (2/N)

  #19765 opened May 19, 2025

• KAFKA-19313: Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET

  #19767 opened May 20, 2025

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

  #19773 opened May 20, 2025

• KAFKA-19316: added share_group_command_test.py system tests

  #19774 opened May 20, 2025

• MINOR: Cleanups in Test Common Module

  #19775 opened May 20, 2025

• KAFKA-19239 Rewrite IntegrationTestUtils by java

  #19776 opened May 20, 2025

• KAFKA-19285: Added more tests in SharePartitionManagerTest

  #19778 opened May 21, 2025

• KAFKA-19300: AsyncConsumer#unsubscribe always timeout due to GroupAuthorizationException

  #19779 opened May 21, 2025

• MINOR: Upgrade to Gradle 8.14.1

  #19780 opened May 21, 2025

• KAFKA-19279: Make DefaultMessageFormatter public

  #19785 opened May 22, 2025

• KAFKA-19268 Missing mocks for SharePartitionManagerTest tests

  #19786 opened May 22, 2025

• KAFKA-19317 : Refactor ShareConsumerTest::waitedPoll to work with multiple records.

  #19789 opened May 22, 2025

• KAFKA-18687: Setting the subscriptionMetadata during conversion to consumer group

  #19790 opened May 22, 2025

• MINOR: Cleanup JMH-Benchmarks Module

  #19791 opened May 23, 2025

• KAFKA-19144 Move DelayedProduce to server module

  #19793 opened May 23, 2025

• KAFKA-17747: Replace subscription metadata with metadata hash in share group (wip)

  #19796 opened May 23, 2025

• MINOR: Remove unused mkMapOfPartitionRacks method

  #19797 opened May 23, 2025

• KAFKA-19322: Remove the DelayedOperation constructor that accepts an external lock

  #19798 opened May 23, 2025

• KAFKA-19155: Update security guide with ACLs for stream RPCs

  #19799 opened May 23, 2025

• KAFKA-14145; Faster KRaft HWM replication

  #19800 opened May 23, 2025

• MINOR: Fix initProducerId throttle time to non-zero

  #19801 opened May 23, 2025

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

  #19802 opened May 24, 2025

40 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-19042: [9/N] Move GroupAuthorizerIntegrationTest to clients-integration-tests module

  #19685 commented on May 19, 2025 • 21 new comments

• KAFKA-19080 The constraint on segment.ms is not enforced at topic level

  #19371 commented on May 24, 2025 • 21 new comments

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

  #19742 commented on May 23, 2025 • 13 new comments

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

  #19668 commented on May 22, 2025 • 12 new comments

• KAFKA-19056: Rewrite EndToEndClusterIdTest in Java and move it to the server module

  #19741 commented on May 23, 2025 • 11 new comments

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

  #19699 commented on May 24, 2025 • 10 new comments

• KAFKA-19034: [1/N] Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module

  #19681 commented on May 23, 2025 • 6 new comments

• [KAFKA-18681] Created GetReplicaLogInfo* RPCs

  #19664 commented on May 21, 2025 • 6 new comments

• KAFKA-19284: Add documentation to clarify the behavior of null values for all partitionsToOffsetAndMetadata methods.

  #19728 commented on May 22, 2025 • 5 new comments

• KAFKA-17573: Move KRaftMetadataCache to metadata module

  #19232 commented on May 24, 2025 • 4 new comments

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

  #17340 commented on May 23, 2025 • 3 new comments

• KAFKA-19294: Fix BrokerLifecycleManager RPC timeouts

  #19745 commented on May 21, 2025 • 3 new comments

• KAFKA-19082:[4/4] Complete Txn Client Side Changes (KIP-939)

  #19714 commented on May 19, 2025 • 2 new comments

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

  #19510 commented on May 24, 2025 • 2 new comments

• KAFKA-13555: Use input partitions for StickyTaskAssignor [WIP]

  #19670 commented on May 18, 2025 • 0 new comments

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

  #19656 commented on May 19, 2025 • 0 new comments

• jprnt02

  #19672 commented on May 19, 2025 • 0 new comments

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

  #19692 commented on May 19, 2025 • 0 new comments

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

  #19696 commented on May 19, 2025 • 0 new comments

• MINOR: Improve the `KAFKA_HEAP_OPTS` definition while run `kafka-server-start.bat` Batch

  #19703 commented on May 21, 2025 • 0 new comments

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

  #19720 commented on May 22, 2025 • 0 new comments

• KAFKA-19154; Offset Fetch API should return INVALID_OFFSET if requested topic id does not match persisted one

  #19744 commented on May 17, 2025 • 0 new comments

• [Don't Merge] Test

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

• KAFKA-17411: Use shared cache for Task offset sums

  #17715 commented on May 20, 2025 • 0 new comments

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

  #18216 commented on May 24, 2025 • 0 new comments

• KAFKA-18647: Clarify Windows support in Quick Start Guide

  #18715 commented on May 22, 2025 • 0 new comments

• MINOR: Add Append KRaft Version Record to BatchAccumulator

  #18956 commented on May 23, 2025 • 0 new comments

• KAFKA-17218: let kafka-consumer-groups handle describe groups with deleted topics

  #19029 commented on May 22, 2025 • 0 new comments

• KAFKA-17651: Implement `describeUserScramCredentials`

  #19066 commented on May 23, 2025 • 0 new comments

• KAFKA-18424: Consider splitting PlaintextAdminIntegrationTest#testConsumerGroups

  #19093 commented on May 23, 2025 • 0 new comments

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

  #19231 commented on May 24, 2025 • 0 new comments

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

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

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

  #19400 commented on May 23, 2025 • 0 new comments

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

  #19501 commented on May 23, 2025 • 0 new comments

• WIP: Test against Java 24

  #19514 commented on May 23, 2025 • 0 new comments

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

  #19522 commented on May 20, 2025 • 0 new comments

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

  #19577 commented on May 21, 2025 • 0 new comments

• KAFKA-19221: Propagate IOException on LogSegment#close

  #19607 commented on May 24, 2025 • 0 new comments

• KAFKA-19244: Add support for kafka-streams-groups.sh options (delete group, offset-related APIs) [1/N]

  #19646 commented on May 19, 2025 • 0 new comments

• KAFKA-19042: [8/N] Move BaseConsumerTest, SaslPlainPlaintextConsumerTest to client-integration-tests module

  #19651 commented on May 23, 2025 • 0 new comments