Confluent Platform Component Changelogs

This topic provides changelogs for the individual Confluent Platform components.

Version 8.1.2

Released March 2026

Community Features

Common

• 700f5331 - Revert Jetty upgrade

• PR-902 - Add –direct-pom-edit support to ci.py for faster CI builds

• 745599ac - Update Jetty to 9.4.59

• 9559effb - Add logback-core dependency management to resolve bazel <–> maven conflicts

• a9b992c5 - Update Log Redactor to 1.0.17 and Netty to 4.1.130

• 3e0892c1 - Update log4j to 2.25.3

• faa63c96 - Update dependency org.bitbucket.b_c:jose4j to v0.9.6

• PR-887 - Update dependency org.apache.logging.log4j:log4j-core to v2.25.3

• c33caa1b - Update Netty to 4.1.129

• f9b8ce5a - Bump proto version

Kafka

• PR-1954 - Skip fetching mavenurl from vault

• PR-21561 - Downgrade Jetty from 12.0.32 to 12.0.25 to fix SLF4J 2.x incompatibility (4.1)

• PR-1942 - Revert Jetty update

• PR-21457 - ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls

• PR-21461 - Upgrade Jetty from 12.0.22 to 12.0.32

• PR-21397 - Add documentation about the incompatibility of RocksDB file format

• PR-21422 - Close pending tasks on shutdown.

• PR-21434 - Group coordinator fails to unload metadata when no longer leader or follower

• PR-21385 - Handle pre-4.1 brokers in kafka-configs.sh for groups

• PR-1898 - Update Jetty to 12.0.32 in 4.1

• PR-21375 - Made PartitionLeaderCache thread safe.

• PR-20289 - Race condition between log segment flush and file deletion causing log dir to go offline

• PR-21300 - Remove templateData.js in release.py

• PR-21286 - Fix rare producer message corruption, don’t reuse buffers

• PR-21250 - Upgrade Log4j to 2.25.3

• PR-21259 - Switched the java version for streams-scala from 17 to 11.

• PR-21243 - Fix the broken quick start link

• PR-21167 - Reset-by-duration should not hand back task to state-updater

• PR-21135 - Gracefully handle exceptions when handling AllocateProducerIdsResponse

• PR-21155 - TaskManager may not close all tasks on task timeouts

• PR-21120 - Update session and window store with new default when no open iterators

• PR-21119 - Group coordinator loading may fail when there is concurrent compaction (4.1)

• PR-21109 - Updating doc for process exceptional handler in case of global threads

• PR-21091 - Refactor to reset timestamp to zero when no open iterators

• PR-21035 - Update lz4 dependency version

• PR-21084 - Upgrade commons-validator to 1.10.1

• PR-21075 - Bumping group epoch when member regex subscription changes from non empty to empty

• PR-20958 - Improved error handling in DefaultStateUpdater.

• PR-20986 - Clamp negative values in coordinator histograms

ksqlDB

• PR-10955 - Migrate KS OAuth handlers based on

• PR-10944 - Fix pipeline reporting

• PR-10935 - Add vert.x handler for unknown endpoints to return http 404.

• PR-10939 - Fix(ci): increase agent size for cp-jar-build to fix disk space issue

• PR-10928 - Ksql 14255 - bump log4j version

• PR-10927 - Update jersey version

• PR-10918 - Add deprecation tracking for external dependencies

• PR-10905 - Print deprecated configurations in maven builds.

• PR-10907 - Fix compilation errors.

REST Proxy

• PR-1273 - Work around jackson databind string length limit

• 8171a366 - Fix partial permission issue for getConsumerGroups()

• 13fb1696 - Use .valid for listConsumerGroups() and fix some checkstyle issues

• 3be45b8a - Revert extra changes done by service bot

• 1df57555 - Bump Jersey dep to 2.46

• 26da27f0 - Dependcy update: bump jersey-apache-connector to 3.1.11

• PR-650 - Update jersey.version to 2.46

• c5e11ac7 - Bump jersey.version from 3.1.9 to 3.1.11

• 89e30a3d - Remove unrelated HTTP/2 case for unencoded backslash

• 6fa7e6e2 - Remove HTTP/2 case for 400 error

• 61dc3772 - Fix Spiffe Dependency

Schema Registry

• PR-4162 - Ensure guid is preserved when formatting schema responses

• 7ff2d58d - Update frozen semantics for associations 1. Don’t allow frozen attribute to be update 2. Ensure schema is passed in for frozen association, and no other schemas exist for the subject 3. Ensure cascdadLifecycle=true when deleting frozen associations

• 791a821d - Support function param for Protobuf deserializer (pt 2)

• PR-4128 - Handle null kafkaClusterId in MetricsContainer

• b02bbb13 - Support function params for Protobuf/JSON Schema deserializers

• bc4996d5 - Minor cleanup of exception handling

• PR-4126 - Revert “Minor enhancement to display soft deleted versions as negative”

• 2fc7a28f - Add support for separate aliases for DEK lookups

• 3a3bea37 - Add integration test for creating KEK that already exists

• 68927075 - Add check for duplicate header in header serializer

• 79ad79c1 - Propagate SR client to embedded executor

• 388c3ef8 - Add createTs to Association

• 6bebdcc2 - Make AssociatedNameStrategy the default

• 88b49837 - Checkstyle lint

• 5f7409e0 - Fix params

• ee3db7d4 - Reuse SR client for DEK Registry if possible

• b303e043 - Add associations filter to /schemas endpoint

• PR-4104 - Support x509 source

• PR-4108 - Create AbstractDekRegistry for store-agnostic methods

• d99f7722 - Add deleted query parm for referencedBy

• ff340425 - Use ContextId instead of Integer

• bbef4832 - Prevent hard-deletion of referenced schemas

• 9a908000 - Add API to test shared KEKs to DEK Registry client

• bb653688 - Ensure output schema is cached if it is returned

• PR-4106 - Add checked exceptions for abstract MetadataEncoderService methods

• 5e81d37d - Refactor assoc response creation

• 2c7c1cae - First cut at batch API improvements

• 6cec9889 - Add validateNewSchemas config

• d84bf175 - Fix MetadataEncoderService initialization bug

• PR-4096 - Add SchemaValueHolder interface for type-safe schema value access

• 8be9ad56 - Add enableOnlyAt property to RuleSet

• d587dc75 - Change AssociatedNameStrategy fallback to enum

• PR-4093 - Make MetadataEncoderService backend-agnostic

• PR-4091 - Fix MetadataEncoderService secret rotation and add test coverage

• PR-4089 - Fix MetadataEncoderService key rotation and add test coverage

• c77034d4 - Fix length calculation

• d99b4812 - Reduce allocations in AbstractKafkaProtobufDeserializer

• PR-4087 - Remove MetadataEncoderService’s tight coupling to KCache

• ee7d984f - Fix Avro union evolution for specific reader

• PR-4082 - Add dependency management entry for log4j version

• PR-4077 - Exclude common-lang-2.6 from rest-utils to avoid conflicts with common-lang3

• aeda9ff5 - Add config to enable asssociation functionality

• PR-4076 - Bump log4j to 2.25.3

• PR-4072 - Upgrade CI instance, add retries

• ee284c9c - Fix ContextFilter to handle associations path w/resource

• c3506a86 - Change PUT associations endpoint to pass resource ID

• 13cd3fc7 - Add more tests for DEK rewrap functionality

• c6beadf0 - Add back BoundedConcurrentHashMap but mark as deprecated

• PR-4046 - Add tool to rewrap DEKs with latest version of KEK

• PR-4043 - Add integration test tag to integration test classes

• PR-4032 - Add support for Associations

• PR-4042 - Allow encrypting a union of primitives

• PR-4041 - Extract Context prefix logic in delete mode to a method

• PR-4040 - Refactor remaining RestApi tests to be harness-agnostic

• PR-4039 - Add Avro deser config “avro.fail.on.trailing.data”

• PR-4038 - Allow use.message.indexes to be set on ConfigSchemaIdDeserializer

• PR-4031 - Fixed some typos and added more checks in mock client test

• PR-4033 - Don’t throw exception for JSON schema with format=serialized

• PR-4030 - Handle subject with name “contexts” or “subjects”

• PR-4029 - Update associations mock client 3

• PR-4011 - Refactor integration test to be harness-agnostic

• PR-4028 - More association changes for client APIs

• PR-4022 - Configure customer handlers after security handler

• PR-4017 - Port setu 7.9

• PR-4019 - Handle raw http in JSON Schema drafts

• PR-4012 - Handle multi-tenant default context in isContext()

• 43eba3f2 - Fix assert for Junit version

• PR-4003 - Add support for contextPrefix on list contexts API

• PR-4008 - Remove unnecessary comment in test harnesses

• e5703b49 - Fix assert of 7.9.x Junit

• PR-4001 - Add support for recursive mode delete

Version 8.1.1

Released December 2025

Community Features

Common

• PR-880 - Update dependency org.bouncycastle:bc-fips to v2.1.2 [SECURITY] (7.4.x)

• 2a944f44 - Use correct groupname for commons-lang3

• 04dd96c1 - Upgrade to Avro 1.12.1

• fdad7f91 - Add azure keyvault-keys dependency to management section to match kafka

• 25ab4be8 - Fix the scope of imported pom

• 4eab14b4 - Update netty and bouncycastle

• 1b8bb0d3 - Add dependency management for grpc libraries and commons-lang3

• 92007c48 - Update jetty to 9.4.58.v20250814 in 7.9.3

• 8223daaa - Update jetty to 9.4.58.v20250814 in 7.8.4

• 6452c47a - Update jetty to 9.4.58.v20250814 in 7.7.5

• 6b641984 - Update jetty to 9.4.58.v20250814 in 7.6.7

• 2763e1a3 - Update jetty to 9.4.58.v20250814 in 7.5.10

• 8c5f24d8 - Update jetty to 9.4.58.v20250814 in 7.4.11

• 179e9ad6 - Update jetty to 9.4.58.v20250814 in 7.3.14

• 7a180037 - Update jetty due to tbd, merge failure

• 68339fe3 - Update jetty in common 8.0.1

• c3793950 - Update azure libraries

• da44e9ae - Update netty to 4.1.125

• cd913d06 - Update netty to 4.1.125

• 61dac927 - Update netty to 4.1.125

• dd5af737 - Update netty to 4.1.125

• 351727d4 - Update netty to 4.1.125

• 1e7d8099 - Update netty to 4.1.125

• 45817e38 - Update netty to 4.1.125

• 63d8206d - Update netty to 4.1.125

• eb5aeb05 - Update netty to 4.1.225

• 83c69d84 - Update netty to 4.1.225

• bd24ec81 - Update netty to 4.1.225

• 3f2822ab - Update netty to 4.1.225

• 731e21af - Update netty to 4.1.225

• 6897f0eb - Update netty to 4.1.225

• 28503347 - Update netty to 4.1.225

• 06c00dc5 - Update netty to 4.1.225

• de6eef11 - Update netty to 4.1.125

• 5efa5ead - Add httpclient5 and remove ZooKeeper

• PR-830 - Upgrade protobuf to 31.1 to match ce-kafka

• c6784097 - Upgrade protobuf to 31.1 to match ce-kafka

• fdbb7f8a - Update bc-fips versions to match ce-kafka / latest security updates in verified fips version

Kafka

• PR-20945 - Use eclipse-temurin as the base image to align with 3.9

• PR-20939 - Removing process id from default client level tags

• PR-20915 - Reintroduce SaslPlainSslEndToEndAuthorizationTest

• PR-20904 - Regex subscription should be empty for classic members joining mixed group (4.1)

• PR-20781 - Don’t consider partitions unreleased when pending revocation by the current member

• PR-20886 - Replace the base image since openjdk image is deprecated

• PR-20808 - Fix CoordinatorExecutorImpl.cancelAll implementation

• PR-20258 - Set OP_WRITE interest after SASL reauthentication to resume pending writes

• be816b82 - Bump version to 4.1.1

• 14f94c75 - Revert “Bump version to 4.1.1”

• b5b09d76 - Bump version to 4.1.1

• PR-20675 - Preferably use the connector classloader when loading pl…

• PR-20668 - Global stream thread should not ignore any exceptions

• PR-20285 - at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees

• PR-20653 - RecordTooLargeExceptions in group coordinator when offsets.topic.compression.codec is used

• PR-20665 - Don’t fail if nextOffsetsAndMetadataToBeConsumed is not available

• PR-20670 - Added check before sending acknowledgements on initial epoch (Cherry-pick)

• PR-20661 - Update ClientTelemetryReporter telemetry push error handling

• PR-20646 - Clear pendingTasksToInit on tasks clear

• PR-20511 - Trigger StreamsRebalanceListener in Consumer.close

• PR-20647 - Restrict cache update for ongoing batch/offset state

ksqlDB

• PR-10903 - Update dependency io.vertx:vertx-web to v4.5.22

• PR-10896 - Auto-migrate exactly_once to exactly_once_v2

• PR-10897 - Explicitly set STATE_UPDATER_ENABLED to true

• PR-10361 - Classify exceptions as user errors

• PR-10893 - Exclude kafka.brokerTypeTopicClient from thread pool check

• PR-10884 - Rely on common for httpclient5

• PR-10869 - Upgrade jline dependency to address terminal sizing issue

• 0f38153b - Bump up tcnative dependency

• 94c228a6 - Bump up tcnative dependency

• cb2697ce - Bump up tcnative version to be in sync with netty

• PR-10865 - Bump up tcnative dependency to be in sync with netty

• PR-10854 - Update netty to 4.1.125

• 8a9b3830 - Update netty to 4.1.125 in 8.0.1

• 1be709ce - Update netty to 4.1.125 in 7.9.3

• ece71da2 - Update netty to 4.1.125 in 7.8.4

• f145df25 - Update netty to 4.1.125 in 7.7.5

• 9576ff68 - Update netty to 4.1.125 in 7.6.7

• b7473128 - Update netty to 4.1.125 in 7.5.10

• 2f04c52c - Update netty to 4.1.125 in 7.4.11

• c5dc9fd5 - Update netty to 4.1.125 in 7.3.14

• PR-10833 - Set the order of timestamp fields to be processed to avoid incorrect modifications for daylight savings

• 707d2c90 - Update catch block to handle Throwable instead of Exception

• PR-10845 - Unpin jackson version

• PR-10841 - Unpin jackson version and upgrade shade plugin

• PR-10808 - Added check for a compliant resource extension class name

• PR-10831 - Fix ProcessValue and update historical plans

• PR-10839 - Update dependency io.netty:netty-codec to v4.1.125.Final [SECURITY] (7.2.x)

• fd1e276f - Update netty version

• aa50267d - Update netty version

• 977e8df4 - Update netty version

• b00b4766 - Update netty version

• 1bd6fe9d - Update netty version

• cf858512 - Update netty version

• 02310d14 - Update netty version

• 73f28ebd - Update netty version

• d760e504 - Update netty version

• a3f4c676 - Update netty version

• PR-10795 - Update dependency io.netty:netty-codec-http2 to v4.1.124.Final [SECURITY] (7.2.x)

REST Proxy

• PR-1420 - Fix spotbug check issue

• 897f4e61 - Increase to 2h

• PR-1415 - Remove spotbug-annotations

• 92e909a4 - Allow suspicious URI characters 8.1.x

• a1096103 - Fix typo

• fc9dae2d - Add tests

• bd24ec6d - Feature flag for URI Compliance

• 7c66698b - Allow suspicious character

• db84d15b - Update spiffe

• PR-584 - Adding ProxyCustomizer for accessing tlvs

• 2c33bc9f - Make getSniServerName public

• PR-611 - Adding ProxyCustomizer for accessing tlvs

• c4281451 - Make getSniServerName public

Schema Registry

• PR-4007 - Refactor ClusterTestHarness to extend generic SR test harness

• PR-4004 - Allow function to be passed during Avro deserialization

• PR-4003 - Add support for contextPrefix on list contexts API

• PR-4001 - Add support for recursive mode delete

• PR-3997 - Expose deserialize APIs to return schema with value

• PR-3998 - Optimization: replace BoundedConcurrentHashMap with guava cache

• e1869a02 - Fix assert for junit version

• PR-3968 - Add support for DELETE /mode

• PR-3994 - Add Confluent-Accept-Unknown-Properties header to SR client

• PR-3989 - Set RestConfig.JETTY_LEGACY_URI_COMPLIANCE

• PR-3988 - Set RestConfig.JETTY_LEGACY_URI_COMPLIANCE

• PR-3985 - Remove addtional delta parameter from unit test

• PR-3984 - Fix unit test due to rest-util

• PR-3981 - Fix use of JSON Schema serializer for key

• PR-3979 - Add stubs for createAssociation(s) APIs

• PR-3977 - Minor optimization to remove synchronized block

• PR-3976 - Add payload encryption test for bytes payload

• PR-3973 - Ensure lazy initialization is thread-safe

• PR-3972 - Only use AWS role if the web identity token file is not set

• cf58140d - Handling trailing hash in JSON Schema drafts

• PR-3969 - Add Accept-Version to recognized headers

• PR-3967 - Upgrade to Avro 1.12.1 part 2

• PR-3965 - Associations client only create or update

• PR-3964 - Add Accept-Version header to the SR client

• 617ea319 - Add association client entities

• PR-3953 - Upgrade to Avro 1.12.1

• PR-3955 - Ensure canonicalString() method is thread-safe

• PR-3952 - Add guid setter

• PR-3950 - In AvroConverter use name-based getter/setter only for valid names

• PR-3947 - Remove sensitive schema data from thrown exceptions

• PR-3946 - Replace add() with put() in getHeaders to overwrite them

• PR-3943 - Log usage of MetadataEncoderService

• PR-3790 - Always add X-Forward header to request forwarded to leader

• f122adbe - Fix junit version calls

• PR-3939 - Cherry-pick change missed when resolving merge conflicts

• PR-3928 - Refactor SchemaRegistry references to use the SchemaRegistry interface

• PR-3932 - REVERT: (Breaking API Change)

• PR-3936 - Remove sensitive schema data from thrown exceptions

• PR-3935 - Ensure payloads are not unnecessarily redacted in DLQ

• PR-3933 - Init function should throw exception on failure

• PR-3930 - Add a lenient policy for JSON Schema compat checks

• PR-3914 - Add StoreUpdateHandler.init() function to call during KafkaStore initialization

• PR-3924 - Add AppRole auth for HC Vault

• PR-3922 - REVERT: (Breaking API Change)

• PR-3923 - Add getRuleSetHandler method to SchemaRegistry interface

• PR-3921 - Add additional methods to SchemaRegistry interface

• PR-3917 - Add health check and SSL factory methods to SchemaRegistry interface

• PR-3913 - Correct default and update example

• f04f8359 - Remove unused Kafka imports from SchemaRegistryConfigTest

• PR-3912 - Refactor schema registry references from KafkaSchemaRegist

• PR-3903 - Add compatibility check script

• PR-3897 - Add latest Protobuf descriptor.proto versions to tests

• PR-3908 - Support custom configs in CompositeDeserializer

• PR-3909 - Upgrade kcache to 5.2.3

• PR-3907 - Avoid extra copying in protobuf serializer

• PR-3904 - Ensure isKey is set for Avro/JSON key serializers

• PR-3901 - Add golden file to test for MD5 regression

• PR-3899 - New sr endpoint client addition

• PR-3902 - Follow up PR to handle old CP versions

• PR-3896 - Update RestService warn log to include error class name

• PR-3889 - Change apache client request body to raw bits

• PR-3894 - Remove protobuf.version in order to rely on the one from common

• PR-3891 - Remove protobuf.version in order to rely on the one from common

• PR-3890 - Ensure tags are used during schema evolution

• PR-3884 - DeleteSubject message handler should only delete non-deleted versions

Version 8.1.0

Released October 2025

Community Features

Common

• bc7c5964 - Update jetty in rc branch

• 76c8abea - Update netty to 4.1.125

• 8f780906 - Update netty to 4.1.225

• PR-830 - Upgrade protobuf to 31.1 to match ce-kafka

• 348fe558 - Update jetty

• a86ab6d5 - Update jetty, add bc-fips to renovatebot ignore file

• PR-819 - Update dependency org.bouncycastle:bc-fips to v2.1.1

• PR-814 - Update dependency org.bouncycastle:bcpkix-fips to v2.0.8

• 94288a36 - Use correct versions of fips providers

• 22a14027 - Revert renovatebot upgrade, use validated versions

• cac21f69 - Update netty and auxilary bc-fips library

• PR-810 - Update dependency org.bouncycastle:bc-fips to v2.1.0

• PR-808 - Add license for assembly-plugin-boilerplate and build-tools modules

• 79dbce2c - Update jackson bom to match ce-kafka version

• 06637ab6 - Pin commons beanutils and validator

• PR-799 - Update jetty 12 version

• PR-797 - Update semaphore instance

• PR-794 - Update node config for semaphore

• PR-793 - Updating jackson version as per ce-kafka version upgrade

• PR-791 - Updating versions as per ce-kafka version upgrade in PR #21588

• 6ce9ebd5 - Update Probuf version to match ce-kafka

• f11da56e - Upgrade spotbugs version

• 5f835d66 - Downgrade the version to reflect logredactor re-release

• 398fd1b3 - Update logredactor to address issues with versions 1 vs 2

• PR-787 - Trigger cp-jar-build to verify CP packaging in after_pipeline job

Kafka

• PR-20633 - KAFKA-19748: Fix metrics leak in Kafka Streams (#20633)

• PR-20618 - KAFKA-19690 Add epoch check before verification guard check to prevent unexpected fatal error (#20618)

• PR-20583 - [MINOR] Cleaning ignored streams test (#20583)

• PR-20604 - KAFKA-19719 –no-initial-controllers should not assume kraft.version=1 (#20604)

• PR-19961 - KAFKA-19390: Call safeForceUnmap() in AbstractIndex.resize() on Linux to prevent stale mmap of index files (#19961)

• PR-20591 - KAFKA-19732, KAFKA-19716: Clear out coordinator snapshots periodically while loading (#20591)

• PR-20581 - KAFKA-19546: Rebalance should be triggered by subscription change during group protocol downgrade (#20581)

• PR-20519 - KAFKA-19695: Fix bug in redundant offset calculation. (#20516) (#20519)

• PR-20512 - KAFKA-19679: Fix NoSuchElementException in oldest open iterator metric (#20512)

• PR-20470 - KAFKA-19668: processValue() must be declared as value-changing operation (#20470)

• 13f70256 - Bump version to 4.1.0

• 70dd1ca2 - Revert “Bump version to 4.1.0”

• PR-20405 - KAFKA-19642 Replace dynamicPerBrokerConfigs with dynamicDefaultConfigs (#20405)

• PR-1777 - KSECURITY-2558: Bump jetty to version 12.0.25 in 4.1

• PR-20070 - KAFKA-19429: Deflake streams_smoke_test, again (#20070)

• PR-20398 - Revert “KAFKA-13722: remove usage of old ProcessorContext (#18292)” (#20398)

• PR-1765 - DPA-1801 Add run_tags to worker-ami and aws-packer

• PR-1746 - Change ci_tools import path

• 23b64404 - Bump version to 4.1.0

• 6340f437 - Revert “Bump version to 4.1.0”

• de16dd10 - KAFKA-19581: Temporary fix for Streams system tests

• PR-20269 - KAFKA-19576 Fix typo in state-change log filename after rotate (#20269)

• PR-20274 - KAFKA-19529: State updater sensor names should be unique (#20262) (#20274)

• PR-1708 - DPA-1675: In case of infra failure in ccs-kafka tag that as infra failure in testbreak

• PR-20165 - KAFKA-19501 Update OpenJDK base image from buster to bullseye (#20165)

• e14d849c - Bump version to 4.1.0

• PR-20200 - KAFKA-19522: avoid electing fenced lastKnownLeader (#20200)

• PR-20196 - KAFKA-19520 Bump Commons-Lang for CVE-2025-48924 (#20196)

• PR-20040 - KAFKA-19427 Allow the coordinator to grow its buffer dynamically (#20040)

• PR-20166 - KAFKA-19504: Remove unused metrics reporter initialization in KafkaAdminClient (#20166)

• PR-20151 - KAFKA-19495: Update config for native image (v4.1.0) (#20151)

• 610f0765 - Bump version to 4.1.0

• PR-1684 - DPA-1489 migrate from vagrant to terraform

• PR-1693 - Revert “Temporarily disable artifact publishing for the 4.1 branch.”

• 57e81f20 - Bump version to 4.1.0

• PR-20071 - KAFKA-19184: Add documentation for upgrading the kraft version (#20071)

• PR-20116 - KAFKA-19444: Add back JoinGroup v0 & v1 (#20116)

• PR-19964 - KAFKA-19397: Ensure consistent metadata usage in produce request and response (#19964)

• PR-19971 - KAFKA-19042 Move ProducerSendWhileDeletionTest to client-integration-tests module (#19971)

• PR-20100 - KAFKA-19453: Ignore group not found in share group record replay (#20100)

• PR-20025 - KAFKA-19152: Add top-level documentation for OAuth flows (#20025)

• PR-20029 - KAFKA-19379: Basic upgrade guide for KIP-1071 EA (#20029)

• PR-20062 - KAFKA-19445: Fix coordinator runtime metrics sharing sensors (#20062)

• PR-19704 - KAFKA-19246; OffsetFetch API does not return group level errors correctly with version 1 (#19704)

• PR-19985 - KAFKA-19414: Remove 2PC public APIs from 4.1 until release (KIP-939) (#19985)

• PR-1672 - DPA-1593 exclude newly added files to fix build

• PR-1663 - DPA-1593 add cloudwatch metrics to view cpu, memory and disk usage

• PR-20022 - KAFKA-19398: (De)Register oldest-iterator-open-since-ms metric dynamically (#20022)

• PR-20033 - KAFKA-19383: Handle the deleted topics when applying ClearElrRecord (#20033)

• PR-19745 - KAFKA-19294: Fix BrokerLifecycleManager RPC timeouts (#19745)

• PR-19974 - KAFKA-19411: Fix deleteAcls bug which allows more deletions than max records per user op (#19974)

• PR-19972 - KAFKA-19407 Fix potential IllegalStateException when appending to timeIndex (#19972)

• PR-1659 - Reapply “KAFKA-18296 Remove deprecated KafkaBasedLog constructor (#18

• PR-20019 - KAFKA-19429: Deflake streams_smoke_test (#20019)

• PR-19999 - KAFKA-19421: Deflake streams_broker_down_resilience_test (#19999)

• PR-20004 - KAFKA-19422: Deflake streams_application_upgrade_test (#20004)

• PR-20005 - KAFKA-19423: Deflake streams_broker_bounce_test (#20005)

• PR-19983 - KAFKA-19356: Prevent new consumer fetch assigned partitions not in explicit subscription (#19983)

• PR-19917 - KAFKA-19297: Refactor AsyncKafkaConsumer’s use of Java Streams APIs in critical sections (#19917)

• PR-19981 - KAFKA-19413: Extended AuthorizerIntegrationTest to cover StreamsGroupDescribe (#19981)

• PR-19978 - KAFKA-19412: Extended AuthorizerIntegrationTest to cover StreamsGroupHeartbeat (#19978)

• PR-19976 - KAFKA-19367: Follow up bug fix (#19976)

• PR-19800 - KAFKA-14145; Faster KRaft HWM replication (#19800)

• PR-1655 - Add back deprecated constructors in KafkaBasedLog

• PR-19938 - KAFKA-19153: Add OAuth integration tests (#19938)

• PR-19910 - KAFKA-19367: Fix InitProducerId with TV2 double-increments epoch if ongoing transaction is aborted (#19910)

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

• PR-19904 - KAFKA-18961: Time-based refresh for server-side RE2J regex (#19904)

• PR-19939 - KAFKA-19359: force bump commons-beanutils for CVE-2025-48734 (#19939)

• b311ac7d - Temporarily disable artifact publishing for the 4.1 branch.

• PR-19607 - KAFKA-19221 Propagate IOException on LogSegment#close (#19607)

• PR-19928 - KAFKA-19389: Fix memory consumption for completed share fetch requests (#19928)

• PR-19895 - KAFKA-19244: Add support for kafka-streams-groups.sh options (delete offsets) [4/N] (#19895)

• PR-19908 - KAFKA-19376: Throw an error message if any unsupported feature is used with KIP-1071 (#19908)

• PR-19936 - KAFKA-19392 Fix metadata.log.segment.ms not being applied (#19936)

• PR-19919 - KAFKA-19382:Upgrade junit from 5.10 to 5.13 (#19919)

• PR-19929 - KAFKA-18486 Remove becomeLeaderOrFollower from readFromLogWithOffsetOutOfRange and other related methods. (#19929)

• PR-19931 - KAFKA-19283: Update transaction exception handling documentation (#19931)

• PR-19832 - KAFKA-19271: allow intercepting internal method call (#19832)

• PR-19918 - KAFKA-19386: Correcting ExpirationReaper thread names from Purgatory (#19918)

• PR-19817 - KAFKA-19334 MetadataShell execution unintentionally deletes lock file (#19817)

• PR-19922 - KAFKA-18486 Remove ReplicaManager#becomeLeaderOrFollower from testReplicaAlterLogDirs (#19922)

• PR-19827 - KAFKA-19042 Move PlaintextConsumerSubscriptionTest to client-integration-tests module (#19827)

• PR-19883 - KAFKA-18486 Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds (#19883)

• PR-19890 - KAFKA-18486 Update activeProducerState wih KRaft mechanism in ReplicaManagerTest (#19890)

• PR-19879 - KAFKA-14895 [1/N] Move AddPartitionsToTxnManager files to java (#19879)

• PR-19915 - KAFKA-19295: Remove AsyncKafkaConsumer event ID generation (#19915)

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

• PR-15913 - KAFKA-19309 : Add transaction client template code in kafka examples (#15913)

• PR-19900 - KAFKA-19369: Add group.share.assignors config and integration test (#19900)

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

• PR-19889 - KAFKA-18913: Start state updater in task manager (#19889)

• PR-19907 - KAFKA-19370: Create JMH benchmark for share group assignor (#19907)

• PR-19773 - KAFKA-19042 Move PlaintextConsumerAssignTest to clients-integration-tests module (#19773)

• PR-18739 - KAFKA-16505: Add source raw key and value (#18739)

• PR-19903 - KAFKA-19373 Fix protocol name comparison (#19903)

• PR-18325 - KAFKA-19248: Multiversioning in Kafka Connect - Plugin Loading Isolation Tests (#18325)

• PR-19844 - KAFKA-18042: Reject the produce request with lower producer epoch early (KIP-890) (#19844)

• PR-19901 - KAFKA-19372: StreamsGroup not subscribed to a topic when empty (#19901)

• PR-19722 - KAFKA-19044: Handle tasks that are not present in the current topology (#19722)

• PR-19856 - KAFKA-17747: [7/N] Add consumer group integration test for rack aware assignment (#19856)

• PR-19898 - KAFKA-19347 Deduplicate ACLs when creating (#19898)

• PR-19872 - KAFKA-19328: SharePartitionManagerTest testMultipleConcurrentShareFetches doAnswer chaining needs verification (#19872)

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

• PR-19754 - KAFKA-18573: Add support for OAuth jwt-bearer grant type (#19754)

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

• PR-19522 - KAFKA-19176: Update Transactional producer to translate retriable into abortable exceptions (#19522)

• PR-19796 - KAFKA-17747: [6/N] Replace subscription metadata with metadata hash in share group (#19796)

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

• PR-19861 - KAFKA-19338: Error on read/write of uninitialized share part. (#19861)

• PR-19878 - KAFKA-19358: Updated share_consumer_test.py tests to use set_group_offset_reset_strategy (#19878)

• PR-19849 - KAFKA-19349 Move CreateTopicsRequestWithPolicyTest to clients-integration-tests (#19849)

• PR-19877 - KAFKA-18904: [4/N] Add ListClientMetricsResources metric if request is v0 ListConfigResources (#19877)

• PR-19811 - KAFKA-19320: Added share_consume_bench_test.py system tests (#19811)

• PR-19831 - KAFKA-16894: share.version becomes stable feature for preview (#19831)

• PR-19836 - KAFKA-19321: Added share_consumer_performance.py and related system tests (#19836)

• PR-19866 - KAFKA-19355 Remove interBrokerListenerName from ClusterControlManager (#19866)

• PR-19327 - KAFKA-19053 Remove FetchResponse#of which is not used in production … (#19327)

• PR-19728 - KAFKA-19284 Add documentation to clarify the behavior of null values for all partitionsToOffsetAndMetadata methods. (#19728)

• PR-19864 - KAFKA-19311 Document commitAsync behavioral differences between Classic and Async Consumer (#19864)

• PR-19685 - KAFKA-19042 Move GroupAuthorizerIntegrationTest to clients-integration-tests module (#19685)

• PR-19651 - KAFKA-19042 Move BaseConsumerTest, SaslPlainPlaintextConsumerTest to client-integration-tests module (#19651)

• PR-19846 - KAFKA-19346: Move LogReadResult to server module (#19846)

• PR-19855 - KAFKA-19351: AsyncConsumer#commitAsync should copy the input offsets (#19855)

• PR-19810 - KAFKA-19042 move ConsumerWithLegacyMessageFormatIntegrationTest to clients-integration-tests module (#19810)

• PR-19808 - KAFKA-18904: kafka-configs.sh return resource doesn’t exist message [3/N] (#19808)

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

• PR-19404 - KAFKA-6629: parameterise SegmentedCacheFunctionTest for session key schemas (#19404)

• PR-19843 - KAFKA-19337: Write state writes snapshot for higher state epoch. (#19843)

• PR-19741 - KAFKA-19056 Rewrite EndToEndClusterIdTest in Java and move it to the server module (#19741)

• PR-19774 - KAFKA-19316: added share_group_command_test.py system tests (#19774)

• PR-19838 - KAFKA-19344: Replace desc.assignablePartitions with spec.isPartitionAssignable. (#19838)

• PR-19840 - KAFKA-19347 Don’t update timeline data structures in createAcls (#19840)

• PR-19826 - KAFKA-19342: Authorization tests for alter share-group offsets (#19826)

• PR-19818 - KAFKA-19335: Membership managers send negative epoch in JOINING (#19818)

• PR-19778 - KAFKA-19285: Added more tests in SharePartitionManagerTest (#19778)

• PR-19823 - KAFKA-19310: (MINOR) Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing (#19823)

• PR-19761 - KAFKA-17747: [4/N] Replace subscription metadata with metadata hash in consumer group (#19761)

• PR-19835 - KAFKA-19336 Upgrade Jackson to 2.19.0 (#19835)

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

• PR-19812 - KAFKA-19330 Change MockSerializer/Deserializer to use String serializer instead of byte[] (#19812)

• PR-19790 - KAFKA-18687: Setting the subscriptionMetadata during conversion to consumer group (#19790)

• PR-19786 - KAFKA-19268 Missing mocks for SharePartitionManagerTest tests (#19786)

• PR-19798 - KAFKA-19322 Remove the DelayedOperation constructor that accepts an external lock (#19798)

• PR-19779 - KAFKA-19300 AsyncConsumer#unsubscribe always timeout due to GroupAuthorizationException (#19779)

• PR-19093 - KAFKA-18424: Consider splitting PlaintextAdminIntegrationTest#testConsumerGroups (#19093)

• PR-19371 - KAFKA-19080 The constraint on segment.ms is not enforced at topic level (#19371)

• PR-19681 - KAFKA-19034 [1/N] Rewrite RemoteTopicCrudTest by ClusterTest and move it to storage module (#19681)

• PR-19759 - KAFKA-19312 Avoiding concurrent execution of onComplete and tryComplete (#19759)

• PR-19767 - KAFKA-19313 Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET (#19767)

• PR-19747 - KAFKA-18345; Wait the entire election timeout on election loss (#19747)

• PR-19687 - KAFKA-19260 Move LoggingController to server module (#19687)

• PR-18929 - KAFKA-16717 [2/N]: Add AdminClient.alterShareGroupOffsets (#18929)

• PR-19729 - KAFKA-19069 DumpLogSegments does not dump the LEADER_CHANGE record (#19729)

• PR-19781 - KAFKA-19204: Add timestamp to share state metadata init maps [1/N] (#19781)

• PR-19582 - KAFKA-19042 Move PlaintextConsumerPollTest to client-integration-tests module (#19582)

• PR-19763 - KAFKA-19314 Remove unnecessary code of closing snapshotWriter (#19763)

• PR-19743 - KAFKA-18904: Add Admin#listConfigResources [2/N] (#19743)

• PR-19757 - KAFKA-19291: Increase the timeout of remote storage share fetch requests in purgatory (#19757)

• PR-18951 - KAFKA-4650: Add unit tests for GraphNode class (#18951)

• PR-19749 - KAFKA-19287 document all group coordinator metrics (#19749)

• PR-19731 - KAFKA-18783 : Extend InvalidConfigurationException related exceptions (#19731)

• PR-19658 - KAFKA-18345; Prevent livelocked elections (#19658)

• PR-1627 - Trigger cp-jar-build to verify CP packaging in after_pipeline job

• PR-19755 - KAFKA-19302 Move ReplicaState and Replica to server module (#19755)

• PR-19389 - KAFKA-19042 Move PlaintextConsumerCommitTest to client-integration-tests module (#19389)

• PR-19611 - KAFKA-17747: [3/N] Get rid of TopicMetadata in SubscribedTopicDescriberImpl (#19611)

• PR-19700 - KAFKA-19202: Enable KIP-1071 in streams_eos_test (#19700)

• PR-19717 - KAFKA-19280: Fix NoSuchElementException in UnifiedLog (#19717)

• PR-19691 - KAFKA-19256: Only send IQ metadata on assignment changes (#19691)

• PR-19708 - KAFKA-19226: Added test_console_share_consumer.py (#19708)

• PR-19683 - KAFKA-19141; Persist topic id in OffsetCommit record (#19683)

• PR-19697 - KAFKA-19271: Add internal ConsumerWrapper (#19697)

• PR-1625 - Increase timeout for Connect tests

• PR-19734 - KAFKA-19217: Fix ShareConsumerTest.testComplexConsumer flakiness. (#19734)

• PR-19507 - KAFKA-19171: Kafka Streams crashes with UnsupportedOperationException (#19507)

• PR-19709 - KAFKA-19267 the min version used by ListOffsetsRequest should be 1 rather than 0 (#19709)

• PR-19580 - KAFKA-19208: KStream-GlobalKTable join should not drop left-null-key record (#19580)

• PR-19493 - KAFKA-18904: [1/N] Change ListClientMetricsResources API to ListConfigResources (#19493)

• PR-19713 - KAFKA-19274; Group Coordinator Shards are not unloaded when __consumer_offsets topic is deleted (#19713)

• PR-19701 - KAFKA-19231-1: Handle fetch request when share session cache is full (#19701)

• PR-19721 - KAFKA-19281: Add share enable flag to periodic jobs. (#19721)

• PR-19523 - KAFKA-17747: [2/N] Add compute topic and group hash (#19523)

• PR-19698 - KAFKA-19269 Unexpected error .. should not happen when the delete.topic.enable is false (#19698)

• PR-19718 - KAFKA-19270: Remove Optional from ClusterInstance#controllerListenerName() return type (#19718)

• PR-19539 - KAFKA-19082:[3/4] Add prepare txn method (KIP-939) (#19539)

• PR-19586 - KAFKA-18666: Controller-side monitoring for broker shutdown and startup (#19586)

• PR-19635 - KAFKA-19234: broker should return UNAUTHORIZATION error for non-existing topic in produce request (#19635)

• PR-19702 - KAFKA-19273 Ensure the delete policy is configured when the tiered storage is enabled (#19702)

• PR-19553 - KAFKA-19091 Fix race condition in DelayedFutureTest (#19553)

• PR-19666 - KAFKA-19116, KAFKA-19258: Handling share group member change events (#19666)

• PR-19569 - KAFKA-19206 ConsumerNetworkThread.cleanup() throws NullPointerException if initializeResources() previously failed (#19569)

• PR-19712 - KAFKA-19275 client-state and thread-state metrics are always “Unavailable” (#19712)

• PR-19630 - KAFKA-19145 Move LeaderEndPoint to Server module (#19630)

• PR-19622 - KAFKA-18847: Refactor OAuth layer to improve reusability 1/N (#19622)

• PR-19677 - KAFKA-18688: Fix uniform homogeneous assignor stability (#19677)

• PR-19659 - KAFKA-19253: Improve metadata handling for share version using feature listeners (1/N) (#19659)

• PR-19559 - KAFKA-19201: Handle deletion of user topics part of share partitions. (#19559)

• PR-19515 - KAFKA-14691; Add TopicId to OffsetFetch API (#19515)

• PR-19705 - KAFKA-19245: Updated default locks config for share group (#19705)

• PR-19496 - KAFKA-19163: Avoid deleting groups with pending transactional offsets (#19496)

• PR-1554 - Chore: update repo by service bot

• PR-19644 - KAFKA-18905; Disable idempotent producer to remove test flakiness (#19644)

• PR-19631 - KAFKA-19242: Fix commit bugs caused by race condition during rebalancing. (#19631)

• PR-19497 - KAFKA-19160;KAFKA-19164; Improve performance of fetching stable offsets (#19497)

• PR-19633 - KAFKA-18695 Remove quorum=kraft and kip932 from all integration tests (#19633)

• PR-19673 - KAFKA-19264 Remove fallback for thread pool sizes in RemoteLogManagerConfig (#19673)

• PR-19346 - KAFKA-19068 Eliminate the duplicate type check in creating ControlRecord (#19346)

• PR-19543 - KAFKA-19109 Don’t print null in kafka-metadata-quorum describe status (#19543)

• PR-19650 - KAFKA-19220 Add tests to ensure the internal configs don’t return by public APIs by default (#19650)

• PR-1623 - KBROKER-295: Ignore failing quota_test

• PR-1622 - KBROKER-295: Ignore failing quota_test

• PR-19508 - KAFKA-17897: Deprecate Admin.listConsumerGroups [2/N] (#19508)

• PR-19657 - KAFKA-19209: Clarify index.interval.bytes impact on offset and time index (#19657)

• PR-18391 - KAFKA-18115; Fix for loading big files while performing load tests (#18391)

• PR-19608 - KAFKA-19182 Move SchedulerTest to server module (#19608)

• PR-19568 - KAFKA-19087 Move TransactionState to transaction-coordinator module (#19568)

• PR-19581 - KAFKA-18855 Slice API for MemoryRecords (#19581)

• PR-19590 - KAFKA-19212: Correct the unclean leader election metric calculation (#19590)

• PR-19609 - KAFKA-19214: Clean up use of Optionals in RequestManagers.entries() (#19609)

• PR-19640 - KAFKA-19241: Updated tests in ShareFetchAcknowledgeRequestTest to reuse the socket for subsequent requests (#19640)

• PR-19598 - KAFKA-19215: Handle share partition fetch lock cleanly using tokens (#19598)

• PR-19625 - KAFKA-19202: Enable KIP-1071 in streams_standby_replica_test.py (#19625)

• PR-19602 - KAFKA-19218: Add missing leader epoch to share group state summary response (#19602)

• PR-19574 - KAFKA-19207 Move ForwardingManagerMetrics and ForwardingManagerMetricsTest to server module (#19574)

• PR-19528 - KAFKA-19170 Move MetricsDuringTopicCreationDeletionTest to client-integration-tests module (#19528)

• PR-19612 - KAFKA-19227: Piggybacked share fetch acknowledgements performance issue (#19612)

• PR-19639 - KAFKA-19216: Eliminate flakiness in kafka.server.share.SharePartitionTest (#19639)

• PR-19592 - KAFKA-19133: Support fetching for multiple remote fetch topic partitions in a single share fetch request (#19592)

• PR-19641 - KAFKA-19240 Move MetadataVersionIntegrationTest to clients-integration-tests module (#19641)

• PR-19619 - KAFKA-19232: Handle Share session limit reached exception in clients. (#19619)

• PR-19629 - KAFKA-19131: Adjust remote storage reader thread maximum pool size to avoid illegal argument (#19629)

• PR-19393 - KAFKA-19060 Documented null edge cases in the Clients API JavaDoc (#19393)

• PR-19578 - KAFKA-19205: inconsistent result of beginningOffsets/endoffset between classic and async consumer with 0 timeout (#19578)

• PR-19571 - KAFKA-18267 Add unit tests for CloseOptions (#19571)

• PR-19603 - KAFKA-19204: Allow persister retry of initializing topics. (#19603)

• PR-1621 - Dexcom fix master

• PR-1620 - Dexcom fix 4.0

• PR-19475 - KAFKA-19146 Merge OffsetAndEpoch from raft to server-common (#19475)

• PR-19606 - KAFKA-16894 Correct definition of ShareVersion (#19606)

• PR-19355 - KAFKA-19073 add transactional ID pattern filter to ListTransactions (#19355)

• PR-19430 - KAFKA-17541:[1/2] Improve handling of delivery count (#19430)

• PR-19329 - KAFKA-19015: Remove share session from cache on share consumer connection drop (#19329)

• PR-19540 - KAFKA-19169: Enhance AuthorizerIntegrationTest for share group APIs (#19540)

• PR-19604 - KAFKA-19202: Enable KIP-1071 in streams_relational_smoke_test (#19604)

• PR-19587 - KAFKA-16718-4/n: ShareGroupCommand changes for DeleteShareGroupOffsets admin call (#19587)

• PR-19601 - KAFKA-19210: resolved the flakiness in testShareGroupHeartbeatInitializeOnPartitionUpdate (#19601)

• PR-19542 - KAFKA-16894: Exploit share feature [3/N] (#19542)

• PR-19594 - KAFKA-19202: Enable KIP-1071 in streams_broker_down_resilience_test (#19594)

• PR-19509 - KAFKA-19173: Add Feature for “streams” group (#19509)

• PR-19191 - KAFKA-18760: Deprecate Optional<String> and return String from public Endpoint#listener (#19191)

• PR-19519 - KAFKA-19139 Plugin#wrapInstance should use LinkedHashMap instead of Map (#19519)

• PR-19588 - KAFKA-19135 Migrate initial IQ support for KIP-1071 from feature branch to trunk (#19588)

• PR-15968 - KAFKA-10551: Add topic id support to produce request and response (#15968)

• PR-19470 - KAFKA-19082: [2/4] Add preparedTxnState class to Kafka Producer (KIP-939) (#19470)

• PR-19584 - KAFKA-19202: Enable KIP-1071 in streams_broker_bounce_test.py (#19584)

• PR-19593 - KAFKA-19181-2: Increased offsets.commit.timeout.ms value as a temporary solution for the system test test_broker_failure failure (#19593)

• PR-19560 - KAFKA-19202: Enable KIP-1071 in streams_smoke_test.py (#19560)

• PR-19555 - KAFKA-19195: Only send the right group ID subset to each GC shard (#19555)

• PR-19535 - KAFKA-19183 Replace Pool with ConcurrentHashMap (#19535)

• PR-19529 - KAFKA-19178 Replace Vector by ArrayList for PluginClassLoader#getResources (#19529)

• PR-19478 - KAFKA-16718-3/n: Added the ShareGroupStatePartitionMetadata record during deletion of share group offsets (#19478)

• PR-19520 - KAFKA-19042 Move PlaintextConsumerFetchTest to client-integration-tests module (#19520)

• PR-19532 - KAFKA-19131: Adjust remote storage reader thread maximum pool size to avoid illegal argument (#19532)

• PR-19504 - KAFKA-17747: [1/N] Add MetadataHash field to Consumer/Share/StreamGroupMetadataValue (#19504)

• PR-19544 - KAFKA-19190: Handle shutdown application correctly (#19544)

• PR-19552 - KAFKA-19198: Resolve NPE when topic assigned in share group is deleted (#19552)

• PR-19548 - KAFKA-19195: Only send the right group ID subset to each GC shard (#19548)

• PR-19450 - KAFKA-19128: Kafka Streams should not get offsets when close dirty (#19450)

• PR-19545 - KAFKA-19192; Old bootstrap checkpoint files cause problems updated servers (#19545)

• PR-17988 - KAFKA-18988: Connect Multiversion Support (Updates to status and metrics) (#17988)

• PR-19429 - KAFKA-19082: [1/4] Add client config for enable2PC and overloaded initProducerId (KIP-939) (#19429)

• PR-19536 - KAFKA-18889: Make records in ShareFetchResponse non-nullable (#19536)

• PR-19457 - KAFKA-19110: Add missing unit test for Streams-consumer integration (#19457)

• PR-19440 - KAFKA-15767 Refactor TransactionManager to avoid use of ThreadLocal (#19440)

• PR-19453 - KAFKA-19124: Follow up on code improvements (#19453)

• PR-19443 - KAFKA-18170: Add scheduled job to snapshot cold share partitions. (#19443)

• PR-19505 - KAFKA-19156: Streamlined share group configs, with usage in ShareSessionCache (#19505)

• PR-19541 - KAFKA-19181: removed assertions in test_share_multiple_partitions as a result of change in assignor algorithm (#19541)

• PR-19461 - KAFKA-14690; Add TopicId to OffsetCommit API (#19461)

• PR-19416 - KAFKA-16538; Enable upgrading kraft version for existing clusters (#19416)

• PR-18673 - KAFKA-18572: Update Kafka Streams metric documenation (#18673)

• PR-19500 - KAFKA-19159: Removed time based evictions for share sessions (#19500)

• PR-19378 - KAFKA-19057: Stabilize KIP-932 RPCs for AK 4.1 (#19378)

• PR-19518 - KAFKA-19166: Fix RC tag in release script (#19518)

• PR-19525 - KAFKA-19179: remove the dot from thread_dump_url (#19525)

• PR-19437 - KAFKA-19019: Add support for remote storage fetch for share groups (#19437)

• PR-17099 - KAFKA-8830 make Record Headers available in onAcknowledgement (#17099)

• PR-19526 - KAFKA-19180 Fix the hanging testPendingTaskSize (#19526)

• PR-19302 - KAFKA-14487: Move LogManager static methods/fields to storage module (#19302)

• PR-19487 - KAFKA-18854 remove DynamicConfig inner class (#19487)

• PR-19286 - KAFKA-18891: Add KIP-877 support to RemoteLogMetadataManager and RemoteStorageManager (#19286)

• PR-19462 - KAFKA-17184: Fix the error thrown while accessing the RemoteIndexCache (#19462)

• PR-19477 - KAFKA-17897 Deprecate Admin.listConsumerGroups (#19477)

• PR-18926 - KAFKA-18332 fix ClassDataAbstractionCoupling problem in KafkaRaftClientTest(1/2) (#18926)

• PR-19465 - KAFKA-19136 Move metadata-related configs from KRaftConfigs to MetadataLogConfig (#19465)

• PR-19503 - KAFKA-19157: added group.share.max.share.sessions config (#19503)

• PR-1614 - CONFLUENT: Fix tools-log4j files in the scripts

• PR-1613 - CONFLUENT: Fix tools-log4j files names in the scripts

• PR-19474 - KAFKA-14523: Move kafka.log.remote classes to storage (#19474)

• PR-19491 - KAFKA-19162: Topology metadata contains non-deterministically ordered topic configs (#19491)

• PR-19394 - KAFKA-19054: StreamThread exception handling with SHUTDOWN_APPLICATION may trigger a tight loop with MANY logs (#19394)

• PR-19454 - KAFKA-19130: Do not add fenced brokers to BrokerRegistrationTracker on startup (#19454)

• PR-19460 - KAFKA-19002 Rewrite ListOffsetsIntegrationTest and move it to clients-integration-test (#19460)

• PR-19492 - KAFKA-19158: Add SHARE_SESSION_LIMIT_REACHED error code (#19492)

• PR-19488 - KAFKA-19147: Start authorizer before group coordinator to ensure coordinator authorizes regex topics (#19488)

• PR-19298 - KAFKA-19042 Move PlaintextConsumerCallbackTest to client-integration-tests module (#19298)

• PR-19472 - KAFKA-13610: Deprecate log.cleaner.enable configuration (#19472)

• PR-19050 - KAFKA-18888: Add KIP-877 support to Authorizer (#19050)

• PR-19420 - KAFKA-18983 Ensure all README.md(s) are mentioned by the root README.md (#19420)

• PR-19433 - KAFKA-18288: Add support kafka-streams-groups.sh –describe (#19433)

• PR-19464 - KAFKA-19137 Use StandardCharsets.UTF_8 instead of StandardCharsets.UTF_8.name() (#19464)

• PR-19364 - KAFKA-15370: ACL changes to support 2PC (KIP-939) (#19364)

• PR-19417 - KAFKA-18900: Implement share.acknowledgement.mode to choose acknowledgement mode (#19417)

• PR-19463 - KAFKA-18629: Account for existing deleting topics in share group delete. (#19463)

• PR-19319 - KAFKA-19042 Move ProducerCompressionTest, ProducerFailureHandlingTest, and ProducerIdExpirationTest to client-integration-tests module (#19319)

• PR-19391 - KAFKA-14523: Decouple RemoteLogManager and Partition (#19391)

• PR-19469 - KAFKA-18172 Move RemoteIndexCacheTest to the storage module (#19469)

• PR-19426 - KAFKA-19119 Move ApiVersionManager/SimpleApiVersionManager to server (#19426)

• PR-19439 - KAFKA-19121 Move AddPartitionsToTxnConfig and TransactionStateManagerConfig out of KafkaConfig (#19439)

• PR-19424 - KAFKA-19113: Migrate DelegationTokenManager to server module (#19424)

• PR-19347 - KAFKA-19027 Replace ConsumerGroupCommandTestUtils#generator by ClusterTestDefaults (#19347)

• PR-19431 - KAFKA-19115: Utilize initialized topics info to verify delete share group offsets (#19431)

• PR-19419 - KAFKA-15371 MetadataShell is stuck when bootstrapping (#19419)

• PR-19345 - KAFKA-19071: Fix doc for remote.storage.enable (#19345)

• PR-19374 - KAFKA-19030 Remove metricNamePrefix from RequestChannel (#19374)

• PR-19387 - KAFKA-14485: Move LogCleaner to storage module (#19387)

• PR-19293 - KAFKA-16894: Define feature to enable share groups (#19293)

• PR-19436 - KAFKA-19127: Integration test for altering and describing streams group configs (#19436)

• PR-19441 - KAFKA-19103 Remove OffsetConfig (#19441)

• PR-19438 - KAFKA-19118: Enable KIP-1071 in StandbyTaskCreationIntegrationTest (#19438)

• PR-19423 - KAFKA-18286: Implement support for streams groups in kafka-groups.sh (#19423)

• PR-19289 - KAFKA-19042 Move TransactionsWithMaxInFlightOneTest to client-integration-tests module (#19289)

• PR-19410 - KAFKA-19101 Remove ControllerMutationQuotaManager#throttleTimeMs unused parameter (#19410)

• PR-19354 - KAFKA-18782: Extend ApplicationRecoverableException related exceptions (#19354)

• PR-19363 - KAFKA-18629: Utilize share group partition metadata for delete group. (#19363)

• PR-19421 - KAFKA-19124: Use consumer background event queue for Streams events (#19421)

• PR-19425 - KAFKA-19118: Enable KIP-1071 in InternalTopicIntegrationTest (#19425)

• PR-19432 - KAFKA-18170: Add create and write timestamp fields in share snapshot [1/N] (#19432)

• PR-19167 - KAFKA-18935: Ensure brokers do not return null records in FetchResponse (#19167)

• PR-19261 - KAFKA-16729: Support isolation level for share consumer (#19261)

• 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-19422 - KAFKA-18287: Add support for kafka-streams-groups.sh –list (#19422)

• PR-18852 - KAFKA-18723; Better handle invalid records during replication (#18852)

• PR-19377 - KAFKA-19037: Integrate consumer-side code with Streams (#19377)

• PR-1611 - Fix build failure (#1582)

• PR-19390 - KAFKA-19090: Move DelayedFuture and DelayedFuturePurgatory to server module (#19390)

• PR-19213 - KAFKA-18984: Reset interval.ms By Using kafka-client-metrics.sh (#19213)

• PR-18976 - KAFKA-16718-2/n: KafkaAdminClient and GroupCoordinator implementation for DeleteShareGroupOffsets RPC (#18976)

• PR-19384 - KAFKA-19093 Change the “Handler on Broker” to “Handler on Controller” for controller server (#19384)

• PR-19296 - KAFKA-19047: Allow quickly re-registering brokers that are in controlled shutdown (#19296)

• PR-19413 - KAFKA-19099 Remove GroupSyncKey, GroupJoinKey, and MemberKey (#19413)

• PR-19068 - KAFKA-18892: Add KIP-877 support for ClientQuotaCallback (#19068)

• PR-19406 - KAFKA-19100: Use ProcessRole instead of String in AclApis (#19406)

• PR-19398 - KAFKA-19098 Remove lastOffset from PartitionResponse (#19398)

• PR-19359 - KAFKA-19077: Propagate shutdownRequested field (#19359)

• PR-19219 - KAFKA-19001: Use streams group-level configurations in heartbeat (#19219)

• PR-19369 - KAFKA-19084: Port KAFKA-16224, KAFKA-16764 for ShareConsumers (#19369)

• PR-19392 - KAFKA-19076 replace String by Supplier<String> for UnifiedLog#maybeHandleIOException (#19392)

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

• PR-19303 - KAFKA-16407: Fix foreign key INNER join on change of FK from/to a null value (#19303)

• PR-19242 - KAFKA-19013 Reformat PR body to 72 characters (#19242)

• PR-19288 - KAFKA-19042 Move TransactionsExpirationTest to client-integration-tests module (#19288)

• PR-19357 - KAFKA-19074 Remove the cached responseData from ShareFetchResponse (#19357)

• PR-19285 - KAFKA-14523: Move DelayedRemoteListOffsets to the storage module (#19285)

• PR-19323 - KAFKA-13747: refactor TopologyTest to test different store type parametrized (#19323)

• PR-19370 - KAFKA-19085: SharePartitionManagerTest testMultipleConcurrentShareFetches throws silent exception and works incorrectly (#19370)

• PR-19218 - KAFKA-7952: use in memory stores for KTable test (#19218)

• PR-19328 - KAFKA-18761: [2/N] List share group offsets with state and auth (#19328)

• PR-19005 - KAFKA-18713: Fix FK Left-Join result race condition (#19005)

• PR-19269 - KAFKA-18067: Add a flag to disable producer reset during active task creator shutting down (#19269)

• PR-19320 - KAFKA-19055 Cleanup the 0.10.x information from clients module (#19320)

• PR-19348 - KAFKA-19075: Included other share group dynamic configs in extractShareGroupConfigMap method in ShareGroupConfig (#19348)

• PR-19333 - KAFKA-19064: Handle exceptions from deferred events in coordinator (#19333)

• PR-19339 - KAFKA-18827: Incorporate initializing topics in share group heartbeat [4/N] (#19339)

• PR-19111 - KAFKA-18923: resource leak in RSM fetchIndex inputStream (#19111)

• PR-19317 - KAFKA-18949 add consumer protocol to testDeleteRecordsAfterCorruptRecords (#19317)

• PR-19324 - KAFKA-19058 Running the streams/streams-scala module tests produces a streams-scala.log (#19324)

• PR-19276 - KAFKA-19003: Add forceTerminateTransaction command to CLI tools (#19276)

• PR-19226 - KAFKA-19004 Move DelayedDeleteRecords to server-common module (#19226)

• PR-18953 - KAFKA-18826: Add global thread metrics (#18953)

• PR-19343 - KAFKA-19016: Updated the retention behaviour of share groups to retain them forever (#19343)

• PR-19344 - KAFKA-19072: Add system test for ELR (#19344)

• PR-19331 - KAFKA-15931: Cancel RemoteLogReader gracefully (#19331)

• PR-19338 - KAFKA-18796-2: Corrected the check for acquisition lock timeout in Sh… (#19338)

• PR-19335 - KAFKA-19062: Port changes from KAFKA-18645 to share-consumers (#19335)

• PR-19334 - KAFKA-19018,KAFKA-19063: Implement maxRecords and acquisition lock timeout in share fetch request and response resp. (#19334)

• PR-18383 - KAFKA-18613: Unit tests for usage of incorrect RPCs (#18383)

• PR-19189 - KAFKA-18613: Improve test coverage for missing topics (#19189)

• PR-18510 - KAFKA-18409: ShareGroupStateMessageFormatter should use CoordinatorRecordMessageFormatter (#18510)

• PR-19274 - KAFKA-18959 increase the num_workers from 9 to 14 (#19274)

• PR-19283 - KAFKA-19042 Move ConsumerTopicCreationTest to client-integration-tests module (#19283)

• PR-18297 - KAFKA-16260: Deprecate window.size.ms and window.inner.class.serde in StreamsConfig (#18297)

• PR-19114 - KAFKA-18613: Add StreamsGroupHeartbeat handler in the group coordinator (#19114)

• PR-19270 - KAFKA-19032 Remove TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames (#19270)

• PR-19268 - KAFKA-19005 improve the documentation of DescribeTopicsOptions#partitionSizeLimitPerResponse (#19268)

• PR-19282 - KAFKA-19036 Rewrite LogAppendTimeTest and move it to storage module (#19282)

• PR-19299 - KAFKA-19049 Remove the @ExtendWith(ClusterTestExtensions.class) from code base (#19299)

• PR-19076 - KAFKA-17830 Cover unit tests for TBRLMM init failure scenarios (#19076)

• PR-19216 - KAFKA-14486 Move LogCleanerManager to storage module (#19216)

• PR-19026 - KAFKA-18827: Initialize share group state group coordinator impl. [3/N] (#19026)

• PR-18695 - KAFKA-18616; Refactor Tools’s ApiMessageFormatter (#18695)

• PR-19192 - KAFKA-18899: Improve handling of timeouts for commitAsync() in ShareConsumer. (#19192)

• PR-19154 - KAFKA-18914 Migrate ConsumerRebootstrapTest to use new test infra (#19154)

• PR-19233 - KAFKA-18736: Add pollOnClose() and maximumTimeToWait() (#19233)

• PR-19230 - KAFKA-18736: Handle errors in the Streams group heartbeat request manager (#19230)

• PR-18711 - KAFKA-18576 Convert ConfigType to Enum (#18711)

• PR-19247 - KAFKA-18796: Added more information to error message when assertion fails for acquisition lock timeout (#19247)

• PR-19046 - KAFKA-18276 Migrate ProducerRebootstrapTest to new test infra (#19046)

• PR-19207 - KAFKA-18980 OffsetMetadataManager#cleanupExpiredOffsets should record the number of records rather than topic partitions (#19207)

• PR-19227 - KAFKA-18999 Remove BrokerMetadata (#19227)

• PR-19256 - KAFKA-17806 remove this-escape suppress warnings in AclCommand (#19256)

• PR-19255 - KAFKA-18329; [3/3] Delete old group coordinator (KIP-848) (#19255)

• PR-19064 - KAFKA-18893: Add KIP-877 support to ReplicaSelector (#19064)

• PR-19251 - KAFKA-18329; [2/3] Delete old group coordinator (KIP-848) (#19251)

• PR-19254 - KAFKA-19017: Changed consumer.config to command-config in verifiable_share_consumer.py (#19254)

• PR-19246 - KAFKA-15599 Move MetadataLogConfig to raft module (#19246)

• PR-19180 - KAFKA-18954: Add ELR election rate metric (#19180)

• PR-19197 - KAFKA-15931: Cancel RemoteLogReader gracefully (#19197)

• PR-19243 - KAFKA-18329; [1/3] Delete old group coordinator (KIP-848) (#19243)

• PR-19174 - KAFKA-18946 Move BrokerReconfigurable and DynamicProducerStateManagerConfig to server module (#19174)

• PR-18842 - KAFKA-806 Index may not always observe log.index.interval.bytes (#18842)

• PR-19214 - KAFKA-18989 Optimize FileRecord#searchForOffsetWithSize (#19214)

• PR-19183 - KAFKA-18819 StreamsGroupHeartbeat API and StreamsGroupDescribe API check topic describe (#19183)

• PR-19217 - KAFKA-18975 Move clients-integration-test out of core module (#19217)

• PR-19193 - KAFKA-18953: [1/N] Add broker side handling for 2 PC (KIP-939) (#19193)

• PR-18949 - KAFKA-17431: Support invalid static configs for KRaft so long as dynamic configs are valid (#18949)

• PR-19202 - KAFKA-18969 Rewrite ShareConsumerTest#setup and move to clients-integration-tests module (#19202)

• PR-19165 - KAFKA-18955: Fix infinite loop and standardize options in MetadataSchemaCheckerTool (#19165)

• PR-18966 - KAFKA-18808 add test to ensure the name=<default> is not equal to default quota (#18966)

• PR-18463 - KAFKA-17171 Add test cases for STATIC_BROKER_CONFIG in kraft mode (#18463)

• PR-18801 - KAFKA-17565 Move MetadataCache interface to metadata module (#18801)

• PR-19181 - KAFKA-18736: Do not send fields if not needed (#19181)

• PR-19215 - KAFKA-18990 Avoid redundant MetricName creation in BaseQuotaTest#produceUntilThrottled (#19215)

• PR-19027 - KAFKA-18859 honor the error message of UnregisterBrokerResponse (#19027)

• PR-19212 - KAFKA-18993 Remove confusing notable change section from upgrade.html (#19212)

• PR-19129 - KAFKA-18703 Remove unused class PayloadKeyType (#19129)

• PR-19187 - KAFKA-18915 Rewrite AdminClientRebootstrapTest to cover the current scenario (#19187)

• PR-19147 - KAFKA-18924 Running the storage module tests produces a storage/storage.log file (#19147)

• PR-19136 - KAFKA-18781: Extend RefreshRetriableException related exceptions (#19136)

• PR-18994 - KAFKA-18843: MirrorMaker2 unique workerId (#18994)

• PR-17264 - KAFKA-17516 Synonyms for client metrics configs (#17264)

• PR-19134 - KAFKA-18927 Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0 (#19134)

• 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-19176 - KAFKA-18651: Add Streams-specific broker configurations (#19176)

• PR-19040 - KAFKA-18858 Refactor FeatureControlManager to avoid using uninitialized MV (#19040)

• PR-19030 - KAFKA-14484: Move UnifiedLog to storage module (#19030)

• PR-18662 - KAFKA-18617 Allow use of ClusterInstance inside BeforeEach (#18662)

• PR-18018 - KAFKA-18142 Switch to com.gradleup.shadow (#18018)

• PR-19169 - KAFKA-18947 Remove unused raftManager in metadataShell (#19169)

• PR-18998 - KAFKA-18837: Ensure controller quorum timeouts and backoffs are at least 0 (#18998)

• PR-19119 - KAFKA-18422 Adjust Kafka client upgrade path section (#19119)

• PR-19168 - KAFKA-18942: Add reviewers to PR body with committer-tools (#19168)

• PR-19148 - KAFKA-18932: Removed usage of partition max bytes from share fetch requests (#19148)

• PR-19145 - KAFKA-18936: Fix share fetch when records are larger than max bytes (#19145)

• PR-18091 - KAFKA-18074: Add kafka client compatibility matrix (#18091)

• PR-18258 - KAFKA-18195: Fix Kafka Streams broker compatibility matrix (#18258)

• PR-19171 - KAFKA-17808: Fix id typo for connector-dlq-adminclient (#19171)

• PR-19144 - KAFKA-18933 Add client integration tests module (#19144)

• PR-19155 - KAFKA-18925: Add streams groups support to Admin.listGroups (#19155)

• PR-19142 - KAFKA-18901: [1/N] Improved homogeneous SimpleAssignor (#19142)

• PR-19162 - KAFKA-18941: Do not test 3.3 in upgrade_tests.py (#19162)

• PR-19121 - KAFKA-18736: Decide when a heartbeat should be sent (#19121)

• PR-19173 - KAFKA-18931: added a share group session timeout task when group coordinator is loaded (#19173)

• PR-19099 - KAFKA-18637: Fix max connections per ip and override reconfigurations (#19099)

• PR-17767 - KAFKA-17856 Move ConfigCommandTest and ConfigCommandIntegrationTest to tool module (#17767)

• PR-18802 - KAFKA-18706 Move AclPublisher to metadata module (#18802)

• PR-19166 - KAFKA-18944 Remove unused setters from ClusterConfig (#19166)

• PR-19081 - KAFKA-18909 Move DynamicThreadPool to server module (#19081)

• PR-19062 - KAFKA-18700 Migrate SnapshotPath, Entry, OffsetAndEpoch, LogFetchInfo, and LogAppendInfo to record classes (#19062)

• PR-19156 - KAFKA-18940: fix electionWasClean (#19156)

• PR-19127 - KAFKA-18920: The kcontrollers must set kraft.version in ApiVersionsResponse (#19127)

• PR-19116 - KAFKA-18285: Add describeStreamsGroup to Admin API (#19116)

• PR-18684 - KAFKA-18461 Add Objects.requireNotNull to Snapshot (#18684)

• PR-18299 - KAFKA-17607: Add CI step to verify LICENSE-binary (#18299)

• PR-19137 - KAFKA-18929: Log a warning when time based segment delete is blocked by a future timestamp (#19137)

• PR-15241 - KAFKA-15931: Reopen TransactionIndex if channel is closed (#15241)

• PR-19138 - KAFKA-18046; High CPU usage when using Log4j2 (#19138)

• PR-19094 - KAFKA-18915: Migrate AdminClientRebootstrapTest to use new test infra (#19094)

• PR-19113 - KAFKA-18900: Experimental share consumer acknowledge mode config (#19113)

• PR-19131 - KAFKA-18648: Make records in FetchResponse nullable again (#19131)

• PR-19120 - KAFKA-18887: Implement Streams Admin APIs (#19120)

• PR-19130 - KAFKA-18811: Added command configs to admin client as well in VerifiableShareConsumer (#19130)

• PR-19112 - KAFKA-18910 Remove kafka.utils.json (#19112)

• 4a500418 - Revert “KAFKA-18246 Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs (#18191)”

• d86cb597 - Revert “KAFKA-18887: Implement Streams Admin APIs (#19049)”

• PR-19049 - KAFKA-18887: Implement Streams Admin APIs (#19049)

• PR-19104 - KAFKA-18919 Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde (#19104)

• PR-19054 - KAFKA-18882 Remove BaseKey, TxnKey, and UnknownKey (#19054)

• PR-19083 - KAFKA-18817: ShareGroupHeartbeat and ShareGroupDescribe API must check topic describe (#19083)

• PR-18983 - KAFKA-14121: AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor (#18983)

• PR-18918 - KAFKA-18804 Remove slf4j warning when using tool script (#18918)

• PR-9766 - KAFKA-10864 Convert end txn marker schema to use auto-generated protocol (#9766)

• 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-19089 - KAFKA-18917: TransformValues throws NPE (#19089)

• PR-19065 - KAFKA-18876 4.0 documentation improvement (#19065)

• PR-19086 - Fix typos in multiple files (#19086)

• PR-19091 - KAFKA-18918: Correcting releasing of locks on exception (#19091)

• PR-19088 - KAFKA-18916; Resolved regular expressions must update the group by topics data structure (#19088)

• PR-19075 - KAFKA-18867 add tests to describe topic configs with empty name (#19075)

• PR-18449 - KAFKA-18500 Build PRs at HEAD commit (#18449)

• PR-19059 - KAFKA-18878: Added share session cache and delayed share fetch metrics (KIP-1103) (#19059)

• 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-19055 - KAFKA-18817:[1/N] ShareGroupHeartbeat and ShareGroupDescribe API must check topic describe (#19055)

• PR-18981 - KAFKA-18613: Auto-creation of internal topics in streams group heartbeat (#18981)

• PR-19056 - KAFKA-18881 Document the ConsumerRecord as non-thread safe (#19056)

• PR-18752 - KAFKA-18168: Adding checkpointing for GlobalKTable during restoration and closing (#18752)

• PR-19070 - KAFKA-18907 Add suitable error message when the appended value is too larger (#19070)

• PR-19067 - KAFKA-18908 Document that the size of appended value can’t be larger than Short.MAX_VALUE (#19067)

• PR-19047 - KAFKA-18880 Remove kafka.cluster.Broker and BrokerEndPointNotAvailableException (#19047)

• PR-19063 - KAFKA-17039 KIP-919 supports for unregisterBroker (#19063)

• PR-17771 - KAFKA-17981 add Integration test for ConfigCommand to add config key=[val1,val2] (#17771)

• PR-19045 - KAFKA-18734: Implemented share partition metrics (KIP-1103) (#19045)

• PR-19048 - KAFKA-18860 Remove Missing Features section (#19048)

• PR-18349 - KAFKA-18371 TopicBasedRemoteLogMetadataManagerConfig exposes sensitive configuration data in logs (#18349)

• PR-19020 - KAFKA-18780: Extend RetriableException related exceptions (#19020)

• PR-19037 - KAFKA-18869 add remote storage threads to “Updating Thread Configs” section (#19037)

• PR-17743 - KAFKA-18863: Connect Multiversion Support (Versioned Connector Creation and related changes) (#17743)

• PR-19042 - KAFKA-18813: ConsumerGroupHeartbeat API and ConsumerGroupDescribe API… (#19042)

• PR-18989 - KAFKA-18813: ConsumerGroupHeartbeat API and ConsumerGroupDescribe API must check topic describe (#18989)

• PR-18979 - KAFKA-18614, KAFKA-18613: Add streams group request plumbing (#18979)

• PR-18864 - KAFKA-18757: Create full-function SimpleAssignor to match KIP-932 description (#18864)

• PR-18988 - KAFKA-18839: Drop EAGER rebalancing support in Kafka Streams (#18988)

• PR-18985 - KAFKA-18792 Add workflow to check PR format (#18985)

• PR-19010 - KAFKA-17351: Improved handling of compacted topics in share partition (2/N) (#19010)

• PR-19021 - KAFKA-17836 Move RackAwareTest to server module (#19021)

• PR-18803 - KAFKA-18712 Move Endpoint to server module (#18803)

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

• PR-18900 - KAFKA-17937 Cleanup AbstractFetcherThreadTest (#18900)

• PR-18898 - KIP-966 part 1 release doc (#18898)

• PR-18770 - KAFKA-18748 Run new tests separately in PRs (#18770)

• PR-18804 - KAFKA-18522: Slice records for share fetch (#18804)

• PR-18233 - KAFKA-18023: Enforcing Explicit Naming for Kafka Streams Internal Topics (#18233)

• PR-18939 - KAFKA-18779: Validate responses from broker in client for ShareFetch and ShareAcknowledge RPCs. (#18939)

• PR-18992 - KAFKA-18827: Initialize share group state persister impl [2/N]. (#18992)

• PR-18880 - KAFKA-15583 doc update for the “strict min ISR” rule (#18880)

• PR-18928 - KAFKA-18629: ShareGroupDeleteState admin client impl. (#18928)

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

• PR-18968 - KAFKA-18827: Initialize share state, share coordinator impl. [1/N] (#18968)

• PR-19000 - Revert “KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)” (#19000)

• PR-18897 - KAFKA-18795 Remove Records#downConvert (#18897)

• PR-18996 - KAFKA-18813: [3/N] Client support for TopicAuthException in DescribeConsumerGroup path (#18996)

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

• 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-18848 - KAFKA-18629: Delete share group state RPC group coordinator impl. [3/N] (#18848)

• 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-18962 - KAFKA-18828: Update share group metrics per new init and call mechanism. (#18962)

• PR-18891 - KAFKA-16918 TestUtils#assertFutureThrows should use future.get with timeout (#18891)

• PR-18965 - MIINOR: Remove redundant quorum parameter from *AdminIntegrationTest classes (#18965)

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

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

• PR-18955 - KAFKA-18791 Enable new asf.yaml parser [1/n] (#18955)

• PR-18845 - KAFKA-18601: Assume a baseline of 3.3 for server protocol versions (#18845)

• PR-18944 - KAFKA-18198: Added check to prevent acknowledgements on initial ShareFetchRequest. (#18944)

• PR-18946 - KAFKA-18799 Remove AdminUtils (#18946)

• PR-18757 - KAFKA-18667 Add replication system test case for combined broker + controller failure (#18757)

• PR-18872 - KAFKA-18773 Migrate the log4j1 config to log4j 2 for native image and README (#18872)

• PR-18004 - KAFKA-18089: Upgrade Caffeine lib to 3.1.8 (#18004)

• PR-18850 - KAFKA-18767: Add client side config check for shareConsumer (#18850)

• PR-18460 - KAFKA-14484: Decouple UnifiedLog and RemoteLogManager (#18460)

• PR-18927 - KAFKA-16718 [1/n]: Added DeleteShareGroupOffsets request and response schema (#18927)

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

• PR-18914 - KAFKA-18798 The replica placement policy used by ReassignPartitionsCommand is not aligned with kraft controller (#18914)

• PR-18888 - KAFKA-18787: RemoteIndexCache fails to delete invalid files on init (#18888)

• PR-18934 - KAFKA-18807; Fix thread idle ratio metric (#18934)

• PR-18871 - KAFKA-18684: Add base exception classes (#18871)

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

• PR-18907 - KAFKA-18801 Remove ClusterGenerator and revise ClusterTemplate javadoc (#18907)

• PR-18809 - KAFKA-18730: Add replaying streams group state from offset topic (#18809)

• PR-18889 - KAFKA-18784 Fix ConsumerWithLegacyMessageFormatIntegrationTest (#18889)

• PR-18920 - KAFKA-18805: add synchronized block for Consumer Heartbeat close (#18920)

• PR-18908 - KAFKA-18755 Align timeout in kafka-share-groups.sh (#18908)

• PR-18922 - KAFKA-18809 Set min in sync replicas for __share_group_state. (#18922)

• 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-18894 - KAFKA-18761: Complete listing of share group offsets [1/N] (#18894)

• PR-18819 - KAFKA-16717 [1/2]: Add AdminClient.alterShareGroupOffsets (#18819)

• PR-18899 - KAFKA-18772 Define share group config defaults for Docker (#18899)

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

• 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-18834 - KAFKA-16720: Support multiple groups in DescribeShareGroupOffsets RPC (#18834)

• 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-18807 - KAFKA-18728 Move ListOffsetsPartitionStatus to server module (#18807)

• PR-18851 - KAFKA-18769: Improve leadership changes handling in ShareConsumeRequestManager. (#18851)

• PR-18869 - KAFKA-18777 add PartitionsWithLateTransactionsCount to BrokerMetricNamesTest (#18869)

• PR-18729 - KAFKA-18323: Add StreamsGroup class (#18729)

• PR-18275 - KAFKA-15443: Upgrade RocksDB to 9.7.3 (#18275)

• PR-18451 - KAFKA-18035: TransactionsTest testBumpTransactionalEpochWithTV2Disabled failed on trunk (#18451)

• PR-17804 - KAFKA-15995: Adding KIP-877 support to Connect (#17804)

• PR-18829 - KAFKA-18756: Enabled share group configs for queues related system tests (#18829)

• PR-18858 - Fix bug in json naming (#18858)

• PR-18833 - KAFKA-18758: NullPointerException in shutdown following InvalidConfigurationException (#18833)

• PR-18855 - KAFKA-18764: Throttle on share state RPCs auth failure. (#18855)

• PR-18039 - KAFKA-14484: Move UnifiedLog static methods to storage (#18039)

• PR-18394 - KAFKA-18396: Migrate log4j1 configuration to log4j2 in KafkaDockerWrapper (#18394)

• PR-18853 - KAFKA-18770 close the RM created by testDelayedShareFetchPurgatoryOperationExpiration (#18853)

• PR-18820 - KAFKA-18366 Remove KafkaConfig.interBrokerProtocolVersion (#18820)

• PR-18812 - KAFKA-18658 add import control for examples module (#18812)

• PR-18821 - KAFKA-18743 Remove leader.imbalance.per.broker.percentage as it is not supported by Kraft (#18821)

• PR-1578 - CCS CP release test regex updates

• PR-18196 - KAFKA-18225 ClientQuotaCallback#updateClusterMetadata is unsupported by kraft (#18196)

• PR-1582 - Fix build failure

• PR-18846 - KAFKA-18763: changed the assertion statement for acknowledgements to include only successful acks (#18846)

• PR-18824 - KAFKA-18745: Handle network related errors in persister. (#18824)

• PR-18252 - KAFKA-17833: Convert DescribeAuthorizedOperationsTest to use KRaft (#18252)

• PR-1577 - CCS CP release test regex updates

• PR-18381 - KAFKA-18275 Restarting broker in testing should use the same port (#18381)

• PR-18818 - KAFKA-18741 document the removal of inter.broker.protocol.version (#18818)

• PR-18496 - KAFKA-18483 Disable Log4jController and Loggers if Log4j Core absent (#18496)

• PR-18672 - KAFKA-18618: Improve leader change handling of acknowledgements [1/N] (#18672)

• 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-18771 - KAFKA-18689: Improve metric calculation to avoid NoSuchElementException (#18771)

• PR-18189 - KAFKA-18206: EmbeddedKafkaCluster must set features (#18189)

• PR-18765 - KAFKA-17379: Fix inexpected state transition from ERROR to PENDING_SHUTDOWN (#18765)

• PR-18696 - KAFKA-18494-3: solution for the bug relating to gaps in the share partition cachedStates post initialization (#18696)

• PR-18748 - KAFKA-18629: Add persister impl and tests for DeleteShareGroupState RPC. [2/N] (#18748)

• PR-18671 - [KAFKA-16720] AdminClient Support for ListShareGroupOffsets (2/2) (#18671)

• PR-18702 - KAFKA-18645: New consumer should align close timeout handling with classic consumer (#18702)

• PR-18791 - KAFKA-18722: Remove the unreferenced methods in TBRLMM and ConsumerManager (#18791)

• PR-18782 - KAFKA-18694: Migrate suitable classes to records in coordinator-common module (#18782)

• PR-18784 - KAFKA-18705: Move ConfigRepository to metadata module (#18784)

• PR-18783 - KAFKA-18698: Migrate suitable classes to records in server and server-common modules (#18783)

• PR-18781 - KAFKA-18675 Add tests for valid and invalid broker addresses (#18781)

• 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-18551 - KAFKA-18538: Add Streams membership manager (#18551)

• PR-18165 - KAFKA-18230: Handle not controller or not leader error in admin client (#18165)

• PR-18700 - KAFKA-18644: improve generic type names for internal FK-join classes (#18700)

• PR-18790 - KAFKA-18693 Remove PasswordEncoder (#18790)

• 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-18676 - KAFKA-18325: Add TargetAssignmentBuilder (#18676)

• 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-18749 - KAFKA-18672; CoordinatorRecordSerde must validate value version (#18749)

• PR-18768 - KAFKA-18678 Update TestVerifiableProducer system test (#18768)

• PR-18652 - KAFKA-17125: Streams Sticky Task Assignor (#18652)

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

• PR-18759 - KAFKA-18683: Handle slicing of file records for updated start position (#18759)

• fc3dca4e - Revert “KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer (#17700)”

• 7920fadb - 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-1541 - Merge trunk

• 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-17511 - KAFKA-15995: Initial API + make Producer/Consumer plugins Monitorable (#17511)

• PR-18722 - KAFKA-18644: improve generic type names for KStreamImpl and KTableImpl (#18722)

• PR-18754 - KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18754)

• PR-18730 - KAFKA-18660: Transactions Version 2 doesn’t handle epoch overflow correctly (#18730)

• PR-1556 - MINOR: Disable publish artifacts for 4.0

• PR-18548 - KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18548)

• PR-18731 - KAFKA-18570: Update documentation to add remainingLogsToRecover, remainingSegmentsToRecover and LogDirectoryOffline metrics (#18731)

• PR-18669 - KAFKA-18621: Add StreamsCoordinatorRecordHelpers (#18669)

• PR-18681 - KAFKA-18636 Fix how we handle Gradle exits in CI (#18681)

• PR-18590 - KAFKA-18569: New consumer close may wait on unneeded FindCoordinator (#18590)

• PR-18698 - KAFKA-13722: remove internal usage of old ProcessorContext (#18698)

• PR-18314 - KAFKA-16339: Add Kafka Streams migrating guide from transform to process (#18314)

• PR-18732 - KAFKA-18498: Update lock ownership from main thread (#18732)

• 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-18718 - KAFKA-18632: Multibroker test improvements. (#18718)

• PR-18725 - KAFKA-18653: Fix mocks and potential thread leak issues causing silent RejectedExecutionException in share group broker tests (#18725)

• PR-18726 - KAFKA-18646: Null records in fetch response breaks librdkafka (#18726)

• PR-18668 - KAFKA-18619: New consumer topic metadata events should set requireMetadata flag (#18668)

• PR-18728 - KAFKA-18488: Improve KafkaShareConsumerTest (#18728)

• PR-18716 - KAFKA-18648: Add back support for metadata version 0-3 (#18716)

• PR-18555 - KAFKA-18528: MultipleListenersWithSameSecurityProtocolBaseTest and GssapiAuthenticationTest should run for async consumer (#18555)

• PR-18651 - KAFKA-17951: Share parition rotate strategy (#18651)

• PR-18712 - KAFKA-18629: Delete share group state impl [1/N] (#18712)

• PR-18570 - KAFKA-17162: join() started thread in DefaultTaskManagerTest (#18570)

• PR-18602 - KAFKA-17587 Refactor test infrastructure (#18602)

• PR-18693 - KAFKA-18631 Remove ZkConfigs (#18693)

• PR-18699 - KAFKA-18642: Increased the timeouts in share_consumer_test.py system tests (#18699)

• PR-18632 - KAFKA-18555 Avoid casting MetadataCache to KRaftMetadataCache (#18632)

• PR-18547 - KAFKA-18533 Remove KafkaConfig zookeeper related logic (#18547)

• PR-18554 - KAFKA-18529: ConsumerRebootstrapTest should run for async consumer (#18554)

• PR-18292 - KAFKA-13722: remove usage of old ProcessorContext (#18292)

• PR-18444 - KAFKA-17894: Implemented broker topic metrics for Share Group 1/N (KIP-1103) (#18444)

• PR-18687 - KAFKA-18630: Clean ReplicaManagerBuilder (#18687)

• PR-18477 - KAFKA-18474: Remove zkBroker listener (#18477)

• PR-18688 - KAFKA-18616; Refactor DumpLogSegments’s MessageParsers (#18688)

• PR-15574 - KAFKA-16372 Fix producer doc discrepancy with the exception behavior (#15574)

• PR-18618 - KAFKA-18590 Cleanup DelegationTokenManager (#18618)

• PR-18593 - KAFKA-18559 Cleanup FinalizedFeatures (#18593)

• PR-18627 - KAFKA-18597 Fix max-buffer-utilization-percent is always 0 (#18627)

• PR-18686 - KAFKA-18620: Remove UnifiedLog#legacyFetchOffsetsBefore (#18686)

• PR-18621 - KAFKA-18592 Cleanup ReplicaManager (#18621)

• PR-18476 - KAFKA-18324: Add CurrentAssignmentBuilder (#18476)

• PR-12042 - KAFKA-13810: Document behavior of KafkaProducer.flush() w.r.t callbacks (#12042)

• PR-18667 - KAFKA-18484 [2/2]; Handle exceptions during coordinator unload (#18667)

• PR-18601 - KAFKA-18488: Additional protocol tests for share consumption (#18601)

• PR-18666 - KAFKA-18486; [1/2] Update LocalLeaderEndPointTest (#18666)

• d2024436 - KAFKA-18575: Transaction Version 2 doesn’t correctly handle race condition with completing and new transaction(#18604)

• 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-18630 - KAFKA-18599: Remove Optional wrapping for forwardingManager in ApiVersionManager (#18630)

• PR-18389 - KAFKA-18229: Move configs out of “kraft” directory (#18389)

• PR-18661 - KAFKA-18484 [1/N]; Handle exceptions from deferred events in coordinator (#18661)

• PR-18649 - KAFKA-18392: Ensure client sets member ID for share group (#18649)

• PR-18527 - KAFKA-18518: Add processor to handle rebalance events (#18527)

• PR-18607 - KAFKA-17402: DefaultStateUpdated should transite task atomically (#18607)

• PR-18539 - KAFKA-18454 Publish build scans to develocity.apache.org (#18539)

• PR-18512 - KAFKA-18302; Update CoordinatorRecord (#18512)

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

• 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-18629 - KAFKA-18598: Remove ControllerMetadataMetrics ZK-related Metrics (#18629)

• PR-18611 - KAFKA-18585 Fix fail test ValuesTest#shouldConvertDateValues (#18611)

• PR-18647 - KAFKA-18487; Remove ReplicaManager#stopReplicas (#18647)

• PR-18635 - KAFKA-18583; Fix getPartitionReplicaEndpoints for KRaft (#18635)

• PR-18442 - KAFKA-18311: Internal Topic Manager (5/5) (#18442)

• PR-18636 - KAFKA-18604; Update transaction coordinator (#18636)

• PR-18497 - KAFKA-14552: Assume a baseline of 3.0 for server protocol versions (#18497)

• PR-18346 - KAFKA-18363: Remove ZooKeeper mentiosn in broker configs (#18346)

• PR-18631 - KAFKA-18595: Remove AuthorizerUtils#sessionToRequestContext (#18631)

• PR-18626 - KAFKA-18594: Cleanup BrokerLifecycleManager (#18626)

• PR-18174 - KAFKA-18232: Add share group state topic prune metrics. (#18174)

• PR-18567 - KAFKA-18553: Update javadoc and comments of ConfigType (#18567)

• PR-18571 - [KAFKA-16720] AdminClient Support for ListShareGroupOffsets (1/n) (#18571)

• PR-18624 - KAFKA-18588 Remove TopicKey.scala (#18624)

• PR-18628 - KAFKA-18578: Remove UpdateMetadataRequest from MetadataCacheTest (#18628)

• PR-18625 - KAFKA-18593 Remove ZkCachedControllerId In MetadataCache (#18625)

• PR-17390 - KAFKA-17668: Clean-up LogCleaner#maxOverCleanerThreads and LogCleanerManager#maintainUncleanablePartitions (#17390)

• 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-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-18586 - KAFKA-18565 Cleanup SaslSetup (#18586)

• PR-18606 - KAFKA-18430 Remove ZkNodeChangeNotificationListener (#18606)

• PR-18492 - KAFKA-18480 Fix fail e2e test_offset_truncate (#18492)

• PR-18012 - KAFKA-806: Index may not always observe log.index.interval.bytes (#18012)

• PR-18595 - KAFKA-18515 Remove DelegationTokenManagerZk (#18595)

• PR-18579 - Remove casts to KRaftMetadataCache (#18579)

• PR-18577 - Convert BrokerEndPoint to record (#18577)

• 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-18209 - Infrastructure for system tests for the new share consumer client (#18209)

• PR-18553 - KAFKA-18373: Remove ZkMetadataCache (#18553)

• PR-18582 - KAFKA-18557 streamline codebase with testConfig() (#18582)

• PR-18573 - KAFKA-18431: Remove KafkaController (#18573)

• PR-18574 - KAFKA-18407: Remove ZkAdminManager, DelayedCreatePartitions, CreatePartitionsMetadata, ZkConfigRepository, DelayedDeleteTopics (#18574)

• PR-18568 - KAFKA-18556: Remove JaasModule#zkDigestModule, JaasTestUtils#zkSections (#18568)

• PR-18534 - KAFKA-14485: Move LogCleaner exceptions to storage module (#18534)

• PR-18565 - KAFKA-18546: Use mocks instead of a real DNS lookup to the outside (#18565)

• 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-18374 - KAFKA-7776: Tests for ISO8601 in Connect value parsing (#18374)

• PR-18562 - KAFKA-18558: Added check before adding previously subscribed partitions (#18562)

• 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-18524 - KAFKA-18514: Refactor share module code to server and server-common (#18524)

• PR-18414 - KAFKA-18331: Make process.roles and node.id required configs (#18414)

• PR-18559 - KAFKA-18552: Remove unnecessary version check in testHandleOffsetFetch* (#18559)

• PR-18483 - KAFKA-18472: Remove MetadataSupport (#18483)

• PR-18342 - KAFKA-18026: KIP-1112, clean up graph node grace period resolution (#18342)

• PR-18491 - KAFKA-18479: Remove keepPartitionMetadataFile in UnifiedLog and LogMan… (#18491)

• 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-18459 - KAFKA-18452: Implemented batch size in acquired records (#18459)

• PR-18448 - KAFKA-18401: Transaction version 2 does not support commit transaction without records (#18448)

• PR-18490 - KAFKA-18479: RocksDBTimeOrderedKeyValueBuffer not initialized correctly (#18490)

• PR-18536 - KAFKA-18514 Remove server dependency on share coordinator (#18536)

• PR-18521 - KAFKA-18513: Validate share state topic records produced in tests. (#18521)

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

• 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-18544 - Revert “KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18050)” (#18544)

• PR-18487 - KAFKA-18476: KafkaStreams should swallow TransactionAbortedException (#18487)

• PR-18195 - KAFKA-18026: KIP-1112, clean up StatefulProcessorNode (#18195)

• 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-18511 - KAFKA-18493: Fix configure :streams:integration-tests project error (#18511)

• PR-18453 - KAFKA-18399 Remove ZooKeeper from KafkaApis (8/N): ELECT_LEADERS , ALTER_PARTITION, UPDATE_FEATURES (#18453)

• PR-18525 - Rename the variable to reflect its purpose (#18525)

• PR-18403 - KAFKA-18211: Override class loaders for class graph scanning in connect. (#18403)

• PR-18500 - Add DescribeShareGroupOffsets API [KIP-932] (#18500)

• PR-17669 - KAFKA-17915: Convert Kafka Client system tests to use KRaft (#17669)

• PR-17901 - KAFKA-18064: SASL mechanisms should throw exception on wrap/unwrap (#17901)

• PR-18507 - KAFKA-18491 Remove zkClient & maybeUpdateMetadataCache from ReplicaManager (#18507)

• PR-18337 - KAFKA-18274 Failed to restart controller in testing due to closed socket channel [2/2] (#18337)

• 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-17870 - KAFKA-18404: Remove partitionMaxBytes usage from DelayedShareFetch (#17870)

• 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-18480 - KAFKA-18457; Update DumpLogSegments to use coordinator record json converters (#18480)

• 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-18404 - KAFKA-18400: Don’t use YYYY when formatting/parsing dates in Java client (#18404)

• 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-17510 - KAFKA-17792: Efficiently parse decimals with large exponents in Connect Values (#17510)

• PR-18679 - KAFKA-18632: Added few share consumer multibroker tests. (#18679)

• 82ccf75a - KAFKA-18575: Transaction Version 2 doesn’t correctly handle race condition with completing and new transaction(#18604)

• 94a1bfb1 - KAFKA-18575: Transaction Version 2 doesn’t correctly handle race condition with completing and new transaction(#18604)

• PR-18340 - KAFKA-18339: Fix parseRequestHeader error handling (#18340)

• PR-18643 - Revert “KAFKA-18404: Remove partitionMaxBytes usage from DelayedShareFetch (#17870)” (#18643)

• 21c4539d - Revert “KAFKA-18034: CommitRequestManager should fail pending requests on fatal coordinator errors (#18050)”

• PR-18150 - KAFKA-18026: KIP-1112 migrate KTableSuppressProcessorSupplier (#18150)

• 0186534a - Revert “KAFKA-17411: Create local state Standbys on start (#16922)” and “KAFKA-17978: Fix invalid topology on Task assignment (#17778)”

• PR-18378 - KAFKA-18340: Change Dockerfile to use log4j2 yaml instead log4j properties (#18378)

• PR-18397 - KAFKA-18311: Enforcing copartitioned topics (4/N) (#18397)

• PR-17454 - KAFKA-17671: Create better documentation for transactions (#17454)

• PR-18455 - KAFKA-18308; Update CoordinatorSerde (#18455)

• PR-18435 - KAFKA-18440: Convert AuthorizationException to fatal error in AdminClient (#18435)

• PR-18458 - KAFKA-18304; Introduce json converter generator (#18458)

• 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-18175 - KAFKA-17986 Fix ConsumerRebootstrapTest and ProducerRebootstrapTest (#18175)

• 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-18395 - KAFKA-18311: Configuring repartition topics (3/N) (#18395)

• PR-18446 - KAFKA-18453: Add StreamsTopology class to group coordinator (#18446)

• PR-18450 - KAFKA-18435 Remove zookeeper dependencies in build.gradle (#18450)

• PR-18452 - KAFKA-18111: Add Kafka Logo to README (#18452)

• PR-18438 - KAFKA-18432 Remove unused code from AutoTopicCreationManager (#18438)

• PR-18436 - KAFKA-18434: enrich the authorization error message of connecting to controller (#18436)

• PR-18441 - KAFKA-18426 Remove FinalizedFeatureChangeListener (#18441)

• PR-18276 - KAFKA-18321: Add StreamsGroupMember, MemberState and Assignment classes (#18276)

• PR-18443 - KAFKA-18425 Remove OffsetTrackingListener (#18443)

• PR-18439 - KAFKA-18433: Add BatchSize to ShareFetch request (1/N) (#18439)

• PR-18428 - Backport some GHA changes from trunk (#18428)

• PR-18415 - KAFKA-18428: Measure share consumers performance (#18415)

• PR-18419 - KAFKA-18397: Added null check before sending background event from ShareConsumeRequestManager. (#18419)

• PR-18440 - KAFKA-18449: Add share group state configs to reconfig-server.properties (#18440)

• PR-18296 - KAFKA-18173 Remove duplicate assertFutureError (#18296)

• PR-18094 - KAFKA-15599: Move SegmentPosition/TimingWheelExpirationService to raft module (#18094)

• 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-18421 - KAFKA-18408 tweak the ‘tag’ field for BrokerHeartbeatRequest.json, BrokerRegistrationChangeRecord.json and RegisterBrokerRecord.json (#18421)

• 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-17946 - KAFKA-10790: Add deadlock detection to producer#flush (#17946)

• PR-18399 - KAFKA-18412: Remove EmbeddedZookeeper (#18399)

• PR-18352 - KAFKA-18368 Remove TestUtils#MockZkConnect and remove zkConnect from TestUtils#createBrokerConfig (#18352)

• PR-18396 - KAFKA-18303; Update ShareCoordinator to use new record format (#18396)

• PR-18370 - KAFKA-18388 test-kraft-server-start.sh should use log4j2.yaml (#18370)

• PR-17742 - KAFKA-18419: KIP-891 Connect Multiversion Support (Transformation and Predicate Changes) (#17742)

• PR-18355 - KAFKA-18374 Remove EncryptingPasswordEncoder, CipherParamsEncoder, GcmParamsEncoder, IvParamsEncoder, and the unused static variables in PasswordEncoder (#18355)

• PR-18379 - KAFKA-18311: Configuring changelog topics (2/N) (#18379)

• PR-18318 - KAFKA-18307: Don’t report on disabled/removed tests (#18318)

• PR-17801 - KAFKA-17278; Add KRaft RPC compatibility tests (#17801)

• PR-18377 - KAFKA-17539: Application metrics extension for share consumer (#18377)

• PR-18384 - KAFKA-17616: Remove KafkaServer (#18384)

• PR-18268 - KAFKA-18311: Add internal datastructure for configuring topologies (1/N) (#18268)

• PR-18343 - KAFKA-18358: Replace Deprecated $buildDir variable in build.gradle (#18343)

• PR-18353 - KAFKA-18365 Remove zookeeper.connect in Test (#18353)

• PR-18373 - Use instanceof pattern to avoid explicit cast (#18373)

• PR-18270 - KAFKA-18319: Add task assignor interfaces (#18270)

• PR-18259 - KAFKA-18273: KIP-1099 verbose display share group options (#18259)

• 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-18232 - KAFKA-12469: Deprecated and corrected topic metrics for consumer (KIP-1109) (#18232)

• PR-18254 - KAFKA-17421 Add integration tests for ConsumerRecord#leaderEpoch (#18254)

• 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-18101 - KAFKA-18135: ShareConsumer HB UnsupportedVersion msg mixed with Consumer HB (#18101)

• 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-18310 - KAFKA-18274 Failed to restart controller in testing due to closed socket channel [1/2] (#18310)

• 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-18223 - KAFKA-18278: Correct name and description for run-gradle step (#18223)

• 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-18218 - KAFKA-18269: Remove deprecated protocol APIs support (KIP-896, KIP-724) (#18218)

• 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-17687 - KAFKA-15370: Support Participation in 2PC (KIP-939) (1/N) (#17687)

• PR-18285 - KAFKA-18312: Added entityType: topicName to SubscribedTopicNames in ShareGroupHeartbeatRequest.json (#18285)

• PR-18261 - KAFKA-18301; Make coordinator records first class citizen (#18261)

• 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-18136 - KAFKA-18207: Serde for handling transaction records (#18136)

• PR-18243 - KAFKA-13722: Refactor Kafka Streams store interfaces (#18243)

• PR-18241 - KAFKA-17131: Refactor TimeDefinitions (#18241)

• PR-18228 - KAFKA-18284: Add group coordinator records for Streams rebalance protocol (#18228)

• PR-18242 - KAFKA-13722: Refactor SerdeGetter (#18242)

• PR-18176 - KAFKA-18227: Ensure v2 partitions are not added to last transaction during upgrade (#18176)

• PR-18251 - Add IT for share consumer with duration base offet auto reset (#18251)

• PR-18230 - KAFKA-18283: Add StreamsGroupDescribe RPC definitions (#18230)

• 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-18227 - KAFKA-18282: Add StreamsGroupHeartbeat RPC definitions (#18227)

• 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-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-18190 - KAFKA-18244: Fix empty SHA on “Pull Request Labeled” workflow (#18190)

• PR-18166 - KAFKA-18226: Disable CustomQuotaCallbackTest and remove isKRaftTest (#18166)

ksqlDB

• PR-10831 - Fix ProcessValue and update historical plans

• 318f76ab - Bump up tcnative dependency.

• 28b84e56 - Update netty to 4.1.125 in 8.1.0

• 53ee8cae - Update netty version

• PR-10820 - Add log4j-slf4j-impl dependency for external security plugins

• 5a2abfb2 - Merge conflict fix

• 35cd807a - Merge conflict fix

• b54b98a7 - Added check for a compliant resource extension class name

• PR-10808 - Added check for a compliant resource extension class name

• PR-10806 - Changes to add License Validation plugin from CSP (#10789)

• PR-10802 - Pin httpclient 5 to correct one

• e9c70665 - Update json-smart version override comment for CVE-2024-57699

• e1506346 - Override vulnerable json-smart version to fix CVE-2024-57699

• PR-10789 - KSQL-13744 Changes to add License Validation plugin from CSP

• ff42df17 - Update dependency io.netty:netty-codec-http2 to v4.1.124.Final [SECURITY]

• PR-10792 - Merge Conflict Resolution (from 7.9.x to 8.0.x)

• PR-10791 - Add option to use local mode in proxy protocol headers.

• PR-10788 - PR merge 7 9 x to 8 0 x

• PR-10782 - Filter out security.protocol and sasl.mechanism as configs to be passed to ksql query overrides.

• PR-10786 - Fix checkstyle errors.

• PR-10785 - Apply proxy protocol configs to admin client.

• PR-10781 - Pass the proxy protocol headers to admin, producer and consumer clients if the user principal is available.

• PR-10779 - CVE fix for commons-lang3. Bump the version to 3.18.0

• PR-10774 - Upgrade http components

• afa3e130 - Master fix

• 1323f2de - Master fix

• 2dc484a5 - Master fix

• PR-10770 - MINOR: Fix ConsistencyOffsetVector deserialization after Jackson 2.19.0 version upgrade

• PR-10768 - MINOR: Update maven-shade-plugin version

• PR-10765 - Adds apache kafka logger to rolling log4j2 yaml file

• 4baa81fa - Preliminary change set to merge when Apache Kafka upstream merges are introduced

• PR-10761 - Fix machine type

• fbbfc142 - Suppress SIC_INNER_SHOULD_BE_STATIC04

• d0ed3895 - Resolve checkstyle errors.

• f48de3d3 - Resolve checkstyle errors.

• 89da3e56 - Resolve checkstyle errors.

• 79daf33d - Due to a recent commit in ce-kafka https://github.com/confluentinc/ce-kafka/pull/21030 (cherry pick from AK), few OAuth layer classes have been renamed: AccessTokenRetriever -> JwtRetriever AccessTokenValidator -> JwtValidator HttpAccessTokenRetriever -> HttpJwtRetriever LoginAccessTokenValidator -> ClientJwtValidator

• 193aa810 - Suppress spotbugs.

• a13a47da - Add suppression for PA_PUBLIC_PRIMITIVE_ATTRIBUTE, FS_BAD_DATE_FORMAT_FLAG_COMBO in findbugs-exclude.xml

• f2beb974 - Suppress spot bug errors.

• 812b566e - Suppress spot bug errors.

• e6450af9 - Suppress spotbug errors..

• PR-10744 - Return a server error for host unavailability errors in pull queries.

REST Proxy

• PR-1409 - Prompt for community/open-source editions (#1407)

• PR-1407 - Prompt for community/open-source editions

• f05cee42 - Remove bc dependency that is being merged in bc-prov

• PR-1403 - Hardcoding the CP rpm and deb installation dependency version

• 3d866adb - Update Ubuntu version from 20 to 24 in Semaphore configuration

• PR-1377 - Remove zk support for kafka-rest integration tests

• PR-1373 - Chore: update repo by service bot

• d3249c51 - Import Disabled

• PR-605 - Merge Conflict Resolution (from 8.0.x to 8.1.x)

• fe264d8b - Adding a UT for the temporary exception Mapper logic

• 76bb723c - Fix build issues

• b59226a4 - Name the config correctly

• 9691e060 - Added behind a RestConfig

• b2279888 - Temp: for inc-3209, we return a 429 instead of 500

• PR-587 - Fix javax to jakarta in SpireTest

• PR-586 - Fix jakarta usage in SpireTest.java

• PR-584 - Adding ProxyCustomizer for accessing tlvs

• 3d67bbc7 - Refactor comments

• 33f20c6e - Add comment to explain acceptAnySpiffeId

• f390b052 - Add comment

• 8dbdc48c - Clean code

• 03d316fc - Fix http2 fips tests

• 2accbb1b - Fix SSL_IS_SPIRE_ENABLED_DOC and SSL_IS_SPIRE_ENABLED_DEFAULT

• e57ff8da - Rename SSL_IS_SPIRE_ENABLED to SSL_SPIRE_ENABLED

• 8b340b25 - Add grpc-netty-linux to pom

• 2837a665 - Dependency modification

• 4f573a6f - White space nit

• 913fe83a - Add more constructor

• e93773ec - Add new consturctor to application server

• 590a07e6 - Style fix

• 94b1e7bb - Add more comments for the sample HelloWorldSpireApplication

• a7f06a76 - Make all the test to use SSL_CLIENT_AUTHENTICATION_CONFIG instead

• d1992f62 - Revert extra variable for MTLS

• 2b569a12 - Fix HelloWorldSpireApplication style issue

• 99dfa601 - Remove socket path

• d102c902 - Remove socketPath variable from config

• e8fa0abe - Remove init X509 Source logic; changed to throw error instead

• b154af2a - Spire Test Refactor 2

• 447f8a9a - Spire Test Refactor 1

• affb8342 - Create HelloWorldApplication with s2s based on spire

• 9e463ffb - Revert all changes made to HelloWorldApplication

• 6fcdf0f2 - Add more tests cases for spire Test

• 5392cec4 - Add option to be MTLS v.s TLS

• 27f06eb5 - Fix TestCustomizeThreadPool unit testing failure due to incorrect constructor building

• 67f8d26c - Nit changes

• 62abe019 - Implement mock class in spire Test

• 54c2459e - Style check for sslfactory

• 85737b0a - Style fixing

• b5ec6760 - Add null check

• bb80e4e8 - Add 2 ways of application starting

• 8c6a02bb - Move X509source object to be in application server to prevent it getting closed

• 0a69aadd - Put x509 passing into the server

• a470260f - Add spire setting for helloWorldApplication

• e6ddc845 - Refactor x509source initilization to sslFactory

• 7b309f76 - Add config for spire related setting

• f5b3cb4f - Modify spireTest to use spiffeFactoryContext

• a14733fd - Modify HelloWorld Application to pass X509Source when init application

• 62f664bd - Modify application to take or initialize X509

• 35162aea - Mdofiy applicationserver to to take X509 source outside

• ed3d2fca - SslFactory utilize SpiffeSslContextFactory instead of custom implementation

• e73cc147 - Remove SpiffeTrustManager

• 6356cf0e - Add spire client test to do MTLS

• 1a5b4c6c - Make HelloWorldApplication using SSL

• c4eb6a20 - Dependency pom xml

• 30763b96 - Modify server to make it connecting to spire agent

• f748ee7d - Use max metric value

• 9fcd1fa5 - Enable metric latency test

• 3685f929 - Enable request log test

• PR-579 - Update Ubuntu version from 20 to 24

• 3af4625f - Semaphore s1-prod-ubuntu24-04-amd64-0 after_pipeline

• 8202fbd9 - Fix test

• a81a7845 - Update Semaphore agent to s1-prod-ubuntu24-04-amd64-1

• 53e0fd45 - Add PREFIX_SNI_PREFIX_CONFIG

• da8cf6fe - Restrict sni prefix validation to certain prefix

• PR-573 - Scoped to listener config for network connector

Schema Registry

• PR-3906 - Follow up PR to handle old CP versions (#3902)

• PR-3895 - Remove protobuf.version in order to rely on the one from common (#3891)

• PR-3892 - Ensure tags are used during schema evolution (#3890)

• PR-3880 - Fix IndexOutOfBoundsException when evolving Avro schema w/rules

• PR-3876 - Fix merge issue; add JavaDoc for invalidate methods

• PR-3875 - Refine cache invalidation

• PR-3868 - DGS-21934: only retry + throw NetworkException on IOException related to network connections

• PR-3871 - Some fixes to tests/lints

• PR-3870 - Add sr-version to sr client API

• PR-3866 - Merge Conflict Resolution (from 7.4.x to 7.5.x)

• 1cdf19fe - Re-organize imports

• PR-3865 - Merge Conflict Resolution (from 7.4.x to 7.5.x)

• PR-3864 - Organizing imports

• PR-3863 - Fix assert equals usage for 8.0.x and greater

• PR-3862 - Add deployment metadata endpoint

• PR-3860 - Add sr type endpoint

• PR-3837 - Hardcoding the CP rpm and deb installation dependency version

• PR-3855 - Minor refactoring; add test

• PR-3850 - Prevent re-registration of schema with dangling reference

• PR-3851 - For shared KEKs avoid calling KMS when deleting DEKs

• PR-3842 - Modify Schema Registry Client Config to convert all configs to string

• PR-3840 - Fix build due to Jackson upgrade to 2.16

• PR-3841 - Modify POST /subjects lookup to fail only if both normalize=true fails

• PR-3838 - Upgrade json-sKema to 0.24.0

• PR-3834 - Add descriptive logging for use of apache http client

• PR-3832 - Close Schema registry after closing resource extensions

• PR-3822 - DGS-21595 Allow alternate KMS key IDs on a KEK

• PR-3826 - Merge Conflict Resolution (from 7.3.x to 7.4.x)

• PR-3821 - Upgrade commons lang version

• PR-3825 - Add Apache and CCL licenses to the dek-* modules

• PR-3824 - Fix license headers

• PR-3823 - Fix license headers

• PR-3815 - Add getGuid method to SchemaRegistryClient

• 752b07bc - DGS-21546 Minor refactor to add subject to create DEK API

• 38791869 - Removed comment

• PR-3810 - Fix : Subject config and mode should be deleted on hard delete

• PR-3817 - Prevent default context being allowed in forward mode

• PR-3816 - DGS-21504 Ensure DEKs are decrypted if version=-1 for shared KEKs

• PR-3814 - Replace MDC with ThreadContext for LOG4J2 compatibility

• PR-3812 - DGS-21443 Configure customer handlers after security handler (#3805) 8.1.x prot

• PR-3809 - Enfroce forward mode to global context

• PR-3808 - Add support for JSON Schema 2020-12 in JsonSchemaUtils

• PR-3777 - DGS-21268 Add support for full payload encryption

• PR-3787 - Changed resource logging to log subject name assotiation rather than hash contents

• PR-3802 - Fix field traversals when POJO property is missing

• PR-3794 - Handle decimals based on fixed type in Avro converter

• PR-3800 - Fix license headers

• PR-3799 - Fix license headers

• PR-3797 - Fix license headers

• PR-3795 - Fix license headers

• PR-3792 - Fix license headers

• PR-3789 - Support for license headers

• PR-3783 - Support for license headers

• PR-3763 - Add additional config for Apache Http Client

• PR-3784 - Fix parsing of recursive definitions for JSON Schema 2020-12

• PR-3773 - Send NetworkException instead of ConnectionException for IO exceptions in Connect converters

• PR-3775 - Set cleanup.policy to compact in integration tests

• da3ea478 - Fix test

• 9661d1af - Migrate test to Junit 5 after merge

• PR-3766 - Support a true global config/mode

• PR-3767 - Upgrade jackson-datatype-protobuf to 0.9.16

• PR-3764 - Add REST API to delete context

• PR-3760 - 7.8 below java doc fix

• PR-3761 - Javadoc fix in ParsedSchema

• PR-3759 - Add javadoc as part of the maven build (#3758)

• PR-3758 - Add javadoc as part of the maven build

• PR-3749 - Update PR template to include related changes

• PR-3755 - Fix for javadoc failure

• PR-3751 - Fix master SR oauth to handle AK changes

• PR-3750 - Bump max DEK registry key default

• PR-3746 - Generate correct field type for Decimal in JSON converter

• PR-3744 - Add referenceFormat param to qualify references

• PR-3738 - Send ConnectException for IO exceptions in connect converters

• dee00fa2 - Checkstlye fix

• e70d6ffe - Formatting fixes

• PR-3741 - DGS-20896 Ensure correct GUID when requesting a formatted schema

• 47c90d80 - Fixed failing test

• d439f6d7 - Formatting fix

• 42349149 - Exposed context name for mode/config errors

• PR-3739 - Fix ubuntu24 image in schema registry repo

• PR-3736 - Suppressions and few volatile var changes to resolve spotbugs errors

• PR-3735 - Add log4j-1.2-api dependency to SR (#3734)

• PR-3734 - Add log4j-1.2-api dependency to SR

• PR-3733 - Fix build by renaming oauth kafka classes

• 39474f1d - Upgrade json-skema to 0.22

• PR-3724 - Upgrade everit json-schema to 1.14.6

• PR-3718 - Adjust the format of the PR template to remove checkbox

• PR-3714 - DGS-20647 Ensure SR client cache for CP 8.0 is backward compat with 7.x.x

• PR-3701 - Adjust the PR template to use freeform text instead of checkbox

• PR-3705 - Correct forward statement

• PR-3703 - Remove unused method to resolve kafka build failure

• PR-3697 - Add Forward mode