63 Pull requests merged by 30 people

• MINOR: add docs for "org.apache.kafka.sasl.oauthbearer.allowed.urls" in v3.8

  #18941 merged Feb 18, 2025

• MINOR: add docs for "org.apache.kafka.sasl.oauthbearer.allowed.urls" in v3.9

  #18940 merged Feb 18, 2025

• MINOR: Align share group admin authz with consumer group

  #18936 merged Feb 18, 2025

• MINOR: add docs for "org.apache.kafka.sasl.oauthbearer.allowed.urls"

  #18938 merged Feb 18, 2025

• KAFKA-18798: The replica placement policy used by ReassignPartitionsCommand is not aligned with kraft controller

  #18914 merged Feb 18, 2025

• KAFKA-18787: RemoteIndexCache fails to delete invalid files on init

  #18888 merged Feb 18, 2025

• KAFKA-18807; Fix thread idle ratio metric

  #18934 merged Feb 18, 2025

• MINOR: Remove dropwizard metrics from dependencies.gradle

  #18932 merged Feb 18, 2025

• HOTFIX: StoreChangelogReader should require stable consumer group

  #18901 merged Feb 17, 2025

• KAFKA-18684: Add base exception classes

  #18871 merged Feb 17, 2025

• KAFKA-18733: Updating share group record acks metric (2/N)

  #18924 merged Feb 17, 2025

• KAFKA-18801 Remove ClusterGenerator and revise docs of ClusterTemplate

  #18907 merged Feb 17, 2025

• KAFKA-18730: Add replaying streams group state from offset topic

  #18809 merged Feb 17, 2025

• KAFKA-18784: Fix ConsumerWithLegacyMessageFormatIntegrationTest

  #18889 merged Feb 17, 2025

• Mark testQuotaOverrideDelete as flaky

  #18925 merged Feb 17, 2025

• KAFKA-18805: Consumer Heartbeat closed change should be locked

  #18920 merged Feb 17, 2025

• KAFKA-18755 Align timeout in kafka-share-groups.sh

  #18908 merged Feb 16, 2025

• MINOR: Remove unused member in DynamicBrokerConfig

  #18915 merged Feb 16, 2025

• KAFKA-18809: Set min in sync replicas for __share_group_state.

  #18922 merged Feb 16, 2025

• KAFKA-18803: The acls would appear at the wrong level of the metadata shell "tree"

  #18916 merged Feb 16, 2025

• MINOR Don't discard thread dumps

  #18909 merged Feb 15, 2025

• MINOR: cleanup top level class JavaDocs for main interfaces of Kafka Streams DSL (2/N)

  #18882 merged Feb 14, 2025

• MINOR: cleanup top level class JavaDocs for main interfaces of Kafka Streams DSL (1/N)

  #18881 merged Feb 14, 2025

• KAFKA-18790: Fix testCustomQuotaCallback

  #18906 merged Feb 14, 2025

• KAFKA-18761: Complete listing of share group offsets [1/N]

  #18894 merged Feb 14, 2025

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

  #18819 merged Feb 14, 2025

• MINOR: Add release notes for Transactions Server Side Defense (KIP-890)

  #18896 merged Feb 14, 2025

• MINOR: TransactionManager logs the epoch bump less frequently.

  #18895 merged Feb 14, 2025

• MINOR: Mark IBP_4_0_IV3 as production ready!

  #18902 merged Feb 14, 2025

• MINOR: Add KIP-848's metric to the doc

  #18890 merged Feb 14, 2025

• KAFKA-18772 Define share group config defaults for Docker

  #18899 merged Feb 14, 2025

• KAFKA-18733: Updating share group metrics (1/N)

  #18826 merged Feb 14, 2025

• KAFKA-18634: Fix ELR metadata version issues

  #18680 merged Feb 14, 2025

• KAFKA-18298;KAFKA-18297: Fix flaky testConsumerGroupsDeprecatedConsumerGroupState and testConsumerGroups in PlaintextAdminIntegrationTest

  #18513 merged Feb 13, 2025

• MINOR: Marking testVerifyFetchAndCloseImplicit flaky

  #18893 merged Feb 13, 2025

• MINOR: Adjust javadoc to reflect the correct status of standby task

  #18892 merged Feb 13, 2025

• KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer

  #18795 merged Feb 13, 2025

• KAFKA-16720: Support multiple groups in DescribeShareGroupOffsets RPC

  #18834 merged Feb 13, 2025

• KAFKA-18654[2/2]: Transction V2 retry add partitions on the server side when handling produce request.

  #18810 merged Feb 13, 2025

• MINOR: fix warn log message in Kafka Streams

  #18878 merged Feb 13, 2025

• KAFKA-18776: Fix flaky coordinator disconnect test & fix log level

  #18866 merged Feb 13, 2025

• KAFKA-17298: Update upgrade notes for 4.0 KIP-848

  #18756 merged Feb 13, 2025

• MINOR Bump setup-gradle version

  #18879 merged Feb 13, 2025

• MINOR: check javadoc while build phase

  #18863 merged Feb 13, 2025

• MINOR: Updated share partition manager tests to close and other fixes

  #18862 merged Feb 13, 2025

• MINOR: Fix typo in ClusterControlManager

  #18886 merged Feb 13, 2025

• KAFKA-18728 Move ListOffsetsPartitionStatus to server module

  #18807 merged Feb 13, 2025

• MINOR: cleanup KStream JavaDocs (14/N) - stream-globalTable-left-join

  #18867 merged Feb 12, 2025

• MINOR: cleanup KStream JavaDocs (13/N) - stream-stream-outer-join

  #18865 merged Feb 12, 2025

• KAFKA-18769: Improve leadership changes handling in ShareConsumeRequestManager.

  #18851 merged Feb 12, 2025

• KAFKA-18777: add PartitionsWithLateTransactionsCount to BrokerMetricNamesTest

  #18869 merged Feb 12, 2025

• KAFKA-18323: Add StreamsGroup class

  #18729 merged Feb 12, 2025

• KAFKA-18771: fix Flaky test KRaftClusterTest .testDescribeQuorumRequestToControllers

  #18859 merged Feb 12, 2025

• KAFKA-18035: TransactionsTest testBumpTransactionalEpochWithTV2Disabled failed on trunk

  #18451 merged Feb 11, 2025

• MINOR: cleanup KStream JavaDocs (12/N) - process[Values]

  #18839 merged Feb 11, 2025

• MINOR: cleanup KStream JavaDocs (11/N) - stream-stream-left-join

  #18836 merged Feb 11, 2025

• KAFKA-15995: Adding KIP-877 support to Connect

  #17804 merged Feb 11, 2025

• KAFKA-18756: Enabled share group configs for queues related system tests

  #18829 merged Feb 11, 2025

• Refactor heartbeat response to include standbys

  #18827 merged Feb 11, 2025

• MINOR: Fix bug in json naming in ShareConsumeBenchSpec

  #18858 merged Feb 11, 2025

• MINOR: Fix reassign partitions system test

  #18860 merged Feb 11, 2025

• MINOR: Fix log compaction system test

  #18857 merged Feb 11, 2025

• KAFKA-18758: NullPointerException in shutdown following InvalidConfigurationException

  #18833 merged Feb 11, 2025

34 Pull requests opened by 26 people

• KAFKA-18606: Flaky test DeleteSegmentsByRetentionTimeTest#executeTieredStorageTest

  #18861 opened Feb 11, 2025

• KAFKA-18757: Create full-function SimpleAssignor to match KIP-932 description

  #18864 opened Feb 11, 2025

• KAFKA-18736: Add Streams group heartbeat request manager (1/N)

  #18870 opened Feb 12, 2025

• KAFKA-18773: Migrate the log4j1 config to log4j 2 for native image and README (wip)

  #18872 opened Feb 12, 2025

• [MINOR] Update to min.isr documentation

  #18874 opened Feb 12, 2025

• DRAFT Standardize PR format

  #18875 opened Feb 12, 2025

• MINOR: disallow rawtypes and fail build

  #18877 opened Feb 12, 2025

• KAFKA-15583: doc update for the "strict min ISR" rule

  #18880 opened Feb 13, 2025

• MINOR: cleanup top level class JavaDocs for main interfaces of Kafka Streams DSL (3/N)

  #18883 opened Feb 13, 2025

• MINOR: cleanup top level class JavaDocs for main interfaces of Kafka Streams DSL (4/N)

  #18884 opened Feb 13, 2025

• KAFKA-16653: Remove delayed initialization because of static voter set

  #18885 opened Feb 13, 2025

• [KAFKA-18713] Fix left join bug by using DELETE_KEY_NO_PROPAGATE

  #18887 opened Feb 13, 2025

• KAFKA-16918: TestUtils#assertFutureThrows should use future.get with timeout

  #18891 opened Feb 13, 2025

• KAFKA-18795: Remove `Records#downConvert`

  #18897 opened Feb 14, 2025

• KIP-966 part 1 release doc

  #18898 opened Feb 14, 2025

• KAFKA-17937: Use ValueSource to refactor AbstractFetcherThreadTest

  #18900 opened Feb 14, 2025

• KAFKA-1792 [WIP]: change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments

  #18903 opened Feb 14, 2025

• KAFKA-18740: Remove BootstrapDirectory#ibp

  #18905 opened Feb 14, 2025

• KAFKA-17125 Add integration test for StreamsGroup in Admin API

  #18911 opened Feb 15, 2025

• [WIP] JWT bearer grant type support

  #18912 opened Feb 15, 2025

• MINOR: TopicIdPartition Records Benchmark

  #18917 opened Feb 15, 2025

• KAFKA-18804: Remove slf4j warning when using tool script

  #18918 opened Feb 16, 2025

• [WIP] KAFKA-18562: standardize election/fetch timeout between Unattached and Followers

  #18921 opened Feb 16, 2025

• MINOR: deflake EligibleLeaderReplicasIntegrationTest

  #18923 opened Feb 16, 2025

• KAFKA-18332: fix ClassDataAbstractionCoupling problem in KafkaRaftClientTest(1/2)

  #18926 opened Feb 17, 2025

• KAFKA-16718 [1/n]: Added DeleteShareGroupOffsets request and response schema

  #18927 opened Feb 17, 2025

• KAFKA-18629: ShareGroupDeleteState admin client impl.

  #18928 opened Feb 17, 2025

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

  #18929 opened Feb 17, 2025

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

  #18930 opened Feb 17, 2025

• MINOR: Add verify_license tool

  #18931 opened Feb 17, 2025

• MINOR: Rename NoOpShareStatePersister for consistency

  #18933 opened Feb 17, 2025

• KAFKA-18816: Add KIP-877 support to KafkaPrincipalBuilder

  #18935 opened Feb 17, 2025

• MINOR: Cleanup metadata module

  #18937 opened Feb 17, 2025

• KAFKA-18779: Validate responses from broker in client for ShareFetch and ShareAcknowledge RPCs.

  #18939 opened Feb 18, 2025

57 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-18641: AsyncKafkaConsumer could lose records with auto offset commit

  #18737 commented on Feb 18, 2025 • 84 new comments

• KAFKA-18601: Assume a baseline of 3.3 for server protocol versions

  #18845 commented on Feb 17, 2025 • 60 new comments

• KAFKA-18629: Delete share group state RPC group coordinator impl. [3/N]

  #18848 commented on Feb 18, 2025 • 40 new comments

• MINOR: Align assertFutureThrows method signature with JUnit conventions

  #18825 commented on Feb 18, 2025 • 17 new comments

• KAFKA-18023: Enforcing Explicit Naming for Kafka Streams Internal Topics

  #18233 commented on Feb 17, 2025 • 15 new comments

• KAFKA-18089: RemoteIndexCacheTest fails with caffeine > 3.1.1

  #18004 commented on Feb 18, 2025 • 13 new comments

• KAFKA-18767: Add client side config check for shareConsumer

  #18850 commented on Feb 18, 2025 • 12 new comments

• KAFKA-18723; Better handle invalid records during replication

  #18852 commented on Feb 18, 2025 • 11 new comments

• KAFKA-14484: Decouple UnifiedLog and RemoteLogManager

  #18460 commented on Feb 18, 2025 • 9 new comments

• Add integration test for IQv2 in KIP-1071

  #18856 commented on Feb 17, 2025 • 8 new comments

• MINOR: fix Kafka Streams "smoke test" pass criteria

  #18835 commented on Feb 14, 2025 • 7 new comments

• KAFKA-18737: KafkaDockerWrapper setup functions fails due to storage format command

  #18844 commented on Feb 18, 2025 • 4 new comments

• KAFKA-18627:add allowed modules to JaasUtils

  #18683 commented on Feb 18, 2025 • 1 new comment

• KIP-909 / KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable

  #16629 commented on Feb 12, 2025 • 0 new comments

• KAFKA-18576: Convert ConfigType to Enum

  #18711 commented on Feb 18, 2025 • 0 new comments

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

  #18715 commented on Feb 18, 2025 • 0 new comments

• KAFKA-18168: Adding checkpointing for GlobalKTable during restoration…

  #18752 commented on Feb 13, 2025 • 0 new comments

• KAFKA-18489 - Fix Connector tasks metrics task-startup-attempts, task…

  #18762 commented on Feb 13, 2025 • 0 new comments

• KAFKA-18748 Run new tests separately in PRs

  #18770 commented on Feb 15, 2025 • 0 new comments

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

  #18789 commented on Feb 18, 2025 • 0 new comments

• Fix an incorrect assignment in StreamsUncaughtExceptionHandlerIntegrationTest

  #18837 commented on Feb 15, 2025 • 0 new comments

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

  #18800 commented on Feb 17, 2025 • 0 new comments

• KAFKA-17565: Move MetadataCache interface to metadata module

  #18801 commented on Feb 14, 2025 • 0 new comments

• KAFKA-18706: Move AclPublisher to metadata module

  #18802 commented on Feb 12, 2025 • 0 new comments

• KAFKA-18712: Move Endpoint to server module

  #18803 commented on Feb 17, 2025 • 0 new comments

• KAFKA-18522: Slice records for share fetch

  #18804 commented on Feb 14, 2025 • 0 new comments

• Return friendly prompt when no quota configs found

  #18808 commented on Feb 13, 2025 • 0 new comments

• [WIP] KAFKA-10844: groupBy without shuffling

  #18811 commented on Feb 18, 2025 • 0 new comments

• KAFKA-10789: Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest

  #18816 commented on Feb 18, 2025 • 0 new comments

• MINOR: use placeholders to replace string concatenation in Metrics log

  #18831 commented on Feb 13, 2025 • 0 new comments

• KAFKA-18754: Allow `PlainSaslServer` to pass client info through the negotiated properties.

  #18828 commented on Feb 18, 2025 • 0 new comments

• KAFKA-16907: Fix RaftUtil's type complexity

  #16831 commented on Feb 17, 2025 • 0 new comments

• KAFKA-17727: swallow exceptions on segment flush

  #17425 commented on Feb 16, 2025 • 0 new comments

• KAFKA-17755 AbstractPartitionAssignor can not enable RackAwareAssignm…

  #17571 commented on Feb 15, 2025 • 0 new comments

• KAFKA-16966:Allow offset commit fetch to reuse previous request if partitions are a subset

  #17584 commented on Feb 15, 2025 • 0 new comments

• KAFKA-16758: Extend Consumer#close with an option to leave the group or not

  #17614 commented on Feb 17, 2025 • 0 new comments

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

  #17715 commented on Feb 13, 2025 • 0 new comments

• [WIP] KIP-891: Connect Multiversion Support (Versioned Connector Creation and related changes)

  #17743 commented on Feb 14, 2025 • 0 new comments

• MINOR: Optimize the 'waitForVerifyAssignment' method log output

  #17753 commented on Feb 18, 2025 • 0 new comments

• KAFKA-17900:Consider async resolution for client-side regex in new consumer

  #17769 commented on Feb 18, 2025 • 0 new comments

• Add Kraft migration revert cleanup steps

  #17792 commented on Feb 12, 2025 • 0 new comments

• Kip 909 2

  #17808 commented on Feb 13, 2025 • 0 new comments

• MINOR: Documentation improvements for dynamic quorums

  #17810 commented on Feb 16, 2025 • 0 new comments

• KAFKA-17993: reassign partition tool stuck with uncaught exception: '…

  #17816 commented on Feb 13, 2025 • 0 new comments

• Update streams compat table 3.8

  #17850 commented on Feb 17, 2025 • 0 new comments

• KAFKA-18142 switch Kafka's Gradle build shadow plugin to `com.gradleup.shadow` (and upgrade plugin version)

  #18018 commented on Feb 15, 2025 • 0 new comments

• KAFKA-18157:Consider UnsupportedVersionException child class to represent the case of unsupported fields

  #18072 commented on Feb 17, 2025 • 0 new comments

• KAFKA-18074: Add kafka client compatibility matrix

  #18091 commented on Feb 14, 2025 • 0 new comments

• KAFKA-18209 Cleanup `__transaction_state` config logic

  #18201 commented on Feb 12, 2025 • 0 new comments

• KAFKA-16260: Deprecate window.size.ms and window.inner.class.serde in StreamsConfig

  #18297 commented on Feb 12, 2025 • 0 new comments

• KAFKA-17607: Add CI step to verify LICENSE-binary

  #18299 commented on Feb 14, 2025 • 0 new comments

• KAFKA-18281: Kafka (3.9.0) is improperly validating non-advertised listeners for routable controller addresses

  #18387 commented on Feb 18, 2025 • 0 new comments

• KAFKA-17171: Add test cases for `STATIC_BROKER_CONFIG`in kraft mode

  #18463 commented on Feb 13, 2025 • 0 new comments

• KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol

  #18600 commented on Feb 17, 2025 • 0 new comments

• KAFKA 10409: Refactor Kakfa Streams RocksDB Iterators

  #18610 commented on Feb 18, 2025 • 0 new comments

• KAFKA-18310: Flaky AbstractCoordinatorTest

  #18665 commented on Feb 15, 2025 • 0 new comments

• KAFKA-18461: Fix potential NPE in setDelta after map is erased

  #18684 commented on Feb 18, 2025 • 0 new comments