53 Pull requests merged by 28 people

• 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

• KAFKA-19355: Remove interBrokerListenerName from ClusterControlManager

  #19866 merged Jun 1, 2025

• KAFKA-19352: Create offsets topic to fix flaky testCommitAsyncCompletedBeforeConsumerCloses

  #19873 merged Jun 1, 2025

• KAFKA-19053: Remove FetchResponse#of which is not used in production …

  #19327 merged Jun 1, 2025

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

  #19728 merged May 31, 2025

• KAFKA-19311: Document commitAsync behavioral differences between Classic and Async Consumer

  #19864 merged May 31, 2025

• KAFKA-19042: [9/N] Move GroupAuthorizerIntegrationTest to clients-integration-tests module

  #19685 merged May 30, 2025

• MINOR: Minor updates to RangeSet

  #19678 merged May 30, 2025

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

  #19651 merged May 30, 2025

• MINOR: Add missing tag to testShareGroups test

  #19860 merged May 30, 2025

• KAFKA-19346: Move LogReadResult to server module

  #19846 merged May 30, 2025

• KAFKA-19351: AsyncConsumer#commitAsync should copy the input offsets

  #19855 merged May 30, 2025

• KAFKA-19042: [11/N] move ConsumerWithLegacyMessageFormatIntegrationTest to clients-integration-tests module

  #19810 merged May 29, 2025

• KAFKA-18904: kafka-configs.sh return resource doesn't exist message [3/N]

  #19808 merged May 29, 2025

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

  #19714 merged May 29, 2025

• KAFKA-6629: parameterise SegmentedCacheFunctionTest for session key schemas

  #19404 merged May 29, 2025

• KAFKA-19337: Write state writes snapshot for higher state epoch.

  #19843 merged May 29, 2025

• MINOR: Removed stale comment

  #19848 merged May 29, 2025

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

  #19741 merged May 29, 2025

• KAFKA-19316: added share_group_command_test.py system tests

  #19774 merged May 29, 2025

• MINOR: removed test cases with combined_kraft mode in share_consumer_test.py

  #19841 merged May 29, 2025

34 Pull requests opened by 24 people

• KAFKA-19305 Ensure all image classes are immutable

  #19847 opened May 29, 2025

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

  #19850 opened May 29, 2025

• MINOR: Cleanup KafkaApisTest `asJava` conversions

  #19851 opened May 29, 2025

• MINOR: Cleanup ShareFetchAcknowledgeRequestTest

  #19852 opened May 29, 2025

• MINOR: Remove unused code from storage classes

  #19853 opened May 29, 2025

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

  #19854 opened May 30, 2025

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

  #19857 opened May 30, 2025

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

  #19858 opened May 30, 2025

• KAFKA-19325 improve forceComplete() in DelayedOperation

  #19862 opened May 30, 2025

• MINOR: Refactor createResponseConfig to avoid collection copy and conversion

  #19867 opened May 30, 2025

• MINOR: Cleanup Connect Module (1/n)

  #19869 opened May 31, 2025

• KAFKA-19010: Added JVM argument to default configuration

  #19870 opened May 31, 2025

• MINOR: Cleanup Connect Module (2/n)

  #19871 opened May 31, 2025

• KAFKA-18995: Add bidirectional replication check

  #19874 opened Jun 1, 2025

• MINOR: Rename ambiguous method name

  #19875 opened Jun 1, 2025

• KAFKA-19340: Move DelayedRemoteFetch to the storage module

  #19876 opened Jun 2, 2025

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

  #19879 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-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds

  #19883 opened Jun 3, 2025

• KAFKA-19324: org.apache.kafka.common.test.TestUtils should be package-private

  #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

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

  #19888 opened Jun 3, 2025

• KAFKA-18913: State Updater thread not shutting down during teardown i…

  #19889 opened Jun 3, 2025

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

  #19890 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-19369: Add group.share.assignors config and integration test

  #19900 opened Jun 4, 2025

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

  #19902 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

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-19255: KRaft request manager should support one in-flight request per request type

  #19668 commented on Jun 3, 2025 • 28 new comments

• KAFKA-18681 Created GetReplicaLogInfo* RPCs

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

• KAFKA-19315: Move ControllerMutationQuotaManager to server module

  #19807 commented on Jun 3, 2025 • 14 new comments

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

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

• KAFKA-19239 Rewrite IntegrationTestUtils by java

  #19776 commented on Jun 3, 2025 • 9 new comments

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

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

• KAFKA-19221: Propagate IOException on LogSegment#close

  #19607 commented on Jun 2, 2025 • 8 new comments

• KAFKA-15599: Move KafkaMetadataLog to the raft module

  #19762 commented on May 29, 2025 • 7 new comments

• KAFKA-14145; Faster KRaft HWM replication

  #19800 commented on Jun 4, 2025 • 6 new comments

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

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

• KAFKA-14830: Illegal state error in transactional producer

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

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

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

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

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

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

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

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

  #19751 commented on May 29, 2025 • 2 new comments

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

  #19805 commented on May 30, 2025 • 1 new comment

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

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

• MINOR: Follow up KAFKA-19080 MetadataLogConfig

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

• MINOR: Fix typo to actually use rocksdb setOptimizeFiltersForHits

  #19837 commented on May 30, 2025 • 0 new comments

• MINOR: clean KafkaConsumer tests

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

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

  #19699 commented on Jun 2, 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-19042: [12/N] Move PlaintextConsumerSubscriptionTest to client-integration-tests module

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

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

  #19773 commented on Jun 1, 2025 • 0 new comments

• (wip )KAFKA-19042 consumer bounce test

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

• KAFKA-19279: Make DefaultMessageFormatter public

  #19785 commented on May 30, 2025 • 0 new comments

• MINOR: Cleanup JMH-Benchmarks Module

  #19791 commented on May 31, 2025 • 0 new comments

• KAFKA-19144 Move DelayedProduce to server module

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

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

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

• KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo

  #19803 commented on May 30, 2025 • 0 new comments

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

  #19804 commented on May 30, 2025 • 0 new comments

• [WIP] KAFKA-19167: Move RemoteLogManagerConfig out of KafkaConfig

  #19806 commented on Jun 1, 2025 • 0 new comments

• Update README.md

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

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

  #19814 commented on May 31, 2025 • 0 new comments

• MINOR: Make InternalStreamsBuilder#addGraphNode public

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

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

  #15913 commented on Jun 4, 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

• 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-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

• MINOR: Remove zk from replica_verification_test

  #19015 commented on May 31, 2025 • 0 new comments

• KAFKA-18854:Move DynamicConfig to server module

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

• MINOR: Remove unused system test code and avoid misleading `quorum.zk` references

  #19034 commented on May 31, 2025 • 0 new comments

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

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

• Clarification of topic configuration 'retention.bytes'

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

• KAFKA-17651: Implement `describeUserScramCredentials`

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

• KAFKA-17573: Move KRaftMetadataCache to metadata module

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

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

  #19236 commented on Jun 5, 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-15873: Filter topics before sorting

  #19304 commented on May 31, 2025 • 0 new comments

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

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

• KAFKA-18066: Fix mismatched StreamThread ID in log messages

  #19517 commented on Jun 1, 2025 • 0 new comments

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

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

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

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

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

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