69 Pull requests merged by 29 people

• KAFKA-18795: Remove Records#downConvert

  #18897 merged Feb 21, 2025

• KAFKA-18813: [3/N] Client support for TopicAuthException in DescribeConsumerGroup path

  #18996 merged Feb 21, 2025

• KAFKA-18733: Implemented fetch ratio and partition acquire time metrics (3/N)

  #18959 merged Feb 21, 2025

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

  #18911 merged Feb 21, 2025

• MINOR: Move the ELR default version to 4.1

  #18954 merged Feb 21, 2025

• KAFKA-18033: Remove flaky tag in ShareConsumerTest

  #18995 merged Feb 21, 2025

• KAFKA-18813: [2/N] Client support for TopicAuthException in HB path

  #18986 merged Feb 21, 2025

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

  #18844 merged Feb 21, 2025

• MINOR: Rearrange configs in GroupCoordinatorConfigs

  #18970 merged Feb 21, 2025

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

  #18848 merged Feb 21, 2025

• KAFKA-18829: Added check before converting to IMPLICIT mode (#18964) (Cherry-pick)

  #18982 merged Feb 21, 2025

• KAFKA-18831: Migrating to log4j2 introduce behavior changes of adjusting level dynamically

  #18969 merged Feb 21, 2025

• MINOR: cleanup SinkNode generics

  #18975 merged Feb 21, 2025

• KAFKA-18641: AsyncKafkaConsumer could lose records with auto offset commit

  #18737 merged Feb 20, 2025

• MINOR: deflake EligibleLeaderReplicasIntegrationTest

  #18923 merged Feb 20, 2025

• KAFKA-18828: Update share group metrics per new init and call mechanism.

  #18962 merged Feb 20, 2025

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

  #18891 merged Feb 19, 2025

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

  #18835 merged Feb 19, 2025

• MINOR: disallow rawtypes and fail build

  #18877 merged Feb 19, 2025

• MIINOR: Remove redundant quorum parameter from *AdminIntegrationTest classes

  #18965 merged Feb 19, 2025

• KAFKA-18791 Set default commit to PR title and description [2/n]

  #18967 merged Feb 19, 2025

• MINOR: Fix incorrect return value from upgradeFeatures

  #18958 merged Feb 19, 2025

• KAFKA-18829: Added check before converting to IMPLICIT mode

  #18964 merged Feb 19, 2025

• MINOR: Update upgrade notes for 4.0.0

  #18960 merged Feb 19, 2025

• Add TransactionAbortableException and Timeout Exception handling instruction in docs

  #18942 merged Feb 19, 2025

• KAFKA-18791 Enable new asf.yaml parser [1/N]

  #18955 merged Feb 19, 2025

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

  #18845 merged Feb 19, 2025

• KAFKA-18198: Added check to prevent acknowledgements on initial ShareFetchRequest.

  #18944 merged Feb 19, 2025

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

  #18884 merged Feb 19, 2025

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

  #18883 merged Feb 19, 2025

• MINOR: verify that internal StreamsConfig members are not public

  #18840 merged Feb 19, 2025

• KAFKA-18799: Remove AdminUtils

  #18946 merged Feb 18, 2025

• MINOR: Tweak default group coordinator config & upgrade notes

  #18948 merged Feb 18, 2025

• KAFKA-18667: Add ducktape tests for simultaneous broker + controller failure

  #18757 merged Feb 18, 2025

• MINOR: Fix the missing and updated licenses

  #18950 merged Feb 18, 2025

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

  #18872 merged Feb 18, 2025

• Add integration test for IQv2 in KIP-1071

  #18856 merged Feb 18, 2025

• KAFKA-18089: RemoteIndexCacheTest fails with caffeine > 3.1.1

  #18004 merged Feb 18, 2025

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

  #18850 merged Feb 18, 2025

• MINOR: Align assertFutureThrows method signature with JUnit conventions

  #18825 merged Feb 18, 2025

• KAFKA-14484: Decouple UnifiedLog and RemoteLogManager

  #18460 merged Feb 18, 2025

• MINOR: Rename NoOpShareStatePersister for consistency

  #18933 merged Feb 18, 2025

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

  #18927 merged Feb 18, 2025

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

  #18870 merged Feb 18, 2025

• MINOR: Update LICENSE-binary

  #18943 merged Feb 18, 2025

• MINOR: Add verify_license tool

  #18931 merged Feb 18, 2025

• 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

41 Pull requests opened by 32 people

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

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

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

• 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

• KAFKA-15900, KAFKA-18310: fix flaky test testOutdatedCoordinatorAssignment and AbstractCoordinatorTest

  #18945 opened Feb 18, 2025

• [WIP] MINOR: Enable auth test for new consumer

  #18947 opened Feb 18, 2025

• KAFKA-17431: Support invalid static configs for KRaft so long as dynamic configs are valid

  #18949 opened Feb 18, 2025

• KAFKA-4650: Add unit tests for GraphNode class

  #18951 opened Feb 18, 2025

• MINOR: update truncation test

  #18952 opened Feb 18, 2025

• KAFKA-18826: Add global thread metrics

  #18953 opened Feb 18, 2025

• MINOR: Add Append KRaft Version Record to BatchAccumulator

  #18956 opened Feb 18, 2025

• MINOR: Fix Some Exceptions in MetaPropertiesEnsemble and MetadataQuorumCommand

  #18957 opened Feb 18, 2025

• MINOR: Add a separate page for zk2kraft.html

  #18961 opened Feb 19, 2025

• [WIP] MINOR: Forbid unused locals

  #18963 opened Feb 19, 2025

• KAFKA-18808: add test to ensure the name=<default> is not equal to default quota

  #18966 opened Feb 19, 2025

• KAFKA-18827: Initialize share state, share coordinator impl. [1/N]

  #18968 opened Feb 19, 2025

• KAFKA-18834 Fix LoggingResourceTest#testSetLevelDefaultScope

  #18972 opened Feb 19, 2025

• KAFKA-16718-2/n: KafkaAdminClient and GroupCoordinator implementation for DeleteShareGroupOffsets RPC

  #18976 opened Feb 20, 2025

• KAFKA-18836 Make ConsumerGroupMetadata an interface

  #18977 opened Feb 20, 2025

• KAFKA-17351: Update tests and acquire API to allow discard batches from compacted topics (1/N)

  #18978 opened Feb 20, 2025

• KAFKA-18614, KAFKA-18613: Add streams group request plumbing

  #18979 opened Feb 20, 2025

• KAFKA-18613: Auto-creation of internal topics in streams group heartbeat

  #18981 opened Feb 20, 2025

• KAFKA-14121: AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor

  #18983 opened Feb 20, 2025

• KAFKA-18792 Add workflow to check PR format

  #18985 opened Feb 20, 2025

• KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests pt 1

  #18987 opened Feb 20, 2025

• KAFKA-18839: Drop EAGER rebalancing support in Kafka Streams

  #18988 opened Feb 21, 2025

• KAFKA-18813: [1/N] ConsumerGroupHeartbeat API and ConsumerGroupDescribe API must check topic describe

  #18989 opened Feb 21, 2025

• MINOR: Don't allow cloning a ProducerStateEntry with a different producer id

  #18990 opened Feb 21, 2025

• MINOR: Specify ArrayDeque init size to NUM_BATCHES_TO_RETAIN in ProducerStateEntry

  #18991 opened Feb 21, 2025

• KAFKA-18827: Initialize share group state persister impl [2/N].

  #18992 opened Feb 21, 2025

• KAFKA-18842: add configurable max number of connectors

  #18993 opened Feb 21, 2025

• KAFKA-18843: Fix MirrorMaker2 workerId is not unique, but use the sam…

  #18994 opened Feb 21, 2025

• KAFKA-18844: Fix flaky QuorumControllerTest.testBalancePartitionLeaders()

  #18997 opened Feb 21, 2025

• KAFKA-18837: Validate controller.quorum.fetch.timeout.ms is a positive value

  #18998 opened Feb 21, 2025

60 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-18723; Better handle invalid records during replication

  #18852 commented on Feb 21, 2025 • 44 new comments

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

  #18864 commented on Feb 21, 2025 • 30 new comments

• KAFKA-17565: Move MetadataCache interface to metadata module

  #18801 commented on Feb 21, 2025 • 9 new comments

• KAFKA-18748 Run new tests separately in PRs

  #18770 commented on Feb 21, 2025 • 7 new comments

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

  #18233 commented on Feb 21, 2025 • 5 new comments

• KAFKA-10409: Refactor Kakfa Streams RocksDB Iterators

  #18610 commented on Feb 19, 2025 • 5 new comments

• KAFKA-18522: Slice records for share fetch

  #18804 commented on Feb 21, 2025 • 4 new comments

• KAFKA-18572: Update Kafka Streams metric documenation

  #18673 commented on Feb 20, 2025 • 2 new comments

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

  #18387 commented on Feb 21, 2025 • 1 new comment

• KAFKA-18627:add allowed modules to JaasUtils

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

• KIP-966 part 1 release doc

  #18898 commented on Feb 20, 2025 • 1 new comment

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

  #18097 commented on Feb 21, 2025 • 1 new comment

• KAFKA-18310: Flaky AbstractCoordinatorTest

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

• KAFKA-18617 Allow use of ClusterInstance inside BeforeEach

  #18662 commented on Feb 20, 2025 • 0 new comments

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

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

• KAFKA-18576: Convert ConfigType to Enum

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

• MINOR: Fix the CLIENT_QUOTA_CALLBACK_CLASS_CONFIG document

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

• KAFKA-18600 Cleanup NetworkClient zk related logging

  #18644 commented on Feb 21, 2025 • 0 new comments

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

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

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

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

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

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

• KAFKA-18706: Move AclPublisher to metadata module

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

• KAFKA-18712: Move Endpoint to server module

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

• [WIP] KAFKA-10844: groupBy without shuffling

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

• KAFKA-10789: Streamlining Tests in ChangeLoggingKeyValueBytesStoreTest

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

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

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

• Fix an incorrect assignment in StreamsUncaughtExceptionHandlerIntegrationTest

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

• KAFKA-18606: Flaky test DeleteSegmentsByRetentionTimeTest#executeTieredStorageTest

  #18861 commented on Feb 21, 2025 • 0 new comments

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

  #18880 commented on Feb 20, 2025 • 0 new comments

• KAFKA-18713: Fix left join bug by using DELETE_KEY_NO_PROPAGATE

  #18887 commented on Feb 20, 2025 • 0 new comments

• KAFKA-17937: Use ValueSource to refactor AbstractFetcherThreadTest

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

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

  #18903 commented on Feb 20, 2025 • 0 new comments

• MINOR: call the serialize method including headers from the MockProducer

  #11144 commented on Feb 21, 2025 • 0 new comments

• KAFKA-16394: Fix null propagation in foreign key join result

  #15607 commented on Feb 20, 2025 • 0 new comments

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

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

• KAFKA-16907: Fix RaftUtil's type complexity

  #16831 commented on Feb 21, 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 21, 2025 • 0 new comments

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

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

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

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

• MINOR: Optimize the 'waitForVerifyAssignment' method log output

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

• KAFKA-17856 Move ConfigCommandTest and ConfigCommandIntegrationTest to tool module

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

• KAFKA-17981:add Integration test for ConfigCommand to add config `key=[val1,val2]`

  #17771 commented on Feb 21, 2025 • 0 new comments

• MINOR: Documentation improvements for dynamic quorums

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

• [DO NOT MERGE] convert aggregate API to ProcessorSupplier#stores method

  #17833 commented on Feb 20, 2025 • 0 new comments

• Update streams compat table 3.8

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

• [DO NOT MERGE] introduce FactoryWrappingStoreBuilder

  #17891 commented on Feb 20, 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 20, 2025 • 0 new comments

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

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

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

  #18216 commented on Feb 21, 2025 • 0 new comments

• KAFKA-18915: Enter incompatible instead of leaving incompatible entires blank in Kafka Streams broker compatibility matrix

  #18258 commented on Feb 21, 2025 • 0 new comments

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

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

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

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

• Feature/arch analysis

  #18356 commented on Feb 21, 2025 • 0 new comments

• KAFKA-17544: Fix for loading big files while performing load tests

  #18391 commented on Feb 19, 2025 • 0 new comments

• KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread

  #18489 commented on Feb 21, 2025 • 0 new comments

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

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