Confluent Platform Component Changelogs¶

This topic provides changelogs for the individual Confluent Platform components.

Version 8.0.0¶

Released June 2025

Community Features¶

Common¶

69b3be7d - update logredactor for the log4j2 migration
44f2c2e4 - update jmx
c2dff5eb - remove zookeeper license / notice
33dd8114 - Update AWS SDK V2 to 2.29.39 for 8.0.x
5d925b59 - Update AWS SDK V2 to 2.27.9 for 7.9.x
PR-778 - Add property for AWS SDK v2
PR-777 - Use JDK 11 for client compatibilty
PR-776 - Emit Java 11 binaries while using JDK 17
4628a392 - fix of conflict merge resolution
467efd8f - fix missing version definition
cbc66130 - add commons-compress to unify versions with ce-kafka
0a1d3244 - update aws sdk to match ce-kafka
ae6ef1e3 - udpate amazonSdkVersion to match ce-kafka
PR-770 - Add slf4j-log4j binding dependency
61775ea0 - update jakarta to latest
b1cc00ad - Pin jakarta versions to support Jetty 12 migration
54d73bbe - update azure dependendecies to versions defined in azure-bom 1.2.32
60322b85 - upgrade jetty to major version 12 for the upcoming CP 8.0
PR-759 - Upgrade Protobuf to 4.29.3
fde07db0 - update netty to 4.1.118
f982ea91 - update bouncycastle dependencies
da33ed03 - fix the merge conflict
29819815 - update jetty to 9.4.57
ffe9fa48 - update bouncycastle to version 2.x for testing in CP
PR-743 - adding block level status for semaphore
PR-742 - Revert upgrade to Avro 1.12.0
130145e6 - Revert “upgrade sem java version to 17 as we already upgraded to 17 here.”
4b2f8e9b - upgrade sem java version to 17 as we already upgraded to 17 here. https://github.com/confluentinc/common/blob/master/.semaphore/semaphore.yml#L79
6a98be70 - update netty to 4.1.115
34310351 - revert bouncycastle bctls due to downstream failues
34f3ad49 - update java to version 17 and avro

Kafka¶

PR-19790 - KAFKA-18687: Setting the subscriptionMetadata during conversion to consumer group (#19790)
PR-19658 - KAFKA-18345; Prevent livelocked elections (#19658)
PR-19507 - KAFKA-19171: Kafka Streams crashes with UnsupportedOperationException (#19507)
PR-19580 - KAFKA-19208: KStream-GlobalKTable join should not drop left-null-key record (#19580)
PR-19713 - KAFKA-19274; Group Coordinator Shards are not unloaded when __consumer_offsets topic is deleted (#19713)
PR-19712 - KAFKA-19275 client-state and thread-state metrics are always “Unavailable” (#19712)
PR-19677 - KAFKA-18688: Fix uniform homogeneous assignor stability (#19677)
PR-19496 - KAFKA-19163: Avoid deleting groups with pending transactional offsets (#19496)
PR-19497 - KAFKA-19160;KAFKA-19164; Improve performance of fetching stable offsets (#19497)
PR-1623 - Ignore failing quota_test
PR-19629 - KAFKA-19131: Adjust remote storage reader thread maximum pool size to avoid illegal argument (#19629)
PR-1620 - Dexcom fix 4.0
PR-19555 - KAFKA-19195: Only send the right group ID subset to each GC shard (#19555)
PR-19545 - KAFKA-19192; Old bootstrap checkpoint files cause problems updated servers (#19545)
PR-19518 - KAFKA-19166: Fix RC tag in release script (#19518)
PR-1613 - CONFLUENT: Fix tools-log4j files names in the scripts
PR-19394 - KAFKA-19054: StreamThread exception handling with SHUTDOWN_APPLICATION may trigger a tight loop with MANY logs (#19394)
PR-19488 - KAFKA-19147: Start authorizer before group coordinator to ensure coordinator authorizes regex topics (#19488)
PR-19345 - KAFKA-19071: Fix doc for remote.storage.enable (#19345)
PR-19188 - KAFKA-18962: Fix onBatchRestored call in GlobalStateManagerImpl (#19188)
83f6a1d7 - KAFKA-18991; Missing change for cherry-pick
PR-19223 - KAFKA-18991: FetcherThread should match leader epochs between fetch request and fetch state (#19223)
PR-18852 - KAFKA-18723; Better handle invalid records during replication (#18852)
PR-1611 - Fix build failure (#1582)
PR-19213 - KAFKA-18984: Reset interval.ms By Using kafka-client-metrics.sh (#19213)
PR-19303 - KAFKA-16407: Fix foreign key INNER join on change of FK from/to a null value (#19303)
PR-19269 - KAFKA-18067: Add a flag to disable producer reset during active task creator shutting down (#19269)
PR-19331 - KAFKA-15931: Cancel RemoteLogReader gracefully (#19331)
PR-18842 - KAFKA-806 Index may not always observe log.index.interval.bytes (#18842)
PR-19212 - KAFKA-18993 Remove confusing notable change section from upgrade.html (#19212)
PR-19164 - KAFKA-18943: Kafka Streams incorrectly commits TX during task revokation (#19164)
PR-19205 - KAFKA-18979; Report correct kraft.version in ApiVersions (#19205)
PR-19119 - KAFKA-18422 Adjust Kafka client upgrade path section (#19119)
PR-18091 - KAFKA-18074: Add kafka client compatibility matrix (#18091)
PR-18258 - KAFKA-18195: Fix Kafka Streams broker compatibility matrix (#18258)
PR-19156 - KAFKA-18940: fix electionWasClean (#19156)
PR-19127 - KAFKA-18920: The kcontrollers must set kraft.version in ApiVersionsResponse (#19127)
PR-19138 - KAFKA-18046; High CPU usage when using Log4j2 (#19138)
PR-19131 - KAFKA-18648: Make records in FetchResponse nullable again (#19131)
4a500418 - Revert “KAFKA-18246 Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs (#18191)”
PR-19104 - KAFKA-18919 Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde (#19104)
PR-19087 - KAFKA-18886 add behavior change of CreateTopicPolicy and AlterConfigPolicy to zk2kraft (#19087)
PR-19097 - KAFKA-18422 add link of KIP-1124 to “rolling upgrade” section (#19097)
PR-19065 - KAFKA-18876 4.0 documentation improvement (#19065)
PR-19088 - KAFKA-18916; Resolved regular expressions must update the group by topics data structure (#19088)
PR-18997 - KAFKA-18844: Stale features information in QuorumController#registerBroker (#18997)
PR-19036 - KAFKA-18864:remove the Evolving tag from stable public interfaces (#19036)
PR-19067 - KAFKA-18908 Document that the size of appended value can’t be larger than Short.MAX_VALUE (#19067)
PR-19048 - KAFKA-18860 Remove Missing Features section (#19048)
PR-19037 - KAFKA-18869 add remote storage threads to “Updating Thread Configs” section (#19037)
PR-19042 - KAFKA-18813: ConsumerGroupHeartbeat API and ConsumerGroupDescribe API… (#19042)
PR-18988 - KAFKA-18839: Drop EAGER rebalancing support in Kafka Streams (#18988)
PR-18387 - KAFKA-18281: Kafka is improperly validating non-advertised listeners for routable controller addresses (#18387)
PR-18898 - KIP-966 part 1 release doc (#18898)
PR-18880 - KAFKA-15583 doc update for the “strict min ISR” rule (#18880)
PR-19000 - Revert “KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)” (#19000)
PR-18996 - KAFKA-18813: [3/N] Client support for TopicAuthException in DescribeConsumerGroup path (#18996)
PR-18986 - KAFKA-18813: [2/N] Client support for TopicAuthException in HB path (#18986)
PR-18844 - KAFKA-18737 KafkaDockerWrapper setup functions fails due to storage format command (#18844)
PR-18982 - KAFKA-18829: Added check before converting to IMPLICIT mode (#18964) (Cherry-pick) (#18982)
PR-18969 - KAFKA-18831 Migrating to log4j2 introduce behavior changes of adjusting level dynamically (#18969)
PR-18737 - KAFKA-18641: AsyncKafkaConsumer could lose records with auto offset commit (#18737)
PR-18845 - KAFKA-18601: Assume a baseline of 3.3 for server protocol versions (#18845)
PR-18872 - KAFKA-18773 Migrate the log4j1 config to log4j 2 for native image and README (#18872)
PR-18934 - KAFKA-18807; Fix thread idle ratio metric (#18934)
PR-18889 - KAFKA-18784 Fix ConsumerWithLegacyMessageFormatIntegrationTest (#18889)
PR-18916 - KAFKA-18803 The acls would appear at the wrong level of the metadata shell “tree” (#18916)
PR-18906 - KAFKA-18790 Fix testCustomQuotaCallback (#18906)
PR-18680 - KAFKA-18634: Fix ELR metadata version issues (#18680)
PR-18795 - KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (#18795)
PR-18810 - KAFKA-18654[2/2]: Transction V2 retry add partitions on the server side when handling produce request. (#18810)
PR-18756 - KAFKA-17298: Update upgrade notes for 4.0 KIP-848 (#18756)
PR-18275 - KAFKA-15443: Upgrade RocksDB to 9.7.3 (#18275)
PR-18394 - KAFKA-18396: Migrate log4j1 configuration to log4j2 in KafkaDockerWrapper (#18394)
PR-18820 - KAFKA-18366 Remove KafkaConfig.interBrokerProtocolVersion (#18820)
PR-18821 - KAFKA-18743 Remove leader.imbalance.per.broker.percentage as it is not supported by Kraft (#18821)
PR-1579 - CCS CP release test regex updates
PR-1578 - CCS CP release test regex updates
PR-18843 - KAFKA-806 Index may not always observe log.index.interval.bytes (#18843)
PR-18196 - KAFKA-18225 ClientQuotaCallback#updateClusterMetadata is unsupported by kraft (#18196)
PR-18252 - KAFKA-17833: Convert DescribeAuthorizedOperationsTest to use KRaft (#18252)
PR-18818 - KAFKA-18741 document the removal of inter.broker.protocol.version (#18818)
PR-18566 - KAFKA-18360 Remove zookeeper configurations (#18566)
PR-18641 - KAFKA-18530 Remove ZooKeeperInternals (#18641)
PR-18583 - KAFKA-18499 Clean up zookeeper from LogConfig (#18583)
PR-18189 - KAFKA-18206: EmbeddedKafkaCluster must set features (#18189)
PR-18702 - KAFKA-18645: New consumer should align close timeout handling with classic consumer (#18702)
PR-18781 - KAFKA-18675 Add tests for valid and invalid broker addresses (#18781)
PR-18767 - KAFKA-18675 Add unit test to verify space separated brokers won’t cause exception for 3.8 and 3.9 (#18767)
PR-18304 - KAFKA-16524; Metrics for KIP-853 (#18304)
PR-18277 - KAFKA-18635: reenable the unclean shutdown detection (#18277)
PR-18708 - KAFKA-18649: complete ClearElrRecord handling (#18708)
PR-18148 - KAFKA-16540: Clear ELRs when min.insync.replicas is changed. (#18148)
PR-17952 - KAFKA-16540: enforce min.insync.replicas config invariants for ELR (#17952)
PR-15622 - KAFKA-16446: Improve controller event duration logging (#15622)
PR-18028 - KAFKA-18131: Improve logs for voters (#18028)
PR-18222 - KAFKA-18305: validate controller.listener.names is not in inter.broker.listener.name for kcontrollers (#18222)
PR-18777 - KAFKA-18690: Keep leader metadata for RE2J-assigned partitions (#18777)
PR-17836 - KAFKA-18028 the effective kraft version of –no-initial-controllers should be 1 rather than 0 (#17836)
PR-18165 - KAFKA-18230: Handle not controller or not leader error in admin client (#18165)
PR-17773 - KAFKA-18001: Support UpdateRaftVoterRequest in KafkaNetworkChannel (#17773)
PR-18720 - KAFKA-18654 [1/2]: Transaction Version 2 performance regression due to early return (#18720)
PR-18592 - KAFKA-18545: Remove Zookeeper logic from LogManager (#18592)
PR-18786 - KAFKA-18672; CoordinatorRecordSerde must validate value version (4.0) (#18786)
PR-18717 - KAFKA-18655: Implement the consumer group size counter with scheduled task (#18717)
PR-18764 - KAFKA-18685: Cleanup DynamicLogConfig constructor (#18764)
PR-18785 - KAFKA-18676; Update Benchmark system tests (#18785)
PR-18330 - KAFKA-17631 Convert SaslApiVersionsRequestTest to kraft (#18330)
PR-18768 - KAFKA-18678 Update TestVerifiableProducer system test (#18768)
PR-18751 - KAFKA-18674 Document the incompatible changes in parsing –bootstrap-server (#18751)
PR-18727 - KAFKA-18659: librdkafka compressed produce fails unless api versions returns produce v0 (#18727)
fc3dca4e - Revert “KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (#17700)”
PR-18758 - KAFKA-18660: Transactions Version 2 doesn’t handle epoch overflow correctly (#18730) (#18758)
PR-18750 - KAFKA-18320; Ensure that assignors are at the right place (#18750)
PR-17700 - KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (#17700)
PR-18766 - KAFKA-18146; tests/kafkatest/tests/core/upgrade_test.py needs to be re-added as KRaft (#18766)
PR-18763 - KAFKA-18677; Update ConsoleConsumerTest system test (#18763)
PR-18754 - KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18754)
PR-1556 - MINOR: Disable publish artifacts for 4.0
PR-18731 - KAFKA-18570: Update documentation to add remainingLogsToRecover, remainingSegmentsToRecover and LogDirectoryOffline metrics (#18731)
PR-18741 - KAFKA-18171: Revert the strict config validation for 3.8 and 3.9 (#18741)
PR-18590 - KAFKA-18569: New consumer close may wait on unneeded FindCoordinator (#18590)
PR-18314 - KAFKA-16339: Add Kafka Streams migrating guide from transform to process (#18314)
PR-18478 - KAFKA-18383 Remove reserved.broker.max.id and broker.id.generation.enable (#18478)
PR-18733 - KAFKA-18662: Return CONCURRENT_TRANSACTIONS on produce request in TV2 (#18733)
PR-18726 - KAFKA-18646: Null records in fetch response breaks librdkafka (#18726)
PR-18736 - KAFKA-18663: Metadata v0-v3 should be undeprecated (#18736)
PR-18668 - KAFKA-18619: New consumer topic metadata events should set requireMetadata flag (#18668)
PR-18716 - KAFKA-18648: Add back support for metadata version 0-3 (#18716)
PR-1553 - [3.9] Update jetty to 9.4.57.v20241219
PR-18555 - KAFKA-18528: MultipleListenersWithSameSecurityProtocolBaseTest and GssapiAuthenticationTest should run for async consumer (#18555)
PR-18602 - KAFKA-17587 Refactor test infrastructure (#18602)
PR-18690 - KAFKA-18597 Fix max-buffer-utilization-percent is always 0 (#18690)
PR-17510 - KAFKA-17792: Efficiently parse decimals with large exponents in Connect Values (#17510)
PR-18539 - KAFKA-18454 Publish build scans to develocity.apache.org (#18539)
PR-18693 - KAFKA-18631 Remove ZkConfigs (#18693)
PR-18547 - KAFKA-18533 Remove KafkaConfig zookeeper related logic (#18547)
PR-18687 - KAFKA-18630: Clean ReplicaManagerBuilder (#18687)
PR-18621 - KAFKA-18592 Cleanup ReplicaManager (#18621)
PR-18477 - KAFKA-18474: Remove zkBroker listener (#18477)
PR-18630 - KAFKA-18599: Remove Optional wrapping for forwardingManager in ApiVersionManager (#18630)
PR-18667 - KAFKA-18484 [2/2]; Handle exceptions during coordinator unload (#18667)
PR-18666 - KAFKA-18486; [1/2] Update LocalLeaderEndPointTest (#18666)
PR-18532 - KAFKA-18517: Enable ConsumerBounceTest to run for new async consumer (#18532)
PR-18614 - KAFKA-18519: Remove Json.scala, cleanup AclEntry.scala (#18614)
PR-18389 - KAFKA-18229: Move configs out of “kraft” directory (#18389)
PR-18629 - KAFKA-18598: Remove ControllerMetadataMetrics ZK-related Metrics (#18629)
PR-18631 - KAFKA-18595: Remove AuthorizerUtils#sessionToRequestContext (#18631)
PR-18661 - KAFKA-18484 [1/N]; Handle exceptions from deferred events in coordinator (#18661)
PR-18657 - KAFKA-18583; Fix getPartitionReplicaEndpoints for KRaft (#18657)
PR-18607 - KAFKA-17402: DefaultStateUpdated should transite task atomically (#18607)
PR-18587 - KAFKA-8862: Improve Producer error message for failed metadata update (#18587)
PR-18581 - KAFKA-17561: add processId tag to thread-state metric (#18581)
PR-18647 - KAFKA-18487; Remove ReplicaManager#stopReplicas (#18647)
PR-18635 - KAFKA-18583; Fix getPartitionReplicaEndpoints for KRaft (#18635)
PR-18485 - Cherrypick lock backoff retry to 3.9 (#18485)
PR-18497 - KAFKA-14552: Assume a baseline of 3.0 for server protocol versions (#18497)
PR-18340 - KAFKA-18339: Fix parseRequestHeader error handling (#18340)
PR-18643 - Revert “KAFKA-18404: Remove partitionMaxBytes usage from DelayedShareFetch (#17870)” (#18643)
PR-18346 - KAFKA-18363: Remove ZooKeeper mentiosn in broker configs (#18346)
PR-18628 - KAFKA-18578: Remove UpdateMetadataRequest from MetadataCacheTest (#18628)
PR-18567 - KAFKA-18553: Update javadoc and comments of ConfigType (#18567)
PR-18624 - KAFKA-18588 Remove TopicKey.scala (#18624)
PR-17390 - KAFKA-17668: Clean-up LogCleaner#maxOverCleanerThreads and LogCleanerManager#maintainUncleanablePartitions (#17390)
PR-18613 - KAFKA-18427: Remove ZooKeeperClient (#18613)
PR-18591 - KAFKA-18540: Remove UpdataMetadataRequest from KafkaApisTest (#18591)
PR-18594 - KAFKA-18532: Clean Partition.scala zookeeper logic (#18594)
PR-18605 - KAFKA-18423: Remove ZkData and related unused references (#18605)
PR-18616 - KAFKA-18429 Remove ZkFinalizedFeatureCache and StateChangeFailedException (#18616)
PR-18619 - KAFKA-18589 Remove unused interBrokerProtocolVersion from GroupMetadataManager (#18619)
PR-18598 - KAFKA-18516 Remove RackAwareMode (#18598)
PR-18608 - KAFKA-18492 Cleanup RequestHandlerHelper (#18608)
PR-18586 - KAFKA-18565 Cleanup SaslSetup (#18586)
PR-18606 - KAFKA-18430 Remove ZkNodeChangeNotificationListener (#18606)
PR-18595 - KAFKA-18515 Remove DelegationTokenManagerZk (#18595)
PR-18492 - KAFKA-18480 Fix fail e2e test_offset_truncate (#18492)
PR-18524 - KAFKA-18514: Refactor share module code to server and server-common (#18524)
PR-17870 - KAFKA-18404: Remove partitionMaxBytes usage from DelayedShareFetch (#17870)
PR-18240 - KAFKA-17642: PreVote response handling and ProspectiveState (#18240)
PR-18585 - KAFKA-18413: Remove AdminZkClient (#18585)
PR-18406 - KAFKA-18318: Add logs for online/offline migration indication (#18406)
PR-18224 - KAFKA-18150; Downgrade group on classic leave of last consumer member (#18224)
PR-18573 - KAFKA-18431: Remove KafkaController (#18573)
PR-18565 - KAFKA-18546: Use mocks instead of a real DNS lookup to the outside (#18565)
PR-18553 - KAFKA-18373: Remove ZkMetadataCache (#18553)
PR-18574 - KAFKA-18407: Remove ZkAdminManager, DelayedCreatePartitions, CreatePartitionsMetadata, ZkConfigRepository, DelayedDeleteTopics (#18574)
PR-18568 - KAFKA-18556: Remove JaasModule#zkDigestModule, JaasTestUtils#zkSections (#18568)
PR-18140 - KAFKA-16368: Add a new constraint for segment.bytes to min 1MB for KIP-1030 (#18140)
PR-18106 - KAFKA-16368: Update defaults for LOG_MESSAGE_TIMESTAMP_AFTER_MAX_MS_DEFAULT and NUM_RECOVERY_THREADS_PER_DATA_DIR_CONFIG (#18106)
PR-18535 - KAFKA-18521 Cleanup NodeApiVersions zkMigrationEnabled field (#18535)
PR-18552 - KAFKA-18542 Cleanup AlterPartitionManager (#18552)
PR-18561 - KAFKA-18406 Remove ZkBrokerEpochManager.scala (#18561)
PR-18508 - KAFKA-18405 Remove ZooKeeper logic from DynamicBrokerConfig (#18508)
PR-18080 - KAFKA-16368: Update default linger.ms to 5ms for KIP-1030 (#18080)
PR-18414 - KAFKA-18331: Make process.roles and node.id required configs (#18414)
PR-18483 - KAFKA-18472: Remove MetadataSupport (#18483)
PR-18536 - KAFKA-18514 Remove server dependency on share coordinator (#18536)
PR-18365 - KAFKA-18364 add document to show the changes of metrics and configs after removing zookeeper (#18365)
PR-18550 - KAFKA-18539 Remove optional managers in KafkaApis (#18550)
PR-18563 - use version.py get_version to get version (#18563)
PR-18490 - KAFKA-18479: RocksDBTimeOrderedKeyValueBuffer not initialized correctly (#18490)
PR-18448 - KAFKA-18401: Transaction version 2 does not support commit transaction without records (#18448)
155d7720 - HOTIFX: fix broken build
PR-18542 - KAFKA-18399 Remove ZooKeeper from KafkaApis (12/N): clean up ZKMetadataCache, KafkaController and raftSupport (#18542)
PR-18386 - KAFKA-18346 Fix e2e TestKRaftUpgrade for v3.3.2 (#18386)
21c4539d - Revert “KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18050)”
PR-18530 - KAFKA-18520: Remove ZooKeeper logic from JaasUtils (#18530)
PR-18540 - KAFKA-18399 Remove ZooKeeper from KafkaApis (11/N): CREATE_ACLS and DELETE_ACLS (#18540)
PR-18432 - KAFKA-18399 Remove ZooKeeper from KafkaApis (10/N): ALTER_CONFIG and INCREMENETAL_ALTER_CONFIG (#18432)
PR-18487 - KAFKA-18476: KafkaStreams should swallow TransactionAbortedException (#18487)
PR-18195 - KAFKA-18026: KIP-1112, clean up StatefulProcessorNode (#18195)
PR-18150 - KAFKA-18026: KIP-1112 migrate KTableSuppressProcessorSupplier (#18150)
PR-18518 - KAFKA-18502 Remove kafka.controller.Election (#18518)
PR-18281 - KAFKA-18330: Update documentation to remove controller deployment limitations (#18281)
PR-18465 - KAFKA-18399 Remove ZooKeeper from KafkaApis (9/N): ALTER_CLIENT_QUOTAS and ALLOCATE_PRODUCER_IDS (#18465)
PR-18453 - KAFKA-18399 Remove ZooKeeper from KafkaApis (8/N): ELECT_LEADERS , ALTER_PARTITION, UPDATE_FEATURES (#18453)
PR-18403 - KAFKA-18211: Override class loaders for class graph scanning in connect. (#18403)
PR-17669 - KAFKA-17915: Convert Kafka Client system tests to use KRaft (#17669)
PR-18507 - KAFKA-18491 Remove zkClient & maybeUpdateMetadataCache from ReplicaManager (#18507)
0186534a - Revert “KAFKA-17411: Create local state Standbys on start (#16922)” and “KAFKA-17978: Fix invalid topology on Task assignment (#17778)”
PR-18475 - KAFKA-18469;KAFKA-18036: AsyncConsumer should request metadata update if ListOffsetRequest encounters a retriable error (#18475)
PR-17728 - KAFKA-17973: Relax Restriction for Voters Set Change (#17728)
PR-18050 - KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18050)
PR-18504 - KAFKA-18485; Update log4j2.yaml (#18504)
PR-18433 - KAFKA-18399 Remove ZooKeeper from KafkaApis (7/N): CREATE_TOPICS, DELETE_TOPICS, CREATE_PARTITIONS (#18433)
PR-18320 - KAFKA-18341: Remove KafkaConfig GroupType config check and warn log (#18320)
PR-18447 - KAFKA-18399 Remove ZooKeeper from KafkaApis (6/N): handleCreateTokenRequest, handleRenewTokenRequestZk, handleExpireTokenRequestZk (#18447)
PR-18464 - KAFKA-18399 Remove ZooKeeper from KafkaApis (5/N): ALTER_PARTITION_REASSIGNMENTS, LIST_PARTITION_REASSIGNMENTS (#18464)
PR-18461 - KAFKA-18399 Remove ZooKeeper from KafkaApis (4/N): OFFSET_COMMIT and OFFSET_FETCH (#18461)
PR-18456 - KAFKA-18399 Remove ZooKeeper from KafkaApis (3/N): USER_SCRAM_CREDENTIALS (#18456)
PR-18472 - KAFKA-18466 Remove log4j-1.2-api from runtime scope while keeping it in distribution package (#18472)
PR-18437 - KAFKA-18446 Remove MetadataCacheControllerNodeProvider (#18437)
PR-18468 - KAFKA-18465: Remove MetadataVersions older than 3.0-IV1 (#18468)
PR-18467 - KAFKA-18464: Empty Abort Transaction can fence producer incorrectly with Transactions V2 (#18467)
PR-18471 - KAFKA-8116: Update Kafka Streams archetype for Java 11 (#18471)
PR-18378 - KAFKA-18340: Change Dockerfile to use log4j2 yaml instead log4j properties (#18378)
PR-17454 - KAFKA-17671: Create better documentation for transactions (#17454)
PR-18422 - KAFKA-18399 Remove ZooKeeper from KafkaApis (2/N): CONTROLLED_SHUTDOWN and ENVELOPE (#18422)
PR-18146 - KAFKA-18073: Prevent dropped records from failed retriable exceptions (#18146)
PR-18321 - KAFKA-13093: Log compaction should write new segments with record version v2 (KIP-724) (#18321)
PR-18100 - KAFKA-18180: Move OffsetResultHolder to storage module (#18100)
PR-17527 - KAFKA-17455: fix stuck producer when throttling or retrying (#17527)
PR-18367 - KAFKA-17915: Convert remaining Kafka Client system tests to use KRaft (#18367)
PR-18247 - KAFKA-18277 Convert network_degrade_test to Kraft mode (#18247)
PR-18445 - KAFKA-18445 Remove LazyDownConversionRecords and LazyDownConversionRecordsSend (#18445)
PR-18417 - KAFKA-18399 Remove ZooKeeper from KafkaApis (1/N): LEADER_AND_ISR, STOP_REPLICA, UPDATE_METADATA (#18417)
PR-18382 - KAFKA-17730 ReplicaFetcherThreadBenchmark is broken (#18382)
PR-18423 - KAFKA-18437: Correct version of ShareUpdateRecord value (#18423)
PR-18457 - KAFKA-18397: Added null check before sending background event from ShareConsumeRequestManager. (#18419) (#18457)
PR-18462 - KAFKA-18449: Add share group state configs to reconfig-server.properties (#18440) (#18462)
PR-18450 - KAFKA-18435 Remove zookeeper dependencies in build.gradle (#18450)
PR-18438 - KAFKA-18432 Remove unused code from AutoTopicCreationManager (#18438)
PR-18441 - KAFKA-18426 Remove FinalizedFeatureChangeListener (#18441)
PR-18443 - KAFKA-18425 Remove OffsetTrackingListener (#18443)
PR-18428 - Backport some GHA changes from trunk (#18428)
PR-18329 - KAFKA-18353 Remove zk config control.plane.listener.name (#18329)
PR-18429 - KAFKA-18443 Remove ZkFourLetterWords (#18429)
PR-18431 - KAFKA-18417 Remove controlled.shutdown.max.retries and controlled.shutdown.retry.backoff.ms (#18431)
PR-18287 - KAFKA-18326: fix merge iterator with cache tombstones (#18287)
PR-18413 - KAFKA-18411 Remove ZkProducerIdManager (#18413)
PR-18401 - KAFKA-18414 Remove KRaftRegistrationResult (#18401)
PR-17671 - KAFKA-17921 Support SASL_PLAINTEXT protocol with java.security.auth.login.config (#17671)
PR-18411 - KAFKA-18436: Revert Multiversioning Changes from 4.0 release. (#18411)
PR-18364 - KAFKA-18384 Remove ZkAlterPartitionManager (#18364)
PR-18399 - KAFKA-18412: Remove EmbeddedZookeeper (#18399)
PR-18352 - KAFKA-18368 Remove TestUtils#MockZkConnect and remove zkConnect from TestUtils#createBrokerConfig (#18352)
PR-18370 - KAFKA-18388 test-kraft-server-start.sh should use log4j2.yaml (#18370)
PR-18355 - KAFKA-18374 Remove EncryptingPasswordEncoder, CipherParamsEncoder, GcmParamsEncoder, IvParamsEncoder, and the unused static variables in PasswordEncoder (#18355)
PR-18384 - KAFKA-17616: Remove KafkaServer (#18384)
PR-18353 - KAFKA-18365 Remove zookeeper.connect in Test (#18353)
PR-18363 - KAFKA-18367 Remove ZkConfigManager (#18363)
PR-18351 - KAFKA-18347 Add tools-log4j2.yaml to config and remove unsed tools-log4j.properties from config (#18351)
PR-18359 - KAFKA-18375 Update the LICENSE-binary (#18359)
PR-18345 - KAFKA-18026: KIP-1112, configure all StoreBuilder & StoreFactory layers (#18345)
PR-18347 - KAFKA-18361 Remove PasswordEncoderConfigs (#18347)
PR-18271 - KAFKA-17615 Remove KafkaServer from tests (#18271)
PR-18308 - KAFKA-18280 fix e2e TestSecurityRollingUpgrade.test_rolling_upgrade_sasl_mechanism_phase_one (#18308)
PR-18327 - KAFKA-18313 Fix to Kraft or remove tests associate with Zk Broker config in SocketServerTest and ReplicaFetcherThreadTest (#18327)
PR-18279 - KAFKA-18316 Fix to Kraft or remove tests associate with Zk Broker config in ConnectionQuotasTest (#18279)
PR-18185 - KAFKA-18243 Fix compatibility of Loggers class between log4j and log4j2 (#18185)
PR-18269 - KAFKA-18315 Fix to Kraft or remove tests associate with Zk Broker config in DynamicBrokerConfigTest, ReplicaManagerTest, DescribeTopicPartitionsRequestHandlerTest, KafkaConfigTest (#18269)
PR-18338 - KAFKA-18354 Use log4j2 APIs to refactor LogCaptureAppender (#18338)
PR-18309 - KAFKA-18314 Fix to Kraft or remove tests associate with Zk Broker config in KafkaApisTest (#18309)
PR-18344 - KAFKA-18359 Set zkConnect to null in LocalLeaderEndPointTest, HighwatermarkPersistenceTest, IsrExpirationTest, ReplicaManagerQuotasTest, OffsetsForLeaderEpochTest (#18344)
PR-18333 - KAFKA-18272: Deprecated protocol api usage should be logged at info level (3.9) (#18333)
PR-18283 - KAFKA-18317 Remove zookeeper.connect from RemoteLogManagerTest (#18283)
PR-18295 - KAFKA-18339: Remove raw unversioned direct SASL protocol (KIP-896) (#18295)
PR-18313 - KAFKA-18272: Deprecated protocol api usage should be logged at info level (#18313)
PR-18282 - KAFKA-18295 Remove deprecated function Partitioner#onNewBatch (#18282)
PR-18317 - KAFKA-18348 Remove the deprecated MockConsumer#setException (#18317)
PR-18324 - KAFKA-18352: Add back DeleteGroups v0, it incorrectly tagged as deprecated (#18324)
PR-18323 - KAFKA-18352: DeleteGroups v0 incorrectly tagged as deprecated (3.9) (#18323)
PR-18250 - KAFKA-18093 Remove deprecated DeleteTopicsResult#values (#18250)
PR-18312 - KAFKA-18343: Use java_pids to implement pids (#18312)
PR-18294 - KAFKA-18338 add log4j.yaml to test-common-api and remove unsed log4j.properties from test-common (#18294)
PR-18306 - KAFKA-18342 Use File.exist instead of File.exists to ensure the Vagrantfile works with Ruby 3.2+ (#18306)
PR-18246 - KAFKA-18290 Remove deprecated methods of FeatureUpdate (#18246)
PR-18255 - KAFKA-18289 Remove deprecated methods of DescribeTopicsResult (#18255)
PR-18265 - KAFKA-18291 Remove deprecated methods of ListConsumerGroupOffsetsOptions (#18265)
PR-18267 - KAFKA-17393: Remove log.message.format.version/message.format.version (KIP-724) (#18267)
PR-18132 - KAFKA-17705: Add Transactions V2 system tests and mark as production ready (#18132)
PR-18291 - KAFKA-18269: Remove deprecated protocol APIs support (KIP-896, KIP-724) (#18291)
PR-18288 - KAFKA-18334: Produce v4-v6 should be undeprecated (#18288)
PR-18262 - KAFKA-18270: FindCoordinator v0 incorrectly tagged as deprecated (#18262)
PR-18221 - KAFKA-18270: SaslHandshake v0 incorrectly tagged as deprecated (#18221)
PR-18249 - KAFKA-13722: code cleanup after deprecated StateStore.init() was removed (#18249)
PR-18285 - KAFKA-18312: Added entityType: topicName to SubscribedTopicNames in ShareGroupHeartbeatRequest.json (#18285)
PR-18204 - KAFKA-18262 Remove DefaultPartitioner and UniformStickyPartitioner (#18204)
PR-18257 - KAFKA-18296 Remove deprecated KafkaBasedLog constructor (#18257)
PR-18238 - KAFKA-12829: Remove old Processor and ProcessorSupplier interfaces (#18238)
PR-18245 - KAFKA-18292 Remove deprecated methods of UpdateFeaturesOptions (#18245)
PR-18154 - KAFKA-12829: Remove deprecated Topology#addProcessor of old Processor API (#18154)
PR-18243 - KAFKA-13722: Refactor Kafka Streams store interfaces (#18243)
PR-18241 - KAFKA-17131: Refactor TimeDefinitions (#18241)
PR-18242 - KAFKA-13722: Refactor SerdeGetter (#18242)
PR-18176 - KAFKA-18227: Ensure v2 partitions are not added to last transaction during upgrade (#18176)
PR-18260 - KAFKA-18294 Remove deprecated SourceTask#commitRecord (#18260)
PR-18211 - KAFKA-18264 Remove NotLeaderForPartitionException (#18211)
PR-18248 - KAFKA-18094 Remove deprecated TopicListing(String, Boolean) (#18248)
PR-18205 - KAFKA-18026: transition KTable#filter impl to use processor wrapper (#18205)
PR-18244 - KAFKA-18293 Remove org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerLoginCallbackHandler and org.apache.kafka.common.security.oauthbearer.secured.OAuthBearerValidatorCallbackHandler (#18244)
PR-18234 - KAFKA-17960; PlaintextAdminIntegrationTest.testConsumerGroups fails with CONSUMER group protocol (#18234)
PR-18144 - KAFKA-18200; Handle empty batches in coordinator runtime (#18144)
PR-18206 - KAFKA-17507; WriteTxnMarkers API must not return until markers are written and materialized in group coordinator’s cache (#18168) (#18206)
PR-18180 - KAFKA-18237: Upgrade system tests from using 3.7.1 to 3.7.2 (#18180)
PR-18210 - KAFKA-18259: Documentation for consumer auto.offset.reset contains invalid HTML (#18210)
PR-18207 - KAFKA-18263; Group lock must be acquired when reverting static membership rejoin (#18207)
PR-18166 - KAFKA-18226: Disable CustomQuotaCallbackTest and remove isKRaftTest (#18166)
PR-18192 - KAFKA-18247 Use log4j2 yaml to rewrite the fix of KAFKA-18145 (#18192)
PR-18096 - KAFKA-18014: Add duration based offset reset option for ShareConsumer (#18096)
PR-18194 - KAFKA-18026: KIP-1112, migrate foreign-key joins to use ProcesserSupplier#stores (#18194)
PR-18191 - KAFKA-18246 Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs (#18191)
PR-18155 - KAFKA-18026: supply stores for KTable#mapValues using ProcessorSupplier#stores (#18155)
PR-18089 - KAFKA-18160 Interrupting or waking up onPartitionsAssigned in AsyncConsumer can cause the ConsumerRebalanceListenerCallbackCompletedEvent to be skipped (#18089)
PR-18173 - KAFKA-18234 DumpLogSegments cannot print ConsumerGroupRegularExpression record (#18173)
PR-18184 - KAFKA-18240 Remove nonexistent LOG4J_CONFIG from transactional_message_copier.py (#18184)
PR-17880 - KAFKA-14587: Move AclCommand to tools (#17880)
PR-18182 - KAFKA-18242 The java code in core module is NOT configured with suitable release version (#18182)
PR-17859 - KAFKA-17928: Make remote log manager thread-pool configs dynamic (#17859)
PR-18170 - KAFKA-18223 Add GHA to run report [2/n] (#18170)
PR-18105 - KAFKA-18181 Refactor ShareConsumerTest (#18105)
PR-18168 - KAFKA-17507; WriteTxnMarkers API must not return until markers are written and materialized in group coordinator’s cache (#18168)
PR-17807 - KAFKA-17641; Update Vote RPC with PreVote field (#17807)
PR-18172 - KAFKA-18224: Explicit group protocol setting in streams resetter (#18172)
PR-18113 - KAFKA-18183 replace BytesSerializer with ByteArraySerializer for producer/consumer (#18113)
PR-18134 - KAFKA-18203 Add a section for Java version in intellij idea in README (#18134)
PR-18163 - KAFKA-18228 The MetricsDuringTopicCreationDeletionTest should delete topics to ensure that the metrics are recreated (#18163)
PR-18156 - KAFKA-18218 fix Trogdor system test (#18156)
PR-17373 - KAFKA-9366 Upgrade log4j to log4j2 (#17373)
PR-18127 - KAFKA-18199; Fix size calculation for nullable tagged structs (#18127)
PR-17199 - KAFKA-16143: New JMX metrics for AsyncKafkaConsumer (#17199)
PR-18141 - KAFKA-17750; Extend kafka-consumer-groups command line tool to support new consumer group (part 3) (#18141)
PR-17524 - KIP-1073: Return fenced brokers in DescribeCluster response (#17524)
PR-18145 - KAFKA-18214 TestUtils#waitForCondition does not honor the maxWaitMs (#18145)
PR-18111 - KAFKA-18026: KIP-1112, migrate stream-stream joins to use ProcesserSupplier#stores (#18111)
PR-18149 - KAFKA-18026: KIP-1112 convert StreamToTableNode (#18149)
PR-18137 - KAFKA-16368: Update remote.log.manager.* default thread pool values for KIP-1030 (#18137)
PR-18159 - KAFKA-18219 Use INFO level instead of ERROR after successfully performing an unclean leader election (#18159)
PR-18160 - Set protocol for streams tests (#18160)
PR-18016 - KAFKA-18136: Remove zk migration from code base (#18016)
PR-18014 - KAFKA-18058: Share group state record pruning impl. (#18014)
PR-18048 - KAFKA-18026: KIP-1112, migrate table-table joins to use ProcesserSuppliers#stores (#18048)
PR-18104 - KAFKA-18186 Set options.release to make Intellij configure suitable language level automatically (#18104)
PR-17741 - KAFKA-18215: KIP-891 Connect Multiversioning Support (Configs and Validation changes for Connectors and Converters) (#17741)
PR-18115 - KAFKA-18015: add byDuration auto.offset.reset to Kafka Streams (#18115)
PR-18088 - KAFKA-12829: Remove deprecated KStream.process() for old Processor API (#18088)
PR-18098 - KAFKA-18021: Disabled MirrorCheckpointConnector throws RetriableException on task config generation (#18098)
PR-18143 - KAFKA-17040: Removing exception on further calls to terminated telemetry reporter (#18143)
PR-17973 - KAFKA-18015: Add support for duration based offset reset strategy to Kafka Streams (#17973)
PR-17352 - KAFKA-17030; Unattached voters will fetch from bootstrap servers (#17352)
PR-18138 - KAFKA-17554 disable testFutureCompletionOutsidePoll (#18138)
PR-18109 - KAFKA-18189: CoordinatorRequestManager log message can include incorrect coordinator disconnect time (#18109)
PR-16754 - KAFKA-16437 Upgrade to Jakarta and Jetty 12 (KIP-1032) (#16754)
PR-18036 - KAFKA-18156 VerifiableConsumer should ignore “–session-timeout” when using CONSUMER protocol (#18036)
PR-18095 - KAFKA-18179: Move AsyncOffsetReadFutureHolder to storage module (#18095)
PR-18116 - KAFKA-18188; Admin LeaveGroup should allow removing member using consumer protocol by member id (#18116)
PR-18123 - update test configs (#18123)
PR-18119 - Add null check (#18119)
PR-18079 - regex integration tests (#18079)
PR-18034 - KAFKA-17750: Extend kafka-consumer-groups command line tool to support new consumer group (part 2) (#18034)
PR-18092 - KAFKA-18178 Remove ZkSecurityMigrator (#18092)
PR-18108 - KAFKA-18040; fix for test that ensures produce during follower shutdown (#18108)
PR-17906 - KAFKA-18026: KIP-1112, document new config and update the Streams upgrade guide (#17906)
PR-18114 - KAFKA-18192 generator module should run under java 11 (#18114)
PR-18102 - KAFKA-18184 Remove the unnecessary project path check from build.gradle (#18102)
PR-17843 - KAFKA-18030 Remove old upgrade-system-tests modules (#17843)
PR-17931 - KAFKA-18067: Kafka Streams can leak Producer client under EOS (#17931)
PR-18083 - KAFKA-18174: Subsequent write event completions should be a noop (#18083)
PR-18063 - KAFKA-18164: Clear existing acknowledgements on share session epoch reset. (#18063)
PR-17500 - KAFKA-14619; KRaft validate snapshot id are at batch boundaries (#17500)
PR-17440 - KAFKA-17696 New consumer background operations unaware of metadata errors (#17440)
PR-18046 - KAFKA-18134; Disallow group upgrades when custom assignors are used (#18046)
PR-17882 - KAFKA-16339: [4/4 KStream#flatTransformValues] Remove Deprecated “transformer” methods and classes (#17882)
PR-18093 - KAFKA-18129 Simplifying share partition maybeInitialize code (#18093)
PR-17992 - KAFKA-18118 Fix the incorrect soft link of results/latest (#17992)
PR-17681 - KAFKA-17864: add descriptions to fields in the agreement (#17681)
PR-18081 - KAFKA-17548: Improve group listing integration test (#18081)
PR-16984 - KAFKA-18182: KIP-891 Add VersionRange to Plugins and DelegatingClassLoader APIs (#16984)
PR-18021 - KAFKA-18144 Move the storage exceptions out of the core module (#18021)
PR-17580 - KAFKA-17796: Persist higher leaderEpoch in read state call. (#17580)
PR-18057 - KAFKA-18162 Move LocalLogTest to storage module (#18057)
PR-18058 - KAFKA-18163: Move VerificationGuardTest to storage module (#18058)
PR-17965 - KAFKA-18084 Added usage for rollback state while SharePartition acquires records (#17965)
PR-17698 - KAFKA-14563: RemoveClient-Side AddPartitionsToTxn Requests (#17698)
PR-18020 - KAFKA-17593; [11/11] Update subscription type (#18020)
PR-17815 - KAFKA-17200: Allow the replication of user internal topics (#17815)
PR-17979 - KAFKA-17945, KAFKA-17944: Handling leader epoch error for offset reset APIs (#17979)
PR-18064 - KAFKA-18148 Remove exceptions from method signatures in Persister (#18064)
PR-17706 - KAFKA-17550: DescribeGroups v6 exploitation (#17706)
PR-18045 - KAFKA-18106: Generate LeaderAndIsrUpdates on unclean shutdown (#18045)
PR-18049 - KAFKA-18159 Remove onPartitionsRevoked and onPartitionsAssigned from SinkTask (#18049)
PR-18022 - KAFKA-18140 Remove ZooKeeperMainWithTlsSupportForKafka (#18022)
PR-18053 - KAFKA-18129: SharePartition#maybeInitialize should complete the future outsize the write lock (#18053)
PR-17886 - KAFKA-18052: Decouple the dependency of feature stable version to the metadata version (#17886)
PR-18047 - KAFKA-18026: KIP-1112, migrate stream-table joins to use ProcesserSupplier#stores (#18047)
PR-17980 - KAFKA-18086: Enable propagation of the error message when writing state (#17980)
PR-17984 - KAFKA-18122 : Added support for ShareConsumeBenchWorker (#17984)
PR-17976 - KAFKA-17593; [10/N] Remove resolved regular expressions when unsubscribed (#17976)
PR-18031 - KAFKA-17598; Command line validation tool for RE2J regex (#18031)
PR-18029 - KAFKA-18155 : Fix bug in response handler for ShareAcknowledge (#18029)
PR-17999 - KAFKA-18050 Upgrade the checkstyle version to 10.20.2 (#17999)
PR-17699 - KAFKA-17947: Update currentLag(), pause(), and resume() to update SubscriptionState in background thread (#17699)
PR-18005 - KAFKA-18132 Remove “session.timeout.ms” from connect-distributed.properties to fix connect e2e (#18005)
PR-17796 - KAFKA-17783: Adding listeners to remove share partition on partition changes (#17796)
PR-18038 - KAFKA-17460 Remove downgrade_test.py (#18038)
PR-18024 - KAFKA-18096: Allow join with regex if no matching topics (#18024)
PR-17985 - KAFKA-18025: Rework acquisition lock timeout test (#17985)
PR-17989 - KAFKA-18127 Validate SubscriptionPattern used on v0 HB (#17989)
PR-18025 - KAFKA-18152 add 0.11, 1.0, 1.1, and 2.0 streams dependencies to dockerfile (#18025)
PR-18023 - KAFKA-18145 Fix failed e2e ConnectDistributedTest.test_dynamic_logging (#18023)
PR-18015 - KAFKA-18026: KIP-1112, skip re-registering aggregate stores in StatefulProcessorNode (#18015)
PR-17991 - KAFKA-18101: Merge duplicate assertFutureThrows and assertFutureExceptionTypeEquals (#17991)
PR-18011 - KAFKA-18137: Unloading transaction state incorrectly removes loading partitions (#18011)
PR-17958 - KAFKA-17750 Extend kafka-consumer-groups command line tool to support new consumer group (part 1) (#17958)
PR-17914 - KAFKA-18060 new coordinator does not handle TxnOffsetCommitRequest with empty member id when using CONSUMER group (#17914)
PR-17957 - KAFKA-18084 Added write locks in SharePartition where locks were async calls were being made (#17957)
PR-17756 - KAFKA-17893: Support record keys in the foreignKeyExtractor argument of KTable foreign join (#17756)
PR-18009 - KAFKA-18138: The controller must add all extant brokers to BrokerHeartbeatTracker when activating (#18009)
PR-17920 - KAFKA-18047: Add org.apache.kafka.automatic.config.providers to System Properties section (#17920)
PR-18003 - KAFKA-18095; Allow a member to join without subscription under new consumer protocol (#18003)
PR-17929 - KAFKA-18026: migrate KStream and KTable aggregates to use ProcesserSupplier#stores (#17929)
PR-18008 - KAFKA-18013: Add integration test for duration based reset strategy in KafkaConsumer (#18008)
PR-17990 - KAFKA-18124 Remove zk migration from RaftManagerTest, BrokerLifecycleManagerTest, KafkaConfigTest, and ReplicaManagerTest (#17990)
PR-18002 - KAFKA-17610 Drop alterConfigs (#18002)
PR-10967 - KAFKA-12770 introduce checkstyleVersion gradle property (for overriding CheckStyle project-defined dependency version) (#10967)
PR-17996 - KAFKA-18128 Fix failed test MetadataSchemaCheckerToolTest.testVerifyEvolutionGit in PR (#17996)
PR-18001 - KAFKA-18130 Remove kafka.utils.VersionInfo (#18001)
PR-15304 - KAFKA-16181: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh (#15304)
PR-17552 - KAFKA-16617 Add KRaft info for the advertised.listeners doc description (#17552)
PR-17972 - KAFKA-18013: Add support for duration based offset reset strategy to Kafka Consumer (#17972)
PR-17964 - KAFKA-15561 [5/N]: Integration tests for new subscribe API with Re2J pattern (#17964)
PR-16899 - KAFKA-17338 ConsumerConfig should prevent using partition assignors with CONSUMER group protocol (#16899)
PR-17975 - KAFKA-18090: Add ShareMemberDescription and Assignment (#17975)
PR-17928 - KAFKA-17997 Remove deprecated config log.message.timestamp.difference.max.ms (#17928)
PR-17740 - KAFKA-17979 Change [pytest] to [tool:pytest] in setup.cfg file (#17740)
PR-17970 - KAFKA-18100 Using block suppresses all errors (#17970)
PR-17971 - KAFKA-18109 Fix failed SaslClientsWithInvalidCredentialsTest in tools module (#17971)
PR-17903 - KAFKA-18026: migrate KTableSource to use ProcesserSupplier#stores (#17903)
PR-17948 - KAFKA-18097 Upgrade readme to include min JDK changes (#17948)
PR-17955 - KAFKA-18098 add kraft support to testReplicaPlacementAllServers and testReplicaPlacementPartialServers (#17955)
PR-17953 - KAFKA-17010 Remove DescribeLogDirsResponse#LogDirInfo, DescribeLogDirsResponse#ReplicaInfo, and DescribeLogDirsResult#all (#17953)
PR-17962 - KAFKA-15561 [4/N]: MockConsumer support for SubscriptionPattern (#17962)
PR-17954 - KAFKA-18100 Using block suppresses all errors (#17954)
PR-17961 - KAFKA-17593; [9/N] Mark ConsumerGroupHeartbeat API v1 as stable (#17961)
PR-17951 - KAFKA-15561 [3/N]: Client support for SubscriptionPattern in HB (#17951)
PR-17934 - KAFKA-18081 Remove isKRaftTest from the kraft-only tests (#17934)
PR-17844 - KAFKA-18012: Update the Scram configuration section for KRaft (#17844)
PR-17904 - KAFKA-12844: clean up TaskId (#17904)
PR-17867 - KAFKA-18062: use feature version to enable ELR (#17867)
PR-17879 - KAFKA-18049: Upgrade the caffeine version to 3.1.1 (#17879)
PR-17864 - KAFKA-17593; [8/N] Resolve regular expressions (#17864)
PR-17736 - KAFKA-17569 Rewrite TestLinearWriteSpeed by Java (#17736)
PR-17522 - KAFKA-17811 Separate modules to use different JDKs (#17522)
PR-17909 - KAFKA-18056: Fixed bug in handling commitAsync responses (#17909)
PR-17932 - KAFKA-18083 ClusterInstance custom controllerListener not work (#17932)
PR-17918 - KAFKA-15561 [2/N]: Background event and subscription state changes for RE2J pattern (#17918)
PR-17927 - KAFKA-18080 Replace DelayedItem by Long type (#17927)
PR-17916 - KAFKA-17990: Deflake testShareAutoOffsetResetDefaultValue (#17916)
PR-17940 - KAFKA-17544: Add log message for early access use of KafkaShareConsumer (#17940)
PR-17849 - KAFKA-17898: Refine Epoch Bumping Logic (#17849)
PR-17783 - KAFKA-17869: Adding tests to ensure KIP-1076 doesn’t interfere producer metrics[2/3] (#17783)
PR-17919 - KAFKA-17299: add unit tests for previous fix (#17919)
PR-17899 - KAFKA-17299: Fix Kafka Streams consumer hang issue (#17899)
PR-17939 - KAFKA-18085: Abort inflight requests on existing connections while rebootstrapping (#17939)
PR-17933 - Fix long running RangeQueryIntegrationTest. (#17933)
PR-17912 - KAFKA-17956 Remove Admin.listShareGroups (#17912)
PR-17923 - KAFKA-18077 Remove deprecated JmxReporter(String) (#17923)
PR-17858 - KAFKA-18013: Add AutoOffsetResetStrategy internal class (#17858)
PR-17876 - KAFKA-18045 Add 0.11, 1.0, 1.1, and 2.0 back to streams_upgrade_test.py (#17876)
PR-17917 - KAFKA-18071: Avoid event to refresh regex if no pattern subscription (#17917)
PR-17925 - KAFKA-18079 consumer-config does not work with console-share-consumer (#17925)
PR-17924 - KAFKA-18078 Fix failed MetricsTest.testJMXFilter (#17924)
PR-17926 - KAFKA-18075 Prevent ClusterInstance default producer and consumer initialization with empty configs (#17926)
PR-17892 - KAFKA-18026: KIP-1112, ProcessorWrapper API with PAPI and partial DSL implementation (#17892)
PR-17922 - KAFKA-18076 Remove isZkMigrationTest and related code (#17922)
PR-17857 - KAFKA-18037 Remove deprecated methods from EmbeddedConnect and EmbeddedConnectCluster (#17857)
PR-17883 - KAFKA-18051: Disallow creating ACLs with principals that do not contain a colon (#17883)
PR-17266 - KAFKA-16339: [3/4 KStream#transformValues] Remove Deprecated “transformer” methods and classes (#17266)
PR-17897 - KAFKA-15561 [1/N]: Introduce new subscribe api for RE2J regex (#17897)
PR-17907 - KAFKA-18059 kafka-metadata-quorum.sh add-controller subcommand can’t recognize argument –config (#17907)
PR-17865 - KAFKA-12690 Remove deprecated Producer#sendOffsetsToTransaction (#17865)
PR-17847 - KAFKA-17917: Convert Kafka core system tests to use KRaft (#17847)
PR-17898 - KAFKA-18063: SnapshotRegistry should not leak memory (#17898)
PR-17889 - KAFKA-18038: fix flakey test StreamThreadTest.shouldLogAndRecordSkippedRecordsForInvalidTimestamps (#17889)
PR-17781 - KAFKA-17869: Adding tests to ensure KIP-1076 doesn’t interfere with consumer metrics[1/3] (#17781)
PR-17403 - KAFKA-17640 Document Java 23 support and include release note (#17403)
PR-17412 - KAFKA-15387: Remove Connect’s deprecated task configurations endpoint (#17412)
PR-17884 - KAFKA-16041: Replace Afterburn module with Blackbird (#17884)
PR-17711 - KAFKA-17850: fix leaking internal exception in state manager (#17711)
PR-17869 - KAFKA-18041: Update key for storing global consumer instance id for consistency (#17869)
PR-17842 - KAFKA-18027: MINOR: Correct DelayedOperationPurgatory code around adding of an already completed operation (#17842)
PR-17525 - KAFKA-17721 Enable to configure listener name and protocol for controller (#17525)
PR-17853 - KAFKA-17733: Protocol upgrade should allow empty member assignment in group conversion (#17853)
PR-17763 - KAFKA-17949: Introduce GroupState and replace ShareGroupState (#17763)
PR-17823 - KAFKA-17593; [7/N] Introduce CoordinatorExecutor (#17823)
PR-17725 - KAFKA-17767 Automatically quarantine new tests [5/n] (#17725)
PR-17713 - KAFKA-17954: Error getting oldest-iterator-open-since-ms from JMX (#17713)
PR-17820 - KAFKA-17561: KIP-1091 add operator metrics (#17820)
PR-17824 - KAFKA-18016: Modified handling of piggyback acknowledgements in ShareConsumeRequestManager. (#17824)
PR-17774 - KAFKA-14934 KafkaClusterTestKit makes FaultHandler accessible (#17774)
PR-17840 - KAFKA-18003: Add test to make sure Admin#deleteRecords can handle the corrupted records (#17840)
PR-17712 - KAFKA-17910 Create integration tests for Admin.listGroups and Admin.describeClassicGroups (#17712)
PR-17367 - KAFKA-17663 Add metadata caching in PartitionLeaderStrategy (#17367)
PR-17717 - KAFKA-17927 Disallow users to configure max.in.flight.requests.per.connection bigger than 5 (#17717)
PR-17822 - KAFKA-18019: Make INVALID_PRODUCER_ID_MAPPING a fatal error (#17822)
PR-17805 - KAFKA-18017: Fix call order for HB error and group manager (#17805)
PR-17811 - KAFKA-17987 Remove ZooKeeper related windows scripts (#17811)
PR-17838 - KAFKA-18029 remove the kraft.version=1 from kafka.py (#17838)
PR-17839 - KAFKA-18029 Fix quorum_reconfiguration_test.py (#17839)
PR-17825 - KAFKA-18022: fetchOffsetMetadata handling for minBytes estimation in both common/uncommon cases of share fetch (#17825)
PR-17777 - KAFKA-16460: New consumer times out consuming records in multiple consumer_test.py system tests (#17777)
PR-17739 - KAFKA-17948: Potential issue during tryComplete and onComplete simultaneous calls to access global variables (#17739)
PR-17542 - KAFKA-17791: Dockerfile should use requirements.txt for dependencies (#17542)
PR-17516 - KAFKA-17648: AsyncKafkaConsumer#unsubscribe and #close swallow TopicAuthorizationException and GroupAuthorizationException (#17516)
PR-17800 - KAFKA-18006: Add 3.9.0 to end-to-end test (streams) (#17800)
PR-17817 - KAFKA-17994 Checked exceptions are not handled (#17817)
PR-17798 - KAFKA-17977 Remove new_consumer from E2E (#17798)
PR-17797 - KAFKA-18006 Add 3.9.0 to end-to-end test (core, client) (#17797)
PR-17709 - KAFKA-17510: Exception handling and purgatory completion on initialization delay (#17709)
PR-17625 - KAFKA-17888 Upgrade ZooKeeper version from 3.4.9 to 3.5.7 to avoid ZOOKEEPER-3779, which can’t run under JDK 11. (#17625)
PR-17794 - KAFKA-17995: Fix errors in remote segment cleanup when retention.ms is large (#17794)
PR-17802 - KAFKA-17992 Remove getUnderlying and isKRaftTest from ClusterInstance (#17802)
PR-17806 - KAFKA-18009: Remove extra public constructor for KafkaShareConsumer (#17806)
PR-16686 - KAFKA-16985: Ensure consumer attempts to send leave request on close even if interrupted (#16686)
PR-17791 - KAFKA-17593; [6/N] Add new record to GroupCoordinatorRecordSerde (#17791)
PR-17799 - Update javadoc on split to mention first matching (#17799)
PR-17750 - KAFKA-17593; [5/N] Include resolved regular expressions into target assignment computation (#17750)
PR-17720 - KAFKA-17885: Enable clients to rebootstrap based on timeout or error code (KIP-1102) (#17720)
PR-17790 - KAFKA-18004 Use version 3.8 to run the ZooKeeper service for end-to-end tests (#17790)
PR-17768 - KAFKA-17987 Remove assorted ZK-related files (#17768)
PR-16705 - KAFKA-17109: Reduce log message load for failed locking (#16705)
PR-17666 - KAFKA-17922 add helper to ClusterInstance to create client component (#17666)
PR-17772 - KAFKA-17991: Added timed calls for future.get in persister. (#17772)
PR-17735 - KAFKA-16780: Document the new RemoteLogMetadataManager#nextSegmentWithTxnIndex API in upgrade notes. (#17735)
PR-17737 - KAFKA-17980: Introduce isReady API in RemoteLogMetadataManager (#17737)
PR-17758 - KAFKA-17985: Set share.auto.offset.reset to earliest in ShareRoundTripWorker (#17758)
PR-17714 - KAFKA-17744: Improve state updater logs when restorating state (#17714)
PR-17778 - KAFKA-17978: Fix invalid topology on Task assignment (#17778)
PR-17620 - KAFKA-17632: Fix RoundRobinPartitioner for even partition counts (#17620)
PR-17749 - KAFKA-17314 Fix the typo: maxlifeTimeMs (#17749)
PR-17754 - KAFKA-17975 Remove ControllerQuorumVotersFutureManager (#17754)
9e01a921 - KAFKA-15722: Add KRaft support in RackAwareAutoTopicCreationTest
PR-17507 - KAFKA-17787: Removed –zookeeper option and logic from ConfigCommand (#17507)
PR-17573 - KAFKA-16726: Added share.auto.offset.reset dynamic config for share groups (#17573)
PR-17243 - KAFKA-17583 Improve the ConfigCommand documentation to show how to set key=[val1,val2] (#17243)
PR-17734 - KAFKA-17974 Upgrade gradle from 8.10 to 8.10.2 (#17734)
PR-17673 - KAFKA-17923 Remove old kafka version from e2e (#17673)
6ea2ed3d - KAFKA-17801: RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns (#17676) (#1 7733)
PR-17670 - KAFKA-17925 Convert Kafka Client integration tests to use KRaft (#17670)
PR-17710 - KAFKA-17872: Update consumed offsets on records with invalid timestamp (#17710)
PR-17730 - KAFKA-15549 Bump swagger dependency version from 2.2.8 to 2.2.25 (#17730)
PR-17579 - KAFKA-17837 Rewrite DeleteTopicTest (#17579)
PR-17722 - KAFKA-17970 Moving some share purgatory classes from core to share module (#17722)
PR-17249 - KAFKA-17570 Rewrite StressTestLog by Java (#17249)
PR-17723 - KAFKA-17969 Fix StorageToolTest for 3.9 (#17723)
PR-17676 - KAFKA-17801: RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns (#17676)
PR-17702 - rebase to fix merge conflict (#17702)
PR-17719 - KAFKA-17926 Improve the documentation explaining why max.in.flight.requests.per.connection should not exceed 5 (#17719)
PR-17660 - KAFKA-17914: Update string ref with SharePartitionKey. (#17660)
PR-17659 - KAFKA-16780: Txn consumer exerts pressure on remote storage when collecting aborted txns (#17659)
PR-17636 - KAFKA-17890: Move DelayedOperationPurgatory to server-common (#17636)
PR-17694 - KAFKA-17593; [4/N] Introduce ConsumerGroupRegularExpression record & related bookkeeping in ConsumerGroup (#17694)
PR-17245 - KAFKA-16339: [2/4 KStream#flatTransform] Remove Deprecated “transformer” methods and classes (#17245)
PR-17657 - KAFKA-17913 Fix KRaft controller count recommendations (#17657)
PR-17567 - KAFKA-17576 Fix all references to kraft/server.properties to use reconfig-server.properties (#17567)
PR-17630 - KAFKA-17248 - KIP 1076 Add process-id to get carried to telemetry results (#17630)
PR-17539 - KAFKA-17743: Add minBytes implementation to DelayedShareFetch (#17539)
PR-17150 - KAFKA-17480: New consumer commit all consumed should retrieve offsets in background thread (#17150)
PR-17692 - KAFKA-17933: Added round trip trogdor workload for share consumer. (#17692)
PR-17691 - KIP-16331: Remove EOS-v1 from StreamsConfigUtils (#17691)
PR-17708 - Update docker_scan.yml for 3.9.0 (#17708)
PR-17686 - KAFKA-17635: Ensure only committed offsets are returned for purging (#17686)
cc53a632 - Bump version to 3.9.0
PR-17680 - KAFKA-17896: Admin.describeClassicGroups (#17680)
PR-17655 - KAFKA-17911: Fix handling of env variables in KafkaDockerWrapper (#17655)
PR-17697 - KAFKA-17924: Remove bufferpool-wait-time-total, io-waittime-total, and iotime-total (#17697)
PR-16988 - KAFKA-12827 Remove Deprecated method KafkaStreams#setUncaughtExceptionHandler (#16988)
PR-17198 - KAFKA-16339: [1/4 KStream#transform] Remove Deprecated “transformer” methods and classes (#17198)
PR-17679 - KAFKA-17931 Revise the specifying-test-retries section in README (#17679)
PR-17682 - KAFKA-17936 Refactor SslTransportLayerTest#testDsaKeyPair to avoid skip test (#17682)
PR-17689 - KAFKA-17916: removing ZK from connect ducktape tests (#17689)
PR-17688 - Fix TransactionStateManager handling of empty batch when loading transaction metadata (#17688)
PR-17021 - KAFKA-17248 - KIP 1076 implementation (#17021)
PR-17275 - KAFKA-17609:[1/4] Changes needed to convert system tests to use KRaft and remove ZK (#17275)
PR-17559 - KAFKA-16816: Remove unneeded FencedInstanceId support on commit path for new consumer (#17559)
PR-17619 - KAFKA-17877; Only call once maybeSendResponseCallback for each marker (#17619)
PR-17537 - KAFKA-17819 : Handle piggyback acknowledgements when subscription changes in ShareConsumeRequestManager. (#17537)
PR-17594 - KAFKA-17857 Move AbstractResetIntegrationTest and subclasses to tools (#17594)
PR-17582 - KAFKA-16964 Integration tests for adding and removing voters (#17582)
PR-17683 - Removed Set.of usage (#17683)
PR-17638 - KAFKA-17625: Removing explicit ZK test parameterizations (#17638)
PR-1510 - Modified Set.of usage in ReplicationControlManagerTest.java to resolve build failures.
PR-17672 - KAFKA-17906 Remove redundant sourceSets from build.gradle (#17672)
PR-17661 - KAFKA-17767 Parse quarantined tests and display them [4/n] (#17661)
PR-17653 - KAFKA-17593; [3/N] Track the number of subscribed members per regular expression in ConsumerGroup (#17653)
PR-17651 - KAFKA-17593; [2/N] Update request validation & validate regex (#17651)
PR-17658 - KAFKA-17919 enable back the failing testShareGroups test (#17658)
PR-17645 - KAFKA-17463 add retry in Persister for NOT_COORDINATOR error (#17645)
PR-17652 - KAFKA-17908 Tweak log messages in group metadata manager (#17652)
PR-17618 - KAFKA-17882 improve the document about “default value” of tagged structure field (#17618)
PR-17665 - KAFKA-17909 Remove zkBroker from ConsumerGroupHeartbeatRequest and ConsumerGroupDescribeRequest (#17665)
PR-17674 - KAFKA-17795 Fix the file path of suppressions.xml to run build on windows (#17674)
PR-17613 - KAFKA-17814 Use final declaration to replace the suppression this-escape (#17613)
PR-17626 - KAFKA-17546 Admin.listGroups and kafka-groups.sh (#17626)
PR-17528 - KAFKA-17803: LogSegment#read should return the base offset of the batch that contains startOffset rather than startOffset (#17528)
PR-17402 - KAFKA-14562 [2/3]: Implement epoch bump after every transaction (KIP-890) (#17402)
PR-17654 - KAFKA-17767 Load test catalog data [3/n] (#17654)
PR-17615 - KAFKA-17880 Move integration test from streams module to streams/integration-tests module (#17615)
PR-17656 - KAFKA-17912 Align string representations of SharePartitionKey (#17656)
PR-17604 - [KAFKA-17870] Fail CreateTopicsRequest if total number of partitions exceeds 10k (#17604)
PR-17549 - KAFKA-17116 New consumer may not send effective leave group if member ID received after close (#17549)
PR-17637 - KAFKA-17899 Add more unit tests for NetworkReceive (#17637)
PR-17648 - KAFKA-17905 Remove the specified type of using lambda for BaseFunction (#17648)
PR-17644 - KAFKA-17903 Remove KafkaFuture#Function and KafkaFuture#thenApply (#17644)
PR-16842 - KAFKA-17002: Integrated partition leader epoch for Persister APIs (KIP-932) (#16842)
PR-17569 - KAFKA-17726: New consumer subscribe/subscribeFromPattern in background thread (#17569)
PR-17603 - KAFKA-17609 Migrate broker compatibility test from ZK to KRaft (#17603)
PR-17562 - KAFKA-17835 Move ProducerIdManager and RPCProducerIdManager to transaction-coordinator module (#17562)
PR-17627 - KAFKA-17767 Store the test catalog in Git [2/n] (2nd attempt) (#17627)
PR-17321 - KAFKA-17609:[2/4]Convert system tests to kraft part 2 (#17321)
PR-17327 - KAFKA-17609:[3/4]Convert system tests to kraft part 3 (#17327)
PR-17328 - KAFKA-17609:[4/4]Convert system tests to kraft part 4 (#17328)
PR-17634 - KAFKA-17593; [1/N] Introduce re2j dependency (#17634)
PR-17605 - KAFKA-17873: Add description to all packages in the public API (#17605)
PR-17609 - KAFKA-17840 Move ReplicationQuotaManager, ClientRequestQuotaManager and QuotaFactory to server module (#17609)
PR-17622 - KAFKA-17867 Consider using zero-copy for PushTelemetryRequest (#17622)
PR-16922 - KAFKA-17411: Create local state Standbys on start (#16922)
PR-17616 - KAFKA-17128 Make node.id immutable after removing zookeeper migration (#17616)
PR-17623 - Update docker_scan.yml for 3.8.1 (#17623)
PR-17600 - KAFKA-17875: Align KRaft controller count recommendations (#17600)
PR-17091 - KAFKA-15344: Streams task should cache consumer nextOffsets (#17091)
PR-17035 - KAFKA-17439: Make polling for new records an explicit action/event in the new consumer (#17035)
PR-17270 - KAFKA-17329: DefaultStatePersister implementation (#17270)
PR-17502 - KAFKA-17793: Improve kcontroller robustness against long delays (#17502)
PR-17587 - KAFKA-14483 Move LocalLog to storage module (#17587)
PR-17602 - KAFKA-17878 Move ActionQueue to server module (#17602)
PR-17612 - KAFKA-17883 Fix jvm error caused by UseParNewGC when running old kafka client in e2e (#17612)
PR-17599 - KAFKA-17874: Fix the KRaft metric names in the documentation (#17599)
PR-17606 - KAFKA-17879 test_performance_services.py should use DEV version to run kafka service (#17606)
PR-17610 - KAFKA-17881 Apply the minJavaVersion to test code (#17610)
PR-17583 - KAFKA-17848: Fixing share purgatory request and locks handling (#17583)
PR-17597 - KAFKA-17868: Do not ignore –feature flag in kafka-storage.sh (#17597)
PR-16965 - KAFKA-16564 Apply Xlint to java code in core module (#16965)
PR-17592 - KAFKA-17863: share consumer max poll records soft limit (#17592)
PR-17089 - KAFKA-16845 Migrate ReplicationQuotasTestRig to new test infra (#17089)
PR-17578 - KAFKA-17847 Avoid the extra bytes copy when compressing telemetry payload (#17578)
PR-17586 - KAFKA-17854 Improve tests for ReadOnlyWindowStoreStub#fetch and #backwardFetch (#17586)
PR-17225 - KAFKA-17574 Allow overriding TestKitNodes baseDirectory (#17225)
PR-17570 - KAFKA-17846 ClientTelemetryReporter does not log trace-level message (#17570)
PR-1498 - [MINOR]: Fix version check in util.py
PR-1497 - [MINOR]: Fix version check in util.py
PR-17588 - KAFKA-17860 Remove log4j-appender module (#17588)
PR-17038 - KAFKA-17233: MirrorCheckpointConnector should use batched listConsumerGroupOffsets (#17038)
PR-17322 - KAFKA-17774: Adding capability to handle max fetch records in Share Fetch (KIP-932) (#17322)
PR-17246 - KAFKA-17568 Rewrite TestPurgatoryPerformance by Java (#17246)
PR-17424 - KAFKA-17614: Remove AclAuthorizer (#17424)
PR-17414 - KAFKA-17600: Add nextOffsets to the ConsumerRecords (#17414)
PR-17577 - KAFKA-17852 Add help message to the –ignore-formatted flag of StorageTool (#17577)
PR-17201 - KAFKA-17526 make ConfigCommandIntegrationTest.java test use correct arguments in testing alias (#17201)
PR-17519 - KAFKA-17813: Moving broker endpoint class and common server connection id (#17519)
PR-17556 - KAFKA-17839 DescribeConsumerGroupTest doesn’t really test different arguments (#17556)
PR-17566 - KAFKA-17844: Complete share fetch request on exception (#17566)
PR-17503 - KAFKA-17272 [2/2]: System tests for protocol migration (#17503)
PR-17521 - KAFKa-16331: remove EOSv1 support for getting clientInstanceIds (#17521)
PR-17504 - KAFKA-17794: Add some formatting safeguards for KIP-853 (#17504)
PR-17499 - KAFKA-17031: Make RLM thread pool configurations public and fix default handling (#17499)
PR-17534 - KAFKA-17545: Removing process fetch queue (#17534)
PR-17557 - KAFKA-17841 Use placeholders instead of string concatenation in logs (#17557)
PR-17409 - KAFKA-17639 Add Java 23 to CI build matrix (#17409)
PR-17550 - KAFKA-17818 add log4j.properties to test-common and test-common-api (#17550)
PR-17553 - KAFKA-17476 Delete kafka.common.OffsetAndMetadata (#17553)
57abfc24 - KAFKA-17838 Move the log4j.properties from resources/test to resources(#17551)
PR-17505 - KAKFA-17173 move quota config params from KafkaConfig to QuotaConfig (#17505)
PR-17543 - KAFKA-17832 Remove all EnabledForJreRange (#17543)
PR-17535 - KAFKA-17817 Remove cache from FetchRequest#fetchData (#17535)
PR-17536 - KAFKA-17827 cleanup the mockit version (#17536)
PR-17492 - KAFKA-17766: Fixing deadlock in TopicBasedRemoteLogMetadataManager (#17492)
PR-17475 - KAFKA-17099: Print the origin processor node in logs when a processing exception occurs (#17475)
PR-17435 - KAFKA-17740 Update Readme and documentation (#17435)
PR-17523 - KAFKA-17816 Add testRuntimeOnly runtimeTestLibs to test-common-api module (#17523)
8a1a5448 - Bump commonsIo to version 2.16.0 in master
PR-17437 - KAFKA-17742: Move DelayedShareFetchPurgatory declaration to ReplicaManager (#17437)
PR-17315 - KAFKA-17558: Remove parameterization from streams integration tests (#17315)
PR-17474 - KAFKA-17778: Add listener to remove client instances on connection disconnect (#17474)
PR-17512 - KAFKA-17802 Update Bouncy castle from 1.75 to 1.78.1 (#17512)
PR-17520 - KAFKA-17812 upgrade base image of e2e from JDK 11 to JDK 17 (#17520)
PR-17418 - KAFKA-17724 Move SubscriptionState changes to background thread (#17418)
PR-17385 - KAFKA-17710; Rework uniform heterogeneous assignor to improve perf (#17385)
PR-17484 - KAFKA-17677 Remove atomicGetOrUpdate (#17484)
PR-17397 - KAFKA-17767 Extract test catalog from JUnit output [1/n] (#17397)
PR-17473 - KAFKA-17776 Capability for connection disconnect listeners in socket server (#17473)
PR-17354 - KAFKA-17683 Remove Zookeeper from READMEs in 4.0 (#17354)
PR-17518 - KAFKA-17728 Add missing config replica-directory-id to raft README (#17518)
PR-16824 - KAFKA-17256 KRAFT should honor the listener name and security protocol from ClusterConfig (#16824)
PR-17513 - KAFKA-17805: Deprecate named topologies in Kafka Streams (#17513)
PR-17422 - KAFKA-17248: Override admin client to push metrics true, test for case where streams metrics [4/N] (#17422)
PR-17441 - KAFKA-17741 Cleanup code base for JDK 11 (#17441)
PR-17480 - KAFKA-17781 add psutil to e2e dockerfile and upgrade ducktape version (#17480)
PR-17483 - KAFKA-17773 Upgrade spotbug to work under java 23 (#17483)
PR-17411 - KAFKA-17536; Ensure clear error message when new consumer used with incompatible cluster (#17411)
5989c2b1 - Revert “KAFKA-17520 align the low bound of ducktape version (#17481)”
71839deb - Ignore failing quota_test
PR-17487 - KAFKA-15859: Complete delayed RemoteListOffsets requests when replica moves away from broker (#17487)
PR-17501 - KAFKA-17790: Document that control.plane.listener should be removed before ZK migration is finished (#17501)
796ce212 - KAFKA-17788: During ZK migration, always include control.plane.listener.name in advertisedBrokerListeners
PR-1438 - disable flakey test
PR-17450 - KAFKA-17756: Added dynamic share group configs share.heartbeat.interval.ms and share.session.timeout.ms (#17450)
PR-17467 - KAFKA-17633: Add share group record formatter and parser. (#17467)
PR-17497 - KAFKA-17748 Remove scala-java8-compat (#17497)
PR-17456 - KAFKA-17693 Remove testEarliestLocalTimestampVersion and testCheckLatestTieredTimestampVersion (#17456)
PR-17481 - KAFKA-17520 align the low bound of ducktape version (#17481)
PR-16964 - KAFKA-17374 add bootstrap.controller to kafka-reassign-partitions.sh (#16964)
PR-17479 - KAFKA-17765 Remove TestUtils.toSet (#17479)
PR-17451 - KAFKA-17746 Replace JavaConverters with CollectionConverters (#17451)
PR-17468 - KAFKA-17763 Remove Utils.covariantCast and use var for type inference (#17468)
PR-17439 - KAFKA-17722 Fix “this-escape” compiler warnings (BrokerTopicMetrics) for JDK 23 (#17439)
PR-17442 - KAFKA-17199 Add UT for TransactionLogConfig and TransactionStateManagerConfig (#17442)
PR-17458 - KAFKA-17717 Remove ConfigUtils#translateDeprecatedConfigs and tests (#17458)
PR-17417 - KAFKA-17723 Fix “this-escape” compiler warnings (MultiThreadedEventProcessor and DistributedHerder) for JDK 23 (#17417)
PR-17460 - KAFKA-17759 Remove Utils.mkSet (#17460)
PR-17466 - KAFKA-17772 Remove inControlledShutdownBrokers(Set<Integer>) and unfenceBrokers(Set<Integer>) from ReplicationControlManagerTest (#17466)
PR-17452 - KAFKA-17764 Remove unnecessary ignorable annotations (#17452)
PR-17461 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960) (#17461)
PR-17398 - KAFKA-17713: Don’t generate snapshot when published metadata is not batch aligned (#17398)
44f15cc2 - KAFKA-17749: Fix Throttler metrics name
PR-17283 - KAFKA-17620: Simplifying share partition acquire API (kip-932) (#17283)
PR-16387 - KAFKA-16972 Move BrokerTopicMetrics to org.apache.kafka.storage.log.metrics (#16387)
PR-17431 - KAFKA-17731: Removed timed waiting signal for client telemetry close (#17431)
PR-17430 - KAFKA-17749: Fix Throttler metrics name (#17430)
PR-17446 - KAFKA-17383; Update upgrade notes about removal of offsets.commit.required.acks (#17446)
PR-17413 - KAFKA-17534: Add configuration to disable the heartbeats topic replication (#17413)
PR-17426 - KAFKA-17739 Clean up build.gradle to adopt the minimum Java version as 11 (#17426)
PR-17331 - KAFKA-17532-2: Moved ShareGroupConfig and added share.record.lock.duration.ms to dynamic configs (#17331)
PR-17406 - KAFKA-17387 Remove broker-list in VerifiableConsumer (#17406)
PR-17432 - KAFKA-17738 upgrade base image from jdk8 to jdk11 (#17432)
PR-17427 - KAFKA-17737 E2E tests need to drop Kafka versions prior to 1.0.0 (#17427)
PR-17436 - KAFKA-17753: Update protobuf and commons-io dependencies (#17436)
PR-17434 - KAFKA-17751; fix pollTimeout calculation in pollFollowerAsVoter (#17434)
PR-17380 - KAFKA-17703: Moved DelayedActionsQueue outside DelayedShareFetch (#17380)
PR-17423 - KAFKA-16896 upgrade spotless version after we drop JDK8 (#17423)
PR-16881 - KAFKA-17005; Online protocol migration integration tests (#16881)
PR-17415 - KAFKA-17729: Remove ZK from AuthorizerBenchmark, CheckpointBench and PartitionCreationBench (#17415)
PR-17420 - KAFKA-14705 Remove deprecated classes and options in tools (#17420)
PR-17408 - KAFKA-17655 add example of changing the e2e image name (#17408)
PR-17410 - KAFKA-17720 Remove zookeeper_migration_test.py and migration-related functions in kafka.py (#17410)
PR-17421 - KAFKA-17735: release.py must not use home.apache.org (#17421)
PR-17344 - KAFKA-16331: Remove task producers from Kafka Streams (#17344)
PR-17230 - KAFKA-17505: New consumer seekToBeginning/End should run in background thread (#17230)
8ebb9d80 - Revert “MINOR: Ensure CI runs on weekends (#17396)”
PR-17368 - KAFKA-15908: Remove deprecated Consumer.poll(long timeout) (#17368)
PR-17009 - KAFKA-17287: Added integration tests for ShareConsumer (#17009)
PR-17360 - KAFKA-14158: Remove auto.include.jmx.reporter configuration (#17360)
PR-17400 - KAFKA-17714 Fix StorageToolTest.scala to compile under Scala 2.12 (#17400)
PR-17224 - KAFKA-17385 Remove authorizer, authorizer-properties, zk-tls-config-file in AclCommand (#17224)
PR-17338 - KAFKA-17624 Remove the E2E uses of accessing ACLs from zk (#17338)
PR-17330 - KAFKA-16331: Remove KafkaClientSupplier from unit tests (#17330)
PR-17377 - KAFKA-17248: Add reporter for getting client metrics into telemetry pipeline and test [3/N] (#17377)
PR-17395 - KAFKA-17709: Remove unused retry_zinc script (#17395)
PR-16770 - KAFKA-17146 Include note to remove migration znode (#16770)
PR-17379 - MINRO: fix stream-stream-join semantic example from 10s window to 15s (#17379)
PR-17392 - KAFKA-17711: Minor cleanup changes in ShareConsumeRequestManager (#17392)
PR-17386 - KAFKA-14705: Remove redirections and unused tools (#17386)
PR-17387 - KAFKA-14705: Move topic filters to tools module (#17387)
PR-17383 - KAFKA-17707 Remove zk from BaseConsumerTest (#17383)
PR-17157 - KAFKA-14577: Move ConsoleProducer to tools module (#17157)
PR-17306 - KAFKA-17317; Validate and maybe trigger downgrade after static member replacement (#17306)
PR-17281 - KAFKA-17618; group consumer heartbeat interval should be less than session timeout (#17281)
PR-17228 - KAFKA-17564 Move BrokerFeatures to server module (#17228)
PR-17332 - KAFKA-17664: Added check before sending background event after ShareAcknowledge (#17332)
PR-17364 - KAFKA-17695 cleanup org.apache.kafka.common.test.TestUtils (#17364)
PR-17202 - KAFKA-17529 Remove blacklist from MM2 (#17202)
PR-17372 - KAFKA-17692 Remove KafkaServer references from IntegrationTestUtils (#17372)
PR-17026 - KAFKA-17415 Avoid overflow of expired timestamp (#17026)
PR-17313 - KAFKA-12895 Drop support for Scala 2.12 in Kafka 4.0 (#17313)
PR-17329 - KAFKA-17672 Run quarantined tests separately (#17329)
PR-17378 - KAFKA-17706 Allow all imports for test-common and test-common-api (#17378)
PR-17376 - KAFKA-17248: Add reporter for adding thread metrics to telemetry pipeline and a test [2/N] (#17376)
PR-17260 - KAFKA-17542: Automatically label small PRs (#17260)
PR-17362 - KAFKA-16308 [4/4]: Add release-version flag to upgrade and downgrade commands (#17362)
PR-17375 - KAFKA-17248: KIP-1076 add admin client test helper [1/N] (#17375)
PR-17177 - KAFKA-17509: Introduce a delayed action queue to complete purgatory actions outside purgatory. (#17177)
PR-17363 - KAFKA-16927; Handle expanding leader endpoints (#17363)
PR-17358 - KAFKA-15859: Fix the Unsupported version error when new admin connects to old broker (#17358)
PR-17325 - KAFKA-16106; Schedule timeout task to refresh classic group size metric (#17325)
PR-17335 - KAFKA-17428: Add retry mechanism for cleaning up dangling remote segments (#17335)
PR-17168 - KAFKA-17525 Convert the UnknownServerException to InvalidRequestException when altering client-metrics config at runtime (#17168)
PR-17356 - KAFKA-17658 Move BootstrapControllersIntegrationTest to kafka.server (#17356)
PR-17350 - KAFKA-17684 Update our java build versions (#17350)
PR-15995 - KAFKA-16469: Metadata schema checker (#15995)
PR-17293 - KAFKA-17613: Remove ZK migration code (#17293)
PR-17355 - KAFKA-17685 Define common testRuntimeOnly dependencies (#17355)
PR-15838 - KAFKA-16649: Remove lock from DynamicBrokerConfig.removeReconfigurable (#15838)
PR-17349 - KAFKA-17469: Move persister related classes to persister pkg. (#17349)
PR-17342 - KAFKA-17674: Fix bug on update positions of newly added partitions (#17342)
PR-17320 - KAFKA-17451 Remove deprecated consumer#committed (#17320)
PR-17312 - KAFKA-17511 Move ElectLeadersRequestOps to ElectLeadersRequest (#17312)
PR-17279 - KAFKA-17500: Metadata redirection for NOT_LEADER_OR_FOLLOWER (#17279)
PR-16843 - KAFKA-17285 Consider using Utils.closeQuietly to replace CoreUtils.swallow when handling Closeable objects (#16843)
PR-17318 - KAFKA-17589 Move JUnit extensions to test-common module (#17318)
PR-17346 - KAFKA-17680 Add timeout to streams test teardown (#17346)
PR-17251 - KAFKA-16974 KRaft support in SslAdminIntegrationTest (#17251)
PR-17311 - KAFKA-17258 Migrate AdminFenceProducersIntegrationTest to ClusterTestExtensions framework (#17311)
PR-17149 - KAFKA-17367: Share coordinator persistent batch merging algorithm. [3/N] (#17149)
PR-17282 - KAFKA-16733: Add share group record support to OffsetsMessageParser (#17282)
PR-17317 - KAFKA-17657 Replace the consumer-fetch-manager-metrics by groupName (#17317)
PR-16443 - KAFKA-16308 [3/N]: Introduce feature dependency validation to UpdateFeatures command (#16443)
PR-17323 - KAFKA-16769 Remove add.source.alias.to.metrics configuration (#17323)
PR-17336 - KAFKA-17673 Switch back to statuses API (#17336)
PR-17334 - KAFKA-17656 Replace string concatenation with parameterized logging for PartitionChangeBuilder (#17334)
PR-17204 - KAFKA-17540: Create script for updating a reference of latest cached trunk commit (#17204)
PR-17280 - KAFKA-17606: Include Rat errors in GitHub workflow summary (#17280)
PR-1436 - disable flakey test
PR-16522 - KAFKA-17078: Add SecurityManagerCompatibility shim (#16522)
PR-17304 - KAFKA-17634 Tweak wakeup logic to match WakeupTrigger changes (#17304)
PR-17209 - KAFKA-17109: Move lock backoff retry to streams TaskManager (#17209)
PR-17132 - KAFKA-17498: Reduce the number of remote calls when serving LIST_OFFSETS request (#17132)
PR-17314 - KAFKA-17653 Update Scala version to 2.13.15 for support Java 23 (#17314)
PR-17263 - KAFKA-17473 Speed Up ClientTelemetryTest (#17263)
PR-16761 - KAFKA-12823 Remove Deprecated method KStream#through (#16761)
PR-17215 - KAFKA-6197: Update Streams API and Javadoc references in documentation (#17215)
PR-17305 - KAFKA-17636 Fix missing SCRAM bootstrap records (#17305)
PR-17016 - KAFKA-14572: Migrate EmbeddedKafkaCluster used by Streams integration tests from EmbeddedZookeeper to KRaft (#17016)
PR-17284 - KAFKA-17619: Remove zk type and instance from ClusterTest (#17284)
PR-17244 - KAFKA-17581: AsyncKafkaConsumer can’t unsubscribe invalid topics (#17244)
PR-17289 - KAFKA-17626: Move common fetch related classes from storage to server-common (#17289)
PR-17290 - KAFKA-17628 New workflows for automating run approvals (#17290)
PR-17259 - KAFKA-16331: remove KafkaClientSupplier from StreamsProducer (#17259)
PR-17182 - KAFKA-17488: Cleanup (test) code for Kafka Streams “metric version” (#17182)
PR-17093 - KAFKA-17277: [2/2] Add feature dependency command to the storage and the feature command tool (#17093)
PR-16912 - KAFKA-16683 Extract security-related helpers from scala.TestUtils to java class (#16912)
PR-17165 - KAFKA-17154: New consumer subscribe may join group without a call to consumer.poll (#17165)
PR-17223 - KAFKA-17563 Move RequestConvertToJson to server module (#17223)
PR-17146 - KAFKA-17608, KAFKA-17604, KAFKA-16963; KRaft controller crashes when active controller is removed (#17146)
PR-17081 - KAFKA-16963: Ducktape test for KIP-853 (#17081)
PR-17288 - KAFKA-17621; Reduce logging verbosity on ConsumerGroupHeartbeat path (#17288)
PR-16719 - KAFKA-14562 [1/2]: Implement epoch bump after every transaction (#16719)
PR-16982 - KAFKA-16792: Enable consumer unit tests that fail to fetch offsets only for new consumer with poll(0) (#16982)
PR-17276 - KAFKA-17612 Remove some tests that only apply to ZK mode or migration (#17276)
PR-17274 - KAFKA-17571; Revert “MINOR: Log pending join members (#17219)” (#17274)
PR-17277 - KAFKA-17496: Add heterogeneous case to TargetAssignmentBuilderBenchmark (#17277)
PR-17258 - KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258)
PR-17112 - KAFKA-15859: Add timeout field to the ListOffsets request (#17112)
PR-17163 - KAFKA-17057: Add RETRY option to ProductionExceptionHanlder (#17163)
PR-17265 - KAFKA-14563: add feature version supports in the producers and ApiVersions (#17265)
PR-17231 - KAFKA-16908 Refactor QuorumConfig with AbstractConfig (#17231)
PR-17240 - KAFKA-17520 Align ducktape version in tests/docker/Dockerfile and tests/setup.py (#17240)
PR-17267 - KAFKA-17602 Remove ConfigUtils.translateDeprecatedConfigs from JmxReporter (#17267)
PR-17222 - KAFKA-17087 Deprecate delete-config of TopicCommand (#17222)
PR-17257 - KAFKA-17592; Support for SubscribedTopicsRegex in ConsumerGroupHeartbeat RPC (#17257)
PR-17233 - KAFKA-17578: Remove partitionRacks from TopicMetadata (#17233)
PR-17193 - KAFKA-17076: retain last batch in each round of cleaning (#17193)
PR-17080 - KAFKA-17465 Refactor getMembersFromGroup to be non-blocking (#17080)
PR-17252 - KAFKA-17585 offsetResetStrategyTimestamp should return long instead of Long (#17252)
PR-17174 - KAFKA-17512 Move LogSegmentTest to storage module (#17174)
PR-17237 - KAFKA-17530 Remove blacklist/whitelist from ReplaceField (#17237)
PR-17262 - KAFKA-17469: Moved share external interfaces to share module. (#17262)
PR-17250 - KAFKA-17459 Stablize reassign_partitions_test.py (#17250)
PR-17253 - Update zstd-jni lib (#17253)
PR-17133 - KAFKA-17495: Factor out assignor benchmark code into utils class (#17133)
PR-17226 - KAFKA-17575 Remove unnecessary file.deleteOnExit call (#17226)
PR-17212 - KAFKA-16331 remove EOSv1 from StreamsProducer (#17212)
PR-17179 - KAFKA-17528 Remove whitelist/blacklist from JMXReporter (#17179)
PR-17170 - KAFKA-16331: remove EOSv1 config from StreamsConfig (#17170)
PR-17234 - KAFKA-17567 Remove TestTruncate (#17234)
PR-16957 - KAFKA-16813 Add global timeout (60s) for @ClusterTemplate, @ClusterTest and @ClusterTests (#16957)
PR-17208 - KAFKA-17542: Use actions/labeler for automatic PR labeling (#17208)
PR-17211 - KAFKA-17356 add integration test for KAFKA-17310 (#17211)
PR-17220 - KAFKA-17555 uncomment all checks of testCommonNameLoggingTrustManagerMixValidAndInvalidCertificates (#17220)
14c45bed - KAFKA-17579: Dynamic LogCleaner configurations are picked up on restart
PR-17210 - KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)
PR-17117 - KAFKA-17472 Speed Up DescribeConsumerGroupTest (#17117)
PR-17218 - Revert “KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)” (#17218)
PR-17042 - KAFKA-14482 Move LogLoader to storage module (#17042)
PR-17110 - KAFKA-16331 Remove EOSv1 from Kafka Streams integration tests (#17110)
PR-16867 - KAFKA-17322: Document required header versions in Protocol Guide (#16867)
PR-17122 - KAFKA-17494: Document message structure in Protocol Guide (#17122)
PR-16602 - KAFKA-15859 Make RemoteListOffsets call an async operation (#16602)
PR-16885 - KAFKA-17066 new consumer updateFetchPositions all in background thread (#16885)
PR-17083 - KAFKA-16027: Refactor testUpdatePartitionLeadership (#17083)
PR-17173 - KAFKA-17513 Move LogSegmentsTest to storage module (#17173)
PR-17192 - KAFKA-17543: Enforce that broker.id.generation.enable is not used when migrating to KRaft (#17192)
PR-17194 - Update to 4.1.0 of setup-gradle action (#17194)
PR-16213 - KAFKA-16681 Rewrite MiniKDC by Java (#16213)
PR-16493 - KAFKA-17036 KIP-919 supports for createAcls, deleteAcls, describeAcls (#16493)
PR-17159 - KAFKA-16468: verify that migrating brokers provide their inter.broker.listener (#17159)
PR-17154 - KAFKA-17508: Adding some guard for fallback deletion logic (#17154)
PR-17136 - KAFKA-17502: Modified commitSync() and close() handling in clients (#17136)
PR-17115 - KAFKA-17489: Do not handle failed tasks as tasks to assign (#17115)
PR-17082 - KAFKA-12601 Remove deprecated delegation.token.master.key (#17082)
PR-17180 - KAFKA-17524: Add timeout to StreamThreadTest (#17180)
PR-17171 - KAFKA-17427: Deprecate leaking *_DOC variables in StreamsConfig (#17171)
PR-17164 - KAFKA-17253: Deprecate Leaking Getter Methods in Joined Helper Class (#17164)
PR-17172 - KAFKA-17410: Disable testPollThrowsInterruptExceptionIfInterrupted for AsyncConsumer (#17172)
PR-17059 - KAFKA-12829: Remove deprecated StreamsBuilder#addGlobalStore of old Processor API (#17059)
PR-17145 - KAFKA-8666: Improve Documentation on usage of Materialized config object (#17145)
PR-17126 - KAFKA-16332 Remove Deprecated builder methods for Time/Session/Join/SlidingWindows (#17126)
PR-17166 - KAFKA-15073 Close stale PRs [2/n] (#17166)
PR-16969 - KAFKA-17400: Added share fetch purgatory for delaying share fetch requests (#16969)
PR-17075 - KAFKA-17448: New consumer seek should update positions in background thread (#17075)
PR-17137 - KAFKA-17231 Add missing node latency metrics (#17137)
PR-17138 - KAFKA-17392 Remove whitelist option in ConsoleConsumerOptions (#17138)
PR-17046 - KAFKA-17347 Add missing client-metrics option to kafka-configs.sh (#17046)
PR-17116 - KAFKA-17109: implement exponential backoff for state directory lock (#17116)
PR-16916 - KAFKA-17290: Added Integration tests for ShareFetch and ShareAcknowledge APIs (#16916)
PR-17027 - KAFKA-17435 remove use.incremental.alter.configs (#17027)
PR-17124 - KAFKA-14995: Automate asf.yaml collaborators refresh (#17124)
PR-17108 - KAFKA-16331: Remove EOSv1 from Kafka Streams system tests (#17108)
PR-17004 - KAFKA-15793 Fix ZkMigrationIntegrationTest#testMigrateTopicDeletions (#17004)
PR-17084 - KAFKA-17458 Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py (#17084)
PR-17128 - KAFKA-17492 skip features with minVersion of 0 instead of replacing 0 with 1 when BrokerRegistrationRequest < 4 (#17128)
PR-17129 - KAFKA-17224 Make ForeachProcessor internal (#17129)
PR-16898 - KAFKA-17306; Soften the validation when replaying tombstones (#16898)
PR-17135 - KAFKA-17311 Add groupProtocol parameter to testClientInstanceId, testClientInstanceIdInvalidTimeout, and testClientInstanceIdNoTelemetryReporterRegistered (#17135)
PR-17071 - KAFKA-17418: Improve markdown formatting in junit.py (#17071)
PR-17114 - KAFKA-17491: Move BrokerServerMetrics to server module (#17114)
PR-17127 - KAFKA-16830 Remove the scala version formatters support (#17127)
PR-17044 - KAFKA-14772; Add ConsumerGroupHeartbeat and ConsumerGroupDescribe API to AuthorizerIntegrationTest (#17044)
PR-16896 - KAFKA-17349 Make sure all IT have “quorum” input arguments (#16896)
PR-17131 - KAFKA-17497 Add e2e for zk migration with old controller (#17131)
PR-17011 - KAFKA-17367: Introduce share coordinator [2/N] (#17011)
PR-17109 - KAFKA-17470: CommitRequestManager should record failed request only once even if multiple errors in response (#17109)
PR-17097 - KAFKA-17482: Make share partition initialization async (KIP-932) (#17097)
PR-16127 - KAFKA-17477 Migrate TopicCommand test to new test infra (#16127)
PR-17125 - KAFKA-13588 We should consolidate changelogFor methods to simplify the generation of internal topic names (#17125)
PR-16676 - KAFKA-17137 Ensure Admin APIs are properly tested (topic-related) (#16676)
PR-16868 - KAFKA-17323 Document UINT16 and COMPACT_RECORDS in Protocol Guide (#16868)
PR-17005 - KAFKA-16863 : Deprecate default exception handlers (#17005)
PR-16505 - KAFKA-14460: Skip removed entries from in-memory KeyValueIterator (#16505)
PR-17121 - KAFKA-17479 Fail the whole pipeline if junit step times out [4/n] (#17121)
PR-17106 - KAFKA-17479 Fix ignoreFailures logic in CI workflow [3/n] (#17106)
PR-17118 - KAFKA-15648 Update leader volatile before handleLeaderChange in LocalLogManager (#17118)
PR-17094 - KAFKA-17457 Don’t allow ZK migration to start without transactions (#17094)
PR-17096 - KAFKA-17483: Complete pending share fetch requests on broker close (#17096)
PR-17098 - KAFKA-17479 Relocate junit XML files [2/n] (#17098)
PR-17054 - KAFKA-16448: Add timestamp to error handler context (#17054)
PR-17090 - KAFKA-16188: Delete kafka.common.MessageReader (#17090)
PR-17066 - KAFKA-17479 Allow “:jar” tasks to be cached [1/n] (#17066)
PR-16967 - KAFKA-17406: Move ClientIdAndBroker to server-common module (#16967)
PR-16986 - KAFKA-17414 Move RequestLocal to server-common module (#16986)
PR-17067 - KAFKA-17454 Fix failed transactions_mixed_versions_test.py when running with 3.2 (#17067)
PR-17078 - KAFKA-17474 fix state transition in GlobalStreamThread (#17078)
PR-16717 - KAFKA-17137 Ensure Admin APIs are properly tested (consumer group and quota) (#16717)
PR-17051 - KAFKA-17412: add doc for unclean.leader.election.enable in KRaft (#17051)
PR-16973 - KAFKA-17277: [1/2] Add version mapping command to the storage tool and feature command tool (#16973)
PR-16517 - KAFKA-16928: Test all of the request and response methods in RaftUtil (#16517)
PR-17039 - KAFKA-17425: Improve coexistence of consumer and share groups (#17039)
PR-17074 - KAFKA-17468 Move kafka/log/remote/quota classes to storage module (#17074)
PR-17045 - KAFKA-15859 Introduce remote.list.offsets.request.timeout.ms dynamic config (#17045)
PR-16833 - KAFKA-17294 Handle retriable errors when fetching offsets in new consumer (#16833)
PR-16665 - KAFKA-15853 Move TransactionLogConfig and TransactionStateManagerConfig getters out of KafkaConfig (#16665)
PR-17015 - KAFKA-17430: Move RequestChannel.Metrics/RequestMetrics to server module (#17015)
PR-17061 - KAFKA-17450 Reduced the handlers for handling ShareAcknowledgeResponse (#17061)
PR-16905 - KAFKA-17137 Ensure Admin APIs are properly tested (token-related) (#16905)
PR-16956 - KAFKA-17442: Handled persister errors with write async calls (KIP-932) (#16956)
PR-16864 - KAFKA-17320 Move SensorAccess to server-common module (#16864)
PR-17069 - KAFKA-17461 move the .github/README.md to .github/workflows/README.md (#17069)
PR-16844 - KAFKA-17293: New consumer HeartbeatRequestManager should rediscover disconnected coordinator (#16844)
PR-16873 - KAFKA-17331 Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec (#16873)
PR-17028 - KAFKA-17437 Upgrade commons-validator from 1.7 to 1.9.0 (#17028)
PR-17023 - KAFKA-12826: Remove Deprecated Class Serdes (#17023)
PR-17060 - KAFKA-17449 Move Quota classes to server-common module (#17060)
PR-16648 - KAFKA-17137 Feat admin client it acl configs (#16648)
PR-17019 - KAFKA-17433 Add a deflake Github action (#17019)
PR-16933 - KAFKA-15909 Throw error when consumer configured with empty/whitespace-only group.id for LegacyKafkaConsumer (#16933)
PR-16983 - KAFKA-17386 Remove broker-list, threads and num-fetch-threads in ConsumerPerformance (#16983)
PR-16744 - KAFKA-16327: Removed Deprecated variable StreamsConfig#TOPOLOGY_OPTIMIZATION (#16744)
PR-17030 - KAFKA-17377: Consider using defaultApiTimeoutMs in AsyncKafkaConsumer#unsubscribe (#17030)
PR-16791 - KAFKA-12829: Remove deprecated Topology#addGlobalStore of old Processor API (#16791)
PR-16778 - KAFKA- 12834 : Removed Deprecated method under MockProcessorContext (#16778)
PR-16673 - KAFKA-17064: New consumer assign should update assignment in background thread (#16673)
PR-17024 - KAFKA-17434: Do not test impossible scenarios in upgrade_test.py (#17024)
PR-16992 - KAFKA-17390 Remove broker-list in GetOffsetShell (#16992)
PR-16958 - KAFKA-17388 Remove broker-list from VerifiableProducer (#16958)
PR-16694 - KAFKA-17170: Add test to ensure new consumer acks reconciled assignment even if first HB with ack lost (#16694)
PR-17013 - KAFKA-17413; Re-introduce group.version feature flag (#17013)
PR-16959 - KAFKA-17062: handle dangling “copy_segment_start” state when deleting remote logs (#16959)
PR-16906 - KAFKA-12829: Remove the deprecated method init(ProcessorContext, StateStore) from the StateStore interface (#16906)
PR-16866 - KAFKA-12670: Support configuring unclean leader election in KRaft (#16866)
PR-16620 - KAFKA-15746: KRaft support in ControllerMutationQuotaTest (#16620)
PR-16904 - KAFKA-15406: Add the ForwardingManager metrics from KIP-938 (#16904)
PR-17017 - KAFKA-17426; Check node directory id for KRaft (#17017)
PR-17018 - KAFKA-17432: Fix threads alive after shutdown (#17018)
PR-17012 - KAFKA-17422: Adding copySegmentLatch countdown after expiration task is over (#17012)
PR-16879 - KAFKA-14262 Deletion of MirrorMaker v1 deprecated classes & tests (#16879)
PR-16974 - KAFKA-17403 Generate HB to leave on pollOnClose if needed (#16974)
PR-16955 - KAFKA-17396: Fix releasing session on final epoch (#16955)
PR-17003 - KAFKA-16972: Move BrokerTopicStats to storage module (#17003)
PR-16887 - KAFKA-17327; Add support of group in kafka-configs.sh (#16887)
PR-16644 - KAFKA-17038 KIP-919 supports for alterPartitionReassignments and listPartitionReassignments (#16644)
PR-16963 - KAFKA-17341 Refactor consumer heartbeat request managers (#16963)
PR-16985 - KAFKA-16330: Remove deprecated methods of TaskId and make deprecated members private (#16985)
PR-15482 - KAFKA-16335: Remove deprecated method of StreamPartitioner (#15482)
12506862 - reconcile develocity changes
PR-16921 - KAFKA-17367: Share coordinator infra classes [1/N] (#16921)
PR-17000 - KAFKA-17382 cleanup out-of-date configs of config_property (#17000)
PR-16980 - KAFKA-17399 Apply LambdaValidator to code base (#16980)
PR-16878 - KAFKA-17324: Set config group.protocol to classic in Streams (#16878)
PR-16987 - KAFKA-17373 Add print.epoch to kafka-console-share-consumer.sh/kafka-console-consumer.sh (#16987)
PR-16998 - KAFKA-17416 Add a checkstyle rule to suppress all generated code (#16998)
PR-16945 - KAFKA-14048; [2/2] Use the new group coordinator by default in 4.0 (#16945)
PR-16914 - KAFKA-17100: GlobalStreamThread#start should not busy-wait (#16914)
PR-16932 - KAFKA-17360 local log retention ms/bytes “-2” is not treated correctly (#16932)
PR-16876 - KAFKA-17331 Set correct version for EarliestLocalSpec and LatestTieredSpec (#16876)
PR-16981 - KAFKA-12824 Delete unused doBranch method (#16981)
PR-16858 - KAFKA-17315 Fix the behavior of delegation tokens that expire immediately upon creation in KRaft mode (#16858)
PR-16979 - KAFKA-17409 Remove deprecated constructor of org.apache.kafka.clients.producer.RecordMetadata (#16979)
PR-16949 - KAFKA-16379; Coordinator event queue, processing, flush, purgatory time histograms (#16949)
PR-16920 - KAFKA-17291: Add integration test for share group list and describe (#16920)
PR-16960 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960)
PR-16625 - KAFKA-17112: Manually stop task manager if stream thread is not in CREATED state (#16625)
PR-16762 - KAFKA-16329: Remove deprecated IQ metadata classes in Kafka Streams (#16762)
c7f0ade7 - KAFKA-16334: Remove –bootstrap-servers from kafka-streams-application-reset
PR-16941 - KAFKA-17371: Fix DefaultTaskExecutorTest.shouldUnassignTaskWhenRequired (#16941)
PR-16935 - KAFKA-17372 Move ThrottledChannelExpirationTest#testThrottledChannelDelay and ThrottledChannel to server module (#16935)
PR-16764 - KAFKA-16333: remove deprecated join method with named param (#16764)
PR-16893 - KAFKA-17336 Add IT to make sure the production MV does not use unstable version of LIST_OFFSET (#16893)
PR-16943 - KAFKA-17370 Move LeaderAndIsr to metadata module (#16943)
PR-1427 - CONFLUENT: Update service.yml
PR-16850 - KAFKA-16324 Move BrokerApiVersionsCommand to tools (#16850)
PR-16942 - KAFKA-17378 Fixes for performance testing (#16942)
PR-16848 - KAFKA-17305; Check broker registrations for missing features (#16848)
PR-16900 - KAFKA-17333; ResignedState should not notify of leader change (#16900)
PR-16937 - KAFKA-14048; [1/N] Use the new group coordinator by default in 4.0 (#16937)
PR-16934 - KAFKA-17279: Handle retriable errors from offset fetches (#16826) (#16934)
PR-16661 - KAFKA-17151 Remove waitForCondition when detecting thread leak (#16661)
PR-16938 - KAFKA-16736 Remove offsets.commit.required.acks in 4.0 (#16938)
PR-16659 - KAFKA-17169: Add EndpointsTest (#16659)
PR-16658 - KAFKA-17137 Ensure Admin APIs are properly tested (#16658)
PR-16826 - KAFKA-17279: Handle retriable errors from offset fetches (#16826)
PR-16903 - KAFKA-17325: Updated result handling in ShareConsumeRequestManager::commitAsync(). (#16903)
PR-16897 - KAFKA-17350: Improve share group describe for empty groups (#16897)
PR-16646 - KAFKA-16900 kafka-producer-perf-test reports error when using transaction. (#16646)
PR-16707 - KAFKA-17181 Replace fileChannel.write with Utils.writeFully to prevent partial write (#16707)
PR-16803 - KAFKA-12824 Remove Deprecated method KStream#branch (#16803)
PR-16907 - KAFKA-17332; Controller always flush and can call resign on observers (#16907)
PR-12782 - KAFKA-14336: MetadataResponse#convertToNodeArray uses iteration (#12782)
PR-16924 - KAFKA-17369: Remove Reflections from logging and update licenses (#16924)
PR-16908 - KAFKA-17180 Upgrade gradle from 8.8 to 8.10 (#16908)
PR-16925 - KAFKA-17368 Add delivery count to kafka-console-share-consumer.sh (#16925)
PR-16888 - KAFKA-17346: Create :share Gradle module (#16888)
PR-16913 - KAFKA-17357 Replace the deprecated retry.maxRetries / retry.maxFailures` (#16913)
PR-16604 - KAFKA-15203: Use Classgraph since org.reflections is no longer under maintenance (#16604)
PR-16849 - KAFKA-12989 MockClient should respect the request matcher passed to prepareUnsupportedVersionResponse (#16849)
PR-16890 - KAFKA-16749: [Minor] Addressed additional review comments (#16890)
PR-16877 - KAFKA-17330: New share-coordinator module. Added record schemas. (#16877)
PR-16911 - KAFKA-17086 add missing Java 21 to ops.html (#16911)
PR-16883 - KAFKA-17342 Moved common coordinator code to separate module (#16883)
PR-16901 - Make TestFeatureVersion 2 always map to MetadataVersion.latestTesting (#16901)
PR-16902 - KAFKA-17352 Migrate from Gradle Enterprise Gradle Plugin to Develocity Gradle Plugin (#16902)
PR-16892 - KAFKA-16842; Fix config validation and support unknown voters (#16892)
PR-16894 - KAFKA-16753: [MINOR] Addressing additional review comments (#16894)
PR-16823 - KAFKA-17283: Integration test for share group heartbeat (#16823)
PR-16860 - KAFKA-16723 : Added kafka-console-share-consumer.sh tool. (#16860)
PR-16891 - KAFKA-16752: [MINOR] Addressed additional review comments (#16891)
PR-16875 - KAFKA-16818 Move event processing-related tests from ConsumerNetworkThreadTest to ApplicationEventProcessorTest (#16875)
PR-16775 - KAFKA-17238 Move VoterSet and ReplicaKey from raft.internals to raft (#16775)
PR-16872 - KAFKA-17318 ConsumerRecord.deliveryCount and remove deprecations (#16872)
PR-16870 - KAFKA-17326 The LIST_OFFSET request is removed from the “Api Keys” page (#16870)
PR-16862 - KAFKA-17304; Make RaftClient API for writing to log explicit (#16862)
PR-16845 - KAFKA-17272: [1/2] System test framework for consumer protocol migration (#16845)
PR-16859 - KAFKA-14510; Extend DescribeConfigs API to support group configs (#16859)
PR-16835 - KAFKA-16714: kafka-share-groups.sh list and describe (#16835)
PR-16832 - KAFKA-17239 add request-latency metrics for node in admin client (#16832)
PR-16786 - KAFKA-17247 Revised share group record schemas (#16786)
PR-16579 - KAFKA-16682 Rewrite JaasTestUtils by Java (#16579)
PR-16167 - KAFKA-16689 Move LogValidatorTest to storage module (#16167)
PR-16865 - KAFKA-17319 change ListOffsetsRequest latestVersionUnstable to false (#16865)
PR-16836 - KAFKA-17300: Add document for new tiered storage feature in v3.9.0. (#16836)
PR-16863 - Kafka 16887 : Upgrade the document to add remote copy/fetch quotas metrics values. (#16863)
PR-16847 - KAFKA-17292: Introduce share coordinator protocol config (#16847)
PR-16838 - KAFKA-17303 Enable testPutControllersInBootstrapBrokersConfig (#16838)
PR-16841 - KAFKA-17018: update MetadataVersion for the Kafka release 3.9 (#16841)
PR-16672 - KAFKA-17190: AssignmentsManager gets stuck retrying on deleted topics (#16672)
PR-16792 - KAFKA-16746: Implemented handleShareAcknowledgeRequest RPC including unit tests (#16792)
PR-16846 - KAFKA-17289: ShareGroupDescribe integration test (#16846)
PR-16856 - KAFKA-17310 locking the offline dir can destroy the broker exceptionally (#16856)
PR-15067 - KAFKA-14511; Extend AlterIncrementalConfigs API to support group config (#15067)
PR-16592 - KAFKA-17056 Convert producer state metadata schemas to use generated protocol (#16592)
PR-16821 - KAFKA-17270 Let test code use Exit.java rather than Exit.scala (#16821)
PR-16828 - KAFKA-17288 Removed tracking partition member epoch (KIP-932) (#16828)
PR-16855 - KAFKA-17297 stabalize testHandleEndQuorumRequest (#16855)
PR-16857 - KAFKA-17312 Fix tests shouldForwardAllDbOptionsCalls and shouldOverwriteAllOptionsMethods in RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest (#16857)
PR-16687 - KAFKA-17137 Add integration tests for admin client (createPartitions and quota) (#16687)
PR-16822 - KAFKA-17273 Migrate BootstrapControllersIntegrationTest to use ClusterTestExtensions (#16822)
PR-16790 - KAFKA-17035 Add debug log to retention cleanupLogs method to help troubleshoot issues (#16790)
PR-16820 - KAFKA-17067; Fix KRaft transition to CandidateState (#16820)
PR-16777 - KAFKA-17240 Try to complete delyed ops for all purgatories even though one of delayed op throws exception (#16777)
PR-16805 - KAFKA-16328 Remove Deprecated config from StreamsConfig (#16805)
PR-16751 - KAFKA-17225: Refactor consumer membership managers (#16751)
PR-16809 - KAFKA-12830: Remove Deprecated constructor in TimeWindowedDeserializer and TimeWindowedSerde (#16809)
PR-16813 - KAFKA-12832 remove deprecated methods in RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter (#16813)
PR-16800 - KAFKA-17228; Static member using new protocol should always replace the one using the old protocol (#16800)
PR-16825 - KAFKA-17267; Don’t return REQUEST_TIMED_OUT for OFFSET_FETCHes (#16825)
PR-16837 - KAFKA-16534; Implemeent update voter sending (#16837)
PR-16774 - KAFKA-16523; kafka-metadata-quorum: support add-controller and remove-controller (#16774)
PR-16753 - KAFKA-17223 Retrying the call after encoutering UnsupportedVersionException will cause ConcurrentModificationException (#16753)
PR-16817 - KAFKA-17269 Fix ConcurrentModificationException caused by NioEchoServer.closeNewChannels (#16817)
PR-16807 - KAFKA-15875: Stops leak Snapshot in public methods (#16807)
PR-16830 - KAFKA-16521: Have Raft endpoints printed as name://host:port (#16830)
PR-16727 - KAFKA-17217: Batched acknowledge requests per node in ShareConsumeRequestManager (#16727)
PR-16773 - KAFKA-17242: Do not log spurious timeout message for MirrorCheckpointTask sync store startup (#16773)
PR-16767 - KAFKA-17232: Do not generate task configs in MirrorCheckpointConnector if initial consumer group load times out (#16767)
PR-16814 - KAFKA-17275: Move ReplicatedCounter to test scope (#16814)
PR-16765 - KAFKA-17236: Handle local log deletion when remote.log.copy.disabled=true (#16765)
PR-16819 - KAFKA-17276; replicaDirectoryId for Fetch and FetchSnapshot should be ignorable (#16819)
PR-16827 - KAFKA-16716: Add admin list and describe share groups (#16827)
PR-16797 - KAFKA-16742: Add share group describe in coordinator (KIP-932) (#16797)
PR-16747 - KAFKA-12828: Removed Deprecated methods under KeyQueryMetadata (#16747)
PR-16709 - KAFKA-16584: Make log processing summary configurable or debug–update upgrade-guide (#16709)
PR-16752 - KAFKA-17222 Remove the subclass of KafkaMetricsGroup (#16752)
PR-16652 - KAFKA-17137 Add integration tests for admin client (Transaction and UserScramCredentials related) (#16652)
PR-16456 - KAFKA-16745: Implemented handleShareFetchRequest RPC including unit tests (#16456)
PR-16795 - KAFKA-17262 Improve kafka-topics usage message (#16795)
PR-16782 - KAFKA-17227: Refactor compression code to only load codecs when used (#16782)
PR-16789 - KAFKA-17235 system test test_performance_service.py failed (#16789)
81edb74c - KAFKA-16533; Update voter handling
PR-16669 - KAFKA-16518: Implement KIP-853 flags for storage-tool.sh (#16669)
e49c8df1 - KAFKA-16533; Update voter handling
PR-16723 - KAFKA-17201 SelectorTest.testInboundConnectionsCountInConnectionCreationMetric leaks sockets and threads (#16723)
PR-16763 - KAFKA-17227: Update zstd-jni lib (#16763)
PR-16783 - KAFKA-16154: Broker returns offset for LATEST_TIERED_TIMESTAMP (#16783)
PR-16745 - KAFKA-16448: Unify error-callback exception handling (#16745)
PR-16653 - KAFKA-16855: remote log disable policy in KRaft (#16653)
PR-16693 - KAFKA-17205: Allow topic config validation in controller level in KRaft mode (#16693)
PR-16781 - KAFKA-16480: ListOffsets change should have an associated API/IBP version update (#16781)
PR-16780 - KAFKA-17245: Revert TopicRecord changes. (#16780)
PR-16715 - KAFKA-16390: add group.coordinator.rebalance.protocols=classic,consumer to broker configs when system tests need the new coordinator (#16715)
PR-16742 - KAFKA-9738: Deprecate old Processor API (#16742)
PR-16776 - KAFKA-16448: Update documentation (#16776)
PR-16748 - KAFKA-16666 Migrate GroupMetadataMessageFormatter` to tools module (#16748)
PR-16678 - KAFKA-17192 Fix MirrorMaker2 worker config does not pass config.provi… (#16678)
PR-16759 - KAFKA-16521; kafka-metadata-quorum describe command changes for KIP-853 (#16759)
PR-16755 - KAFKA-17230: Fix for consumer node latency metrics (#16755)
PR-16760 - KAFKA-17234: Partition.tryCompleteDelayedRequests should not throw (#16760)
PR-16300 - KAFKA-16448: Handle processing exceptions in punctuate (#16300)
PR-16736 - KAFKA-16448: Unify class cast exception handling for both key and value (#16736)
PR-16738 - Revert “KAFKA-16508: Streams custom handler should handle the timeout exceptions (#16450)” (#16738)
PR-16334 - KAFKA-16899 MembershipManagerImpl: rebalanceTimeoutMs variable name changed to commitTimeoutDuringReconciliation (#16334)
PR-16724 - KAFKA-17188: Ensure login and callback handler are closed upon encountering LoginException (#16724)
PR-16689 - KAFKA-16666 Migrate OffsetMessageFormatter to tools module (#16689)
PR-16675 - KAFKA-16448: Handle fatal user exception during processing error (#16675)
PR-16730 - KAFKA-17203 StreamThread leaking producer instances (#16730)
PR-16680 - KAFKA-17185 Declare Loggers as static to prevent multiple logger instances (#16680)
PR-16666 - KAFKA-17175 Remove interface BrokerNode and ControllerNode (#16666)
PR-16726 - KAFKA-17214: Add 3.8.0 version to core and client system tests (#16726)
PR-16728 - KAFKA-17214: Add 3.8.0 version to streams system tests (#16728)
PR-16650 - KAFKA-15469: Add documentation for configuration providers (#16650)
PR-16432 - KAFKA-16448: Add ErrorHandlerContext in deserialization exception handler (#16432)
PR-16433 - KAFKA-16448: Add ErrorHandlerContext in production exception handler (#16433)
f26f0b66 - tests/kafkatest/version.py: Add 3.9.0 as DEV_VERSION
0ec520a2 - Bump trunk to 4.0.0-SNAPSHOT

ksqlDB¶

PR-10741 - Remove zookeeper references from the codebase
PR-10739 - Remove zookeeper references
PR-10735 - Implement new SR client method getIdWithResponse
PR-10737 - Remove zookeeper license
PR-10733 - Fix backward compatibility of log4j1
PR-10732 - remove monitoring interceptor classes
PR-10731 - Pin JDK to 17
PR-10729 - Return a server error for host unavailability errors in pull queries.
PR-10722 - Update dependency Pygments to v2.15.1 [SECURITY] (7.1.x)
PR-10728 - Update the ZK notices text version under licenses
b0408e52 - Add comment and proper log message.
PR-10703 - Migrate jetty 9 to jetty 12
15443bd0 - ‘org.apache.kafka.common.errors.GroupIdNotFoundException’ import. Should be before ‘import org.apache.kafka.common.errors.GroupNotEmptyException;’.
a11521a7 - ‘org.apache.kafka.common.errors.GroupIdNotFoundException’ import. Should be before ‘org.apache.kafka.common.errors.RetriableException’.
ef35befc - Cleanup code.
PR-10726 - Update dependency jinja2 to v3.1.6 [SECURITY] (7.1.x)
fab70735 - Add logs.
1866bf04 - Keep poll time to be 10 ms, only after creating the consumer.
0dc3edf7 - Revert retries.
a10bbe2e - Poll consumers for long time to let them join the consumer group.
1cb51bec - Increase retries
4fc6b79d - Uncomment shouldListConsumerGroupsWhenTheyExist.
PR-10710 - Add a sleep for 100ms before the select queries.
PR-10708 - Removed JaasUtil’s zookeeper dependency for Ksql Build
PR-10707 - Zookeeper Deprecation (Moving to KRaft)
PR-10706 - Fix log4j2 config
PR-10705 - Downgrade jetty version to fix build
a4fe7a51 - changes in additional places
57537e6a - addressing comments
0f6f2a62 - abstracting oauth implementation
PR-10698 - Log4j to Log4j2 Migration
PR-10700 - Revert “Merge pull request”
PR-10699 - Upgrade antlr version to 4.10.1
PR-10695 - Set the default value for SecurityManager enablement to false as it is deprecated on java 21.
0a211a88 - corrected conflict
PR-10686 - update netty
PR-10678 - Query Plans and Topologies for kSQLDB 8.0
PR-10682 - Fix the compilation error.
PR-10630 - Added sonar.properties
b7c8a55f - bouncy castle fix
PR-10676 - FlatTransformValues Migration and Legacy Fallback to AlterConfigs Removed
PR-10672 - Merge Conflict Resolution (from 7.4.x to 7.5.x)
8fcad7f8 - remove jetty pin / outdated comment
be803959 - debug
313fd1da - debug
9c0edb4e - nit
90d5e47e - nit
PR-10659 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
PR-10657 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
PR-10655 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
PR-10653 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
f6c26e7a - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
8bfe4b59 - Update vertx to 4.4.8 for 7.1.x
PR-10628 - Transform to Process Migration (2nd PR)
PR-10633 - refactor: refactored ksqltransformer and its implementations
PR-10627 - refactor: refactored for checkstyle
PR-10596 - Fix master build
PR-10620 - Fix jsonschema dependency
PR-10619 - Fix jsonschema dependency
PR-10613 - Fix jsonschema dependency
PR-10576 - adding block level status for semaphore
PR-10550 - Fix the deprecated api methods.
1f619471 - Fix checkstyle error
03a41110 - Use the actual window size instead of long max

REST Proxy¶

dc0155b0 - revert version bump
26d8d8f9 - merge version bump by bot
16d5bd68 - fix typo
15dc547a - restore property
abcb7731 - remove zk
ca430c3e - Remove zk notice for cp 8.0.x release
PR-1374 - Convert log4j2 properties file to yaml
e295cb84 - change while-loop conditions to not overcheck the request log
PR-1371 - Fix log4j pattern config
PR-1368 - Migrate reload4j (log4j1) to log4j2
PR-1358 - Jetty migration 9 to 12: kafka-rest
PR-1367 - refactor: changing the config introduced in the commit d65a0b3
PR-1360 - fix: return errors from SchemaUtils class rather than Optional.empty
PR-1359 - Handle null payload in POST requests
PR-1356 - perf: add singleton to SchemaRecordSerializerFactory
ace1de9f - openapi.yaml
0a3055c3 - fix unit tests
b17955a3 - integration tests
ef37ffed - consumer group manager impl
PR-1352 - Remove java-7-jdk dependency from debian build scripts
PR-1335 - Add API to fetch earliest and latest partition offsets
PR-1349 - Implement hashCode for ConsumerGroup.State to satisfy equals contract
PR-1348 - Use GroupState from AK instead of deprecated api
PR-1341 - Copy TestUtils#createBrokerConfig to avoid depending on upstream internal API
1233e45d - change imports to confluent package
a313d614 - change imports to confluent package
PR-1339 - Remove kafka_2.13 dep and exclude log4j2 compatibility jar
PR-1337 - Exclude log4j2 deps from kafka
PR-1333 - Change visibility of testInfo and quorumTestHarness to protected so they can be used by subclasses
PR-1338 - Fix build due to upstream change
PR-1334 - Use backward compatible method to fix downstream build
2ff8e32c - Remove unncessary code changes
cf536506 - Address comments
0b6b7b6f - Fix unit test failures after changing ConsumerGroupState to GroupState
970a3995 - Remove random print
2e2aa71d - Remove zk from integration tests and fix consumer group description lookup breaking change
PR-1326 - Temporarily disable unit tests in SchemaManagerImplTest
PR-1325 - Remove zk and replace jetty DOSFilter with Confluent fork
PR-1324 - Correct field name in ConsumerGroupData, consumer -> consumers to mach code/examples
PR-1307 - Remove/Disable ZK specific tests in Kafka Rest
16369e5e - [Update] Remove counting error codes for 200
fad6156c - [Update] Fixed assertion caused by counting 200 error code
8780d5fb - [Update] Remove equals and hashCode methods of ProduceRecordErrorCounter, add cutom matcher for easymocking ProduceErrorCounter
9b47ae1a - [UPDATE] Remove unused variables
aa44306c - Delete 1
823718c1 - [Update] Code structure changes
3e5af49c - [Update] Change to more detailed method and attribute names for ProduceRecordErrorCounter
61c5b940 - [Update] Fix format
0bc39fa3 - Delete my.properties
cd45cf2b - [Update] Change class name from ProduceCounter to ProduceRecordErrorCounter
39af2bac - Add back .gitignore
a6d4b1b0 - Delete .gitignore
a6b6caa9 - [Update] Add override equals method for ProduceCounter and modified ProduceActionTest accrodingly
8e8f325f - [DO NOT MERGE] Pushing for review only
c6cff764 - Delete my.properties
da4fae88 - [Update] Add comments to test_WhenProduceRequestWithMultipleRecords_ThenRequestLogHasAggregatedErrorCodes, modify variable/function names, avoided hard coding “Codes=”, corresponding changes to tests
6d8a2bff - [Update] Add an integration test for streaming produce with multiple records in one single request
3000a4ff - [Update] shorten expectings in streamingRequestsWithExceptions
ffc921ca - [Updated] Including counting with response 200 ok (previous version cannot work on local testings)
88e9d879 - Include counting error code with 200 ok
555a5849 - Produce V3 API - Improve visibility around produce-record errors
c94062ed - remove zk references
5da01411 - Remove zk notice for cp 8.0.x release
PR-565 - Pin JDK to 17
96e64e52 - resolve merge conflict from 7.8 to 7.9
PR-491 - Add configuration hsts.header.enable to control whether we response with HSTS header
345fcebb - Fix log4j pattern config
PR-561 - Upgrade log4j1 to log4j2
ec24728a - Fix for new changes merged in
f8f06361 - CustomLog fixed; No need to use Jetty 9 RequestLogHandler
fcba5cf4 - trigger cla-status-check
8f0dce70 - PR comment; ** role for MDS authz
6480173f - rename snihandler
c23b84c7 - add config: sni.host.check.enabled for SNI host checking in SecureRequestCustomizer
6bc44ca5 - comments
1c492d6f - more tests
c54a9d3f - add test
034b803a - Implement TenantPrefixSniHandler to perform prefix validation using the tenant name
d8e5f924 - Fix the way requestlog is set
7a6bcbcb - Cleanup code comments for security constraints
5475e6c5 - Use pinned jakarta versions from common
88744003 - Dedup httpclient() in tests
1c7e1851 - add comment for disabled test
7b3be310 - update SNIUtils
62f8d3e5 - change PropertyFileLoginModule package in SaslTest
9b93be44 - allow ambiguous http to go through servlet
fef52601 - Fix CustomInitTest setup; ServerContainerInitializer related
619e8166 - Fix Http2Test ambiguous segment - please review
6a459c97 - clean up the pom files
5ec83c01 - fix http client initialization in tests
5bf4b783 - add comment for RestConfig timeout change, unify pom version for websocket-api
dc32d30a - change ErrorHandler for Jetty 12 API
2803ca1b - Security Constraint related changes with comments for review
ae462b74 - fix roles related assertions; JakartaWebSocketServletContainerInitializer to register endpoints;
09fb3e38 - server taking too long to shutdown, bumping default timeout to 5seconds
a7e9fe48 - small fix to AuthUtilTest, getRoles() returns a Set now
78a1130b - modify websocket-server for jetty 12; fix for client-api build failures
d154b969 - Temp commit - revert it later
c347aea6 - fix examples,fips-test
ea3acc6f - getRoles(), validateRequest and handler fixes
4e40602f - Major fix for httpclient and SslContextFactory issues
97439b29 - update v9.53 DosFilter to be compatible with Jetty 12
3a76ebc9 - PR comments; header fixes
9d7d7408 - RolePrincipal and import fixes
85d30eb5 - Fix ResourceCollection, Constraint and other imports
1168d7fa - easy fixes; security imports
3f66161d - javax.ws.rs -> jakarta.ws.rs; fix tests
c2bde5b7 - Fix JakartaWebSocketServletContainerInitializer
7af7af7c - Update jersey,jackson,jakarta dependencies
9ab7aa62 - Fix authUtil securityHandler issues
3d1a7e14 - fix sniUtils SslConnection
fd761cb4 - More handler related fixes
45faefd0 - Fix compilation issues; Handler overrides
c963e46b - fix HandlerWrapper; use jakarta imports for httpServletRequest and Response
0be2567f - fix for HandlerCollection
1d5fa089 - Fix ServerContainer; remaining Filter imports
PR-553 - Override jetty version to 9.4.57.v20241219
48793a42 - Fix Filter, FilterChain, FilterConfig; use jakarta
63a4096a - Fix ServletRequest and ServletResponse; using jakarta
fb4c77c1 - Fix dispatcherType; Remove RequestLogHandler
dc53690e - fix for servletException; remaining httpservlet ones
770021db - fix httpservletrequest and httpservletresponse imports
d83c2b78 - Fix security imports; javax.servlet fixes pending
4f44892e - Temp fix for DoSFilter
882d9ab8 - Fixed some compilation issues; need to fix DoSFilter
3ae701c0 - Init commit; build passes with compilation failures
6f7f0fa6 - add test
c19acb95 - fix import
5b13d1ec - fmt
3b3ff728 - add config for forwarded request customizer
PR-547 - Allow attaching NetworkTrafficListener to connectors of unnamed application
PR-546 - Allow attaching NetworkTrafficListener to connectors of unnamed application
c073c5b9 - Handle CompletionExceptions wrapping other exceptions
PR-537 - [master] Allow for upgrade to jetty and unpin jetty-servlets
PR-536 - [7.9.x] Allow for upgrade to jetty and unpin jetty-servlets
PR-535 - [7.8.x] Allow for upgrade to jetty and unpin jetty-servlets
27412aa1 - Map GroupAuthorizationException to 403 code
979f2f91 - Added validator for PERCENTILE_MAX_LATENCY
PR-523 - Include request URI in SNI logging
b8926290 - remove api team from codeowners
PR-518 - adding block level status for semaphore
016fc099 - checkstyle changes
94b6b72c - Make percentile max latency configurable
PR-516 - Handle jetty 11+ behavior of NetworkTrafficServerConnector
PR-515 - Add DoSFilter from Jetty 9.4.53
PR-514 - Map UnknownTopicIdException to 404 code
PR-506 - Log unexpected SNI headers in REST
PR-508 - Don’t log RestConfig value when creating DEFAULT_SSL config

Schema Registry¶

PR-3715 - Ensure SR client cache for CP 8.0 is backward compat with 7.x.x
PR-3711 - Add warning log whenever baseUrl changes in RestService
PR-3710 - Improve unit test coverage (edge case handling) for SetCompatibilityMojoTest
d977dc30 - Add tests for MD5 calculations
PR-3707 - Fix reference to Jetty JAAS class
PR-3706 - Bump dependency versions for GCP
PR-3698 - Distinguish between null and missing props for PUT
PR-3700 - Remove zookeeper references in log4j
PR-3691 - Start with first URL in UrlList
PR-3693 - Ensure AvroConverter does not rely on field order
PR-3692 - Remove zookeeper dependency in 8.0.x
PR-3688 - Use aws-java-sdk-v2.version from common
PR-3690 - Downgrade aws sdk v2 to match kafka on 7.7.x
PR-3685 - Add support for hybrid handler
PR-3678 - Generate Java 11 compatible class files for client modules
PR-3669 - Support schema ID in header
PR-3682 - Ignore JSON schema fields not in the Java class
306f08dc - Upgrade mbknor library to 1.0.39.3
7505a200 - Handle default context properly for /config and /mode
PR-3664 - log schema reads, writes and deletes
PR-3648 - Update dependency junit:junit to v4.13.1 [SECURITY] (7.1.x)
PR-3667 - Remove deprecated older interface for subject name strategy
PR-3666 - Add RuleSet.isEmpty method
PR-3663 - Convert XML log4j2 properties files to YAML
PR-3662 - Update the ZK notices text version under licenses
PR-3661 - add new cache schema registry method
PR-3658 - Remove slf4j-reload4j dependency to fix runtime
PR-3656 - Add minimal validation for certain KMS key IDs
PR-3650 - Migrate slf4j-reload4j to log4j2
PR-3630 - Upgrade to Jetty 12, use jakarta APIs
PR-3642 - Upgrade log4j to log4j2
PR-3641 - adding retry test for ser/de/restservice
PR-3640 - Handle URL-encoded paths in ContextFilter
PR-3636 - Support new CachedSchemaRegistryClient in SchemaRegistryClientFactory
PR-3635 - Support new CachedSchemaRegistryClient in SchemaRegistryClientFactory
PR-3632 - Merge Conflict Resolution (from 7.9.x to master)
PR-3631 - deep copy for Schema
PR-3626 - Redact sensitive fields in the DLQ Action
PR-3625 - Return deleted flag for schemas via REST API
PR-3621 - Always override X-Forwarded-For header on follower call
PR-3622 - Upgrade Tink to 1.17.0
PR-3620 - Remove unstable annotation from Avro serdes
PR-3619 - Expand semantic check when looking up schemas
PR-3581 - SR dek paginations
PR-3616 - Update test to use qualified subject names and fix a typo
PR-3615 - Upgrade to aws sdk 2.30.33
PR-3614 - Increase max length for kek and rule names
PR-3613 - Exclude javapoet dependency from wire (requires Java 17)
PR-3610 - exclude an imported 3P util class from test coverage
PR-3609 - add dek-registry module for coverage aggregation
PR-3608 - Test coverage: fix the module and updated the tests.
76c315ae - Ensure use of DEK object is thread-safe
PR-3605 - Update deps for CSPs
PR-3604 - Update proto-related libs for Protbuf 4
PR-3597 - Remove java-7-jdk dependency from debian build scripts
PR-3600 - Fix message reader to allow for interactive usage
PR-3599 - Improve test coverage (no feature change)
PR-3590 - Add retry for schema exporter upon IOException
PR-3582 - add missing tests for DekRegistry
5e23bc86 - HostSslSocketFactory for bouncycastle fix.
PR-3592 - Enhance integration test w/additional lookup
PR-3585 - Upgrade to wire 5.3.0
PR-3591 - Call close on custom auth provider
edff633b - Convert test to JUnit5 to fix build
2d0c34e6 - Upgrade Tink to 1.16
PR-3584 - Upgrade json-skema to 0.20
PR-3576 - Upgrade cel to 0.5.1; jsonata to 2.5.1
PR-3578 - Pagination of SR APIs (Subject and Schema)
PR-3575 - Support Protobuf oneof fields in Data Contract rules
PR-3577 - changing access to public
PR-3573 - Upgrade commons.validator to 1.9.0
PR-3569 - Upgrade to Protobuf 4
PR-3566 - add missing tests for DekRegistry
PR-3570 - reverting changes on 7.9 and above
PR-3568 - Merge Conflict Resolution (from 7.5.x to 7.6.x)
PR-3564 - Fix OAuth tests due to AK changes
PR-3561 - Ensure that DEK lookups use applicable aliases
PR-3559 - Setting default SSLSocketFactory from HttpsURLConnection in RestService.
PR-3555 - Ensure lookup by schema logic matches logic during register
PR-3554 - Return creation time for schemas via REST API
PR-3551 - Add support for schema guids that are stable across contexts
PR-3544 - Upgrade everit json-schema to 1.14.5
PR-3540 - Return subject/version when getting schema by ID
PR-3542 - Bouncy Castle and SunJSSE compatibility fix (additional flows)
PR-3538 - Bouncy Castle and SunJSSE compatibility fix.
PR-3539 - Fix inline tag retrieval for JSON Schema with null in array
PR-3535 - Remove use of ZK in SASL cluster tests
PR-3533 - Use JDK 17 for 8.0.0
PR-3530 - Attempt to reenable possibly flakey test
PR-3529 - Add display name generator to ensure Kraft is used in integration tests
PR-3527 - set pagination limit for subjects to INT_MAX
PR-3523 - Retry on NotLeaderOrFollowerException
PR-3518 - Remove ZK from integration tests; upgrade to JUnit 5
PR-3491 - Update KafkaGroupLeaderElector.java
PR-3502 - Fix compilation
PR-3490 - enabling cp jar build through service.yml
PR-3473 - Remove some deprecated classes for CP 8.0
PR-3488 - Fix deprecated OAuthBearerLoginCallbackHandler
PR-3474 - adding block level status for semaphore
PR-3460 - Add avro array test
PR-3452 - Bump org.apache.maven.plugin version to 3.13.1 to support java 17
PR-3442 - Add PR template
PR-3443 - Enable semaphore pipeline on SC release branch
PR-3353 - Fix issues relating deprecated interfaces in upstream kafka