Confluent Platform Component Changelogs
This topic provides changelogs for the individual Confluent Platform components.
This page contains the changelog for Confluent Platform 7.9. To view the changelog for an earlier Confluent Platform release, use the version picker to switch to the documentation for that release. To find the latest patch version for each Confluent Platform release line, see Confluent Platform patch versions.
Version 7.9.8
Released June 2026
Community Features
Common
2636f6a9 - Add jetty-alpn-*-client artifacts to dependencyManagement
bd2bfe51 - Update mina-core to 2.2.7
902d6f6b - Pin plexus-utils dependency to match ce-kafka
e0509516 - Update logredactor
9c4d0eb1 - Update Jetty to 9.4.61
c35f82c6 - Re-scope spotbugs-annotations
c92168f8 - Update Netty to 4.1.133
feef7ef9 - Update bouncycastle to 1.84
9c2d2eaa - Replace jetty-bom with individual dependency definitions
93f81673 - Add log4j2 version definition and update version in log4j2-extensions
f6f72532 - Update Netty to 4.1.132
f3d00a7d - Update Jackson to 2.18.6
PR-927 - Rename docker-arm profile to docker-fabric8 and migration changes
88413aa1 - Update Jetty to 9.4.60 and ZooKeeper to 3.8.6
952e3d32 - Update Avro to 1.11.5 in 7.8.7
e8cf967f - Update Avro to 1.11.5 in 7.7.8
62db0fed - Update Avro to 1.11.5 in 7.6.10
71f054dd - Update Avro to 1.11.5 in 7.5.13
217dac01 - Update Avro to 1.11.5 in 7.4.14
d5a703f7 - Update Avro to latest patch release
Kafka
PR-2070 - Update Netty to 4.1.133 in 3.9
PR-22219 - Backwards compatible advertised.listeners when it is not defined
5c9f7e11 - Upgrade Netty to 4.1.132.Final
3ac9673d - Bump maven-artifact to 3.9.15
6ca74b7c - Upgrade Jetty from 9.4.59 to 9.4.60
5fdea4c1 - Bump Jackson to 2.18.6
e92eb28e - Upgrade ZooKeeper from 3.8.4 to 3.8.6 with SLF4J version pin
PR-21881 - Fix LazyDownConversionRecordsTest in using zlib-ng
PR-21740 - Receive buffers allocated from MemoryPool may not be released if request is invalid
PR-21731 - Improve ClusterControlManager error message
PR-21717 - Fix error invoking org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close()
ksqlDB
PR-11066 - Enforce DenyListPropertyValidator on in-SQL SET statements.
PR-11072 - Pin kotlin-stdlib via kotlin-bom to fix runtime crash in ksqldb
PR-11052 - TransientQueryCleanup leak-detection ordering + TransientQueryQueue LIMIT-handler null-guard
a5803cee - Update vertx and netty to resolve known security issues
PR-11033 - Fix: wait for broker to unfence in EmbeddedSingleNodeKafkaCluster.start()
PR-11030 - Fix: always retry admin stmts on topic-not-found, even with expectedError
PR-11029 - Fix: retry admin statements on transient topic-not-found errors
PR-11023 - Fix: KsqlTarget and SchemaRegistryUtil prefix collision
PR-11014 - Feat(config): deprecate ksql.runtime.feature.shared.enabled
PR-11010 - Mark spotbugs-annotations as provided scope as they are only used for static code analysis.
PR-11009 - Fix type mismatch error.
e8475caf - Bump Netty to 4.1.132.Final
PR-10988 - Fix to prevent error when HTTP response fails in KsqlTarget
PR-10985 - Remove cc-docker-ksql as downstream branch
PR-10986 - Remove unused dependency for airlift.
PR-10975 - Add a no arg constructor for ProtobufNoSRConverter
PR-10971 - Remove duplicate definition for pr_ci_gating.
PR-10970 - Fix printTopic error when SSL is enabled
512f69e5 - Backport pr_ci_gating and status_level from master to service.yml
REST Proxy
PR-1473 - Disable javaType resolution in JSONSCHEMA consumer (7.5.x)
PR-1449 - Fix integration test failures (rate limit broken pipe, Jackson string length)
PR-705 - Add explicit jetty-alpn-java-client version after common dropped jetty-bom (7.9.x)
PR-704 - Add explicit jetty-alpn-java-client version after common dropped jetty-bom (7.8.x)
e918b7a1 - Update async-http-client
9af8e309 - Remove Jackson definitions already present in common
b77450cc - Use mvn help:evaluate instead of regex for VERSION fallback
32898c8a - Tighten VERSION grep and drop unused mkdir BINPATH
PR-684 - Bump async-http-client to 2.14.5
PR-669 - Fix header validation to allow colons in header values
de983175 - Backport pr_ci_gating and status_level from master to service.yml
Schema Registry
bbd699d9 - Adjust logging level in NONE action
PR-4312 - Add size limit handler
57320568 - Add allow package config for JSON deserializer
75b6c604 - Fix AWS KMS driver to use AssumeRoleWithWebIdentity in IRSA pods
560bf4ca - Handle anyOf/allOf in JSON transforms
PR-4148 - DefaultToGlobal available in SRClient
118b46ba - Nits
fedca30c - Change structure to filter
a2d0b821 - Change header name
PR-4223 - Fix UriPercentEncoder to correctly encode multi-byte Unicode characters
865f274c - Tests structure change
1c62d809 - Expose exporter name as part of logs in schema exporter destination
108e27ab - Remove println
47f2ece1 - Fix compat check on circular ref for JSON Schema 2020-12-20
PR-4207 - Fix incorrect OpenAPI example for getSchemaOnly endpoints
PR-4199 - Fix handling of JSON Schema with a single child
PR-4193 - Fix FindTags endpoint handling of JSON Schema with oneOf containing $ref
89b3155e - Quote lang_version in service.yml to fix service-bot validation
52ac4f7c - Backport pr_ci_gating and status_level from master to service.yml
Version 7.9.7
Released May 2026
Community Features
ksqlDB
Implemented a security fix for ksqlDB.
Schema Registry
Resolved a security vulnerability in io.confluent.kafka-json-schema-serializer
Version 7.9.6
Released March 2026
Community Features
Common
0f55ed5b - Update Avro to 1.11.5 in 7.9.6
PR-902 - Add –direct-pom-edit support to ci.py for faster CI builds
745599ac - Update Jetty to 9.4.59
a9b992c5 - Update Log Redactor to 1.0.17 and Netty to 4.1.130
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
Kafka
PR-1952 - Skip fetching mavenurl from vault
PR-21624 - Deflake streams_broker_down_resilience_test
PR-21505 - Upgrade Jetty from 9.4.57 to 9.4.58
PR-1893 - Update Jetty to 9.4.59 in 3.9
PR-1883 - Update Netty to 4.1.130 in 3.9
PR-21300 - Remove templateData.js in release.py
PR-21288 - Fix rare producer message corruption, don’t reuse buffers
PR-21255 - Upgraded Jose4J to 0.9.6 to remediate
PR-21243 - Fix the broken quick start link
PR-21137 - Change example kafka-storage command in the migration section
PR-19263 - AlterConfigPolicy incompatibility between ZK mode and KR
PR-21138 - Gracefully handle exceptions when handling AllocateProducerIdsResponse
PR-21155 - TaskManager may not close all tasks on task timeouts
PR-21104 - Document support for testing with java 25 (3.9)
PR-21109 - Updating doc for process exceptional handler in case of global threads
PR-21035 - Update lz4 dependency version
PR-21085 - Upgrade commons-validator to 1.10.1 (3.9)
PR-21026 - Support testing with Java 25 using Gradle Java Toolchains (3.9)
PR-21063 - OffsetFetch API does not return group level errors correctly with version 1
PR-20535 - Retain last batch in each round of cleaning
PR-16845 - [1/2] System test framework for consumer protocol migration
PR-20897 - Replace the base image since openjdk image is deprecated
ksqlDB
REST Proxy
Schema Registry
88b49837 - Checkstyle lint
5f7409e0 - Fix params
PR-4089 - Fix MetadataEncoderService key rotation and add test coverage
ee7d984f - Fix Avro union evolution for specific reader
PR-4077 - Exclude common-lang-2.6 from rest-utils to avoid conflicts with common-lang3
13cd3fc7 - Add more tests for DEK rewrap functionality
PR-4046 - Add tool to rewrap DEKs with latest version of KEK
PR-4041 - Extract Context prefix logic in delete mode to a method
PR-4033 - Don’t throw exception for JSON schema with format=serialized
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
e5703b49 - Fix assert of 7.9.x Junit
PR-4001 - Add support for recursive mode delete
Version 7.9.5
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
25ab4be8 - Fix the scope of imported pom
4eab14b4 - Update netty and bouncycastle
1b8bb0d3 - Add dependency management for grpc libraries and commons-lang3
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
c3793950 - Update azure libraries
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
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
fdbb7f8a - Update bc-fips versions to match ce-kafka / latest security updates in verified fips version
a86ab6d5 - Update jetty, add bc-fips to renovatebot ignore file
PR-819 - Update dependency org.bouncycastle:bc-fips to v2.1.1 [SECURITY] (7.2.x)
Kafka
PR-20877 - Add Java 21 and 23 to supported version
PR-18752 - Adding checkpointing for GlobalKTable during restoration and closing
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-20646 - Clear pendingTasksToInit on tasks clear
PR-20624 - –no-initial-controllers should not assume kraft.version=1
PR-20627 - Recreate /migration when it has null value
ksqlDB
PR-10903 - Update dependency io.vertx:vertx-web to v4.5.22
PR-10361 - Classify exceptions as user errors
PR-10893 - Exclude kafka.brokerTypeTopicClient from thread pool check
PR-10869 - Upgrade jline dependency to address terminal sizing issue
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
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
PR-10845 - Unpin jackson version
PR-10841 - Unpin jackson version and upgrade shade plugin
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
1bd6fe9d - Update netty version
cf858512 - Update netty version
02310d14 - Update netty version
73f28ebd - Update netty version
d760e504 - Update netty version
a3f4c676 - Update netty version
53ee8cae - Update netty version
PR-10795 - Update dependency io.netty:netty-codec-http2 to v4.1.124.Final [SECURITY] (7.2.x)
ff42df17 - Update dependency io.netty:netty-codec-http2 to v4.1.124.Final [SECURITY]
REST Proxy
Schema Registry
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-3981 - Fix use of JSON Schema serializer for key
PR-3977 - Minor optimization to remove synchronized block
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-3955 - Ensure canonicalString() method is thread-safe
PR-3950 - In AvroConverter use name-based getter/setter only for valid names
f122adbe - Fix junit version calls
PR-3790 - Always add X-Forward header to request forwarded to leader
PR-3935 - Ensure payloads are not unnecessarily redacted in DLQ
PR-3924 - Add AppRole auth for HC Vault
PR-3901 - Add golden file to test for MD5 regression
PR-3902 - Follow up PR to handle old CP versions
PR-3896 - Update RestService warn log to include error class name
PR-3890 - Ensure tags are used during schema evolution
PR-3884 - DeleteSubject message handler should only delete non-deleted versions
PR-3880 - Fix exception when evolving Avro schema with rules
PR-3876 - Fix merge issue; add JavaDoc for invalidate methods
PR-3875 - Refine cache invalidation
PR-3868 - Only retry + throw exception on exception related to network connections
PR-3871 - Some fixes to tests/lints
PR-3870 - Add sr-version to sr client API
1cdf19fe - Re-organize imports
PR-3864 - Organizing imports
PR-3862 - Add deployment metadata endpoint
Version 7.9.4
Released October 2025
Community Features
Kafka
Commercial Features
Connect
Bug fix: Confluent Enterprise distribution of Kafka Connect workers (CE, connect-server, or connect-server-base): Fixed a plugin class loading bug that prevented certain non-isolated classes (for example, javax.jms) from being loaded from plugin JARs. For more information, see article.
Version 7.9.3
Released September 2025
Community Features
Common
92007c48 - Update jetty to 9.4.58.v20250814 in 7.9.3
83c69d84 - Update netty to 4.1.225
94288a36 - Use correct versions of fips providers
PR-808 - adding license for assembly-plugin-boilerplate and build-tools modules
79dbce2c - Update jackson bom to match ce-kafka version
06637ab6 - Pin commons beanutils and validator
Kafka
PR-20529 - Fix TransactionStateManager handling of empty batch when loading transaction metadata (#20529)
PR-1787 - Update netty to 4.1.125 in 3.9
PR-20433 - Bump Commons-Lang
PR-20404 - Log ‘Listeners are not identical across brokers’ message at INFO instead of ERROR (#20404)
PR-1775 - Bump jetty to version 9.4.58.v20250814 in 3.9
PR-17620 - Fix RoundRobinPartitioner for even partition counts (#17620)
PR-1763 - Add run_tags to worker-ami and aws-packer
PR-1748 - Change ci_tools import path
PR-20272 - State updater sensor names should be unique (#20262) (#20272)
PR-20258 - Set OP_WRITE interest after SASL reauthentication to resume pending writes (#20258)
PR-1706 - In case of infra failure in ccs-kafka tag that as infra failure in testbreak
PR-20179 - Cherrypick “MINOR : Handle error for client telemetry push (#19881)” (#20179)
PR-20142 - Undeprecate JoinGroup V0 & V1 (#20142)
PR-1682 - Migrate from vagrant to terraform
PR-1674 - Exclude newly added files to fix build
PR-1665 - Add cloudwatch metrics to view cpu, memory and disk usage
PR-19745 - Fix BrokerLifecycleManager RPC timeouts (#19745)
PR-19974 - Bug fix in deleteAcls operation
PR-1652 - Upgrade ducktape and requests version
PR-19817 - MetadataShell execution unintentionally deletes lock file (#19817)
ksqlDB
PR-10869 - Upgrade jline dependency to address terminal sizing issue
94c228a6 - Bump up tcnative dependency.
1be709ce - Update netty to 4.1.125 in 7.9.3
PR-10833 - Set the order of timestamp fields to be processed to avoid incorrect modifications for daylight savings.
PR-10791 - Add option to use local mode in proxy protocol headers.
PR-10782 - Improve configuration filtering for 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 - Bump the commons-lang3 version to 3.18.0
REST Proxy
f05cee42 - Remove bc dependency that is being merged in bc-prov
PR-1403 - Hardcoding the CP rpm and deb installation dependency version
33f20c6e - Add comment to explain acceptAnySpiffeId
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
913fe83a - Add more constructor
e93773ec - Add new consturctor to application server
94b1e7bb - Add more comments for the sample HelloWorldSpireApplication
a7f06a76 - Make all the test to use SSL_CLIENT_AUTHENTICATION_CONFIG instead
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
affb8342 - Create HelloWorldApplication with s2s based on spire
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
62abe019 - Implement mock class in spire Test
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
53e0fd45 - Add PREFIX_SNI_PREFIX_CONFIG
da8cf6fe - Restrict sni prefix validation to certain prefix
Schema Registry
PR-3860 - Add sr type endpoint
PR-3837 - Hardcoding the CP rpm and deb installation dependency version
PR-3850 - Prevent re-registration of schema with dangling reference
PR-3851 - For shared KEKs avoid calling KMS when deleting DEKs
PR-3840 - Fix build due to Jackson upgrade to 2.16
PR-3838 - Upgrade json-sKema to 0.24.0
PR-3822 - Allow alternate KMS key IDs on a KEK
PR-3821 - Upgrade commons lang version
PR-3825 - Add Apache and CCL licenses to the dek-* modules
PR-3823 - Fix license headers
752b07bc - Minor refactor to add subject to create DEK API
PR-3810 - Fix : Subject config and mode should be deleted on hard delete
PR-3816 - Ensure DEKs are decrypted if version=-1 for shared KEKs
PR-3808 - Add support for JSON Schema 2020-12 in JsonSchemaUtils
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-3797 - Fix license headers
PR-3783 - Support for license headers
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-3766 - Support a true global config/mode
PR-3767 - Upgrade jackson-datatype-protobuf to 0.9.16
PR-3760 - 7.8 below java doc fix
PR-3761 - Javadoc fix in ParsedSchema
PR-3758 - Add javadoc as part of the maven build
PR-3750 - Bump max DEK registry key default
PR-3746 - Generate correct field type for Decimal in JSON converter
PR-3738 - Send ConnectException for IO exceptions in connect converters
42349149 - Exposed context name for mode/config errors
PR-3724 - Upgrade everit json-schema to 1.14.6
Version 7.9.2
Released June 2025
Community Features
Common
44f2c2e4 - Update jmx FF-20502
5d925b59 - Update AWS SDK V2 to 2.27.9 for 7.9.x
PR-778 - Add property for AWS SDK v2
467efd8f - Fix missing version definition
cbc66130 - Add commons-compress to unify versions with ce-kafka
0a1d3244 - Update aws sdk to match ce-kafka
54d73bbe - Update azure dependendecies to versions defined in azure-bom 1.2.32
fde07db0 - Update netty to 4.1.118
f982ea91 - Update bouncycastle dependencies
29819815 - Update jetty to 9.4.57
Kafka
PR-1634 - Replace all occurrences of ‘s1-prod-ubuntu20-04’ with ‘s1-prod-ubuntu24-04’ (#1554)
PR-19658 - Prevent livelocked elections (#19658)
PR-19631 - Fix commit bugs caused by race condition during rebalancing. (#19631)
PR-1619 - Cherry pick fix for Dexcom
PR-19563 - Add note in ZK to KRaft migration (#19563)
14169327 - Bump version to 3.9.1
5681889f - Push the branch with the RC tag
ksqlDB
PR-10744 - Return a server error for host unavailability errors in pull queries.
PR-10722 - Update dependency Pygments to v2.15.1 [SECURITY] (7.1.x)
PR-10728 - Update the ZK notices text version under licenses
PR-10726 - Update dependency jinja2 to v3.1.6 [SECURITY] (7.1.x)
a4fe7a51 - Changes in additional places
57537e6a - Addressing comments
0f6f2a62 - Abstracting oauth implementation
PR-10686 - Update netty
b7c8a55f - Bouncy castle fix
PR-10671 - Unpinned Jetty Version
PR-10653 - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
f6c26e7a - Fix the placement of default port number and capture the sub path while creating a client to ksqlDB.
8bfe4b59 - Update vertx to 4.4.8 for 7.1.x
PR-10620 - Fix jsonschema dependency
REST Proxy
1233e45d - Change imports to confluent package
PR-491 - Add configuration hsts.header.enable to control whether we response with HSTS header
fcba5cf4 - Trigger cla-status-check
6480173f - Rename snihandler
c23b84c7 - Add config: sni.host.check.enabled for SNI host checking in SecureRequestCustomizer
034b803a - Implement TenantPrefixSniHandler to perform prefix validation using the tenant name
3b3ff728 - Add config for forwarded request customizer
PR-547 - Allow attaching NetworkTrafficListener to connectors of unnamed application
PR-536 - [7.9.x] Allow for upgrade to jetty and unpin jetty-servlets
Schema Registry
PR-3711 - Add warning log whenever baseUrl changes in RestService
PR-3710 - Improve unit test coverage (edge case handling) for SetCompatibilityMojoTest
PR-3706 - Bump dependency versions for GCP
PR-3698 - Distinguish between null and missing props for PUT
PR-3691 - Start with first URL in UrlList
PR-3693 - Ensure AvroConverter does not rely on field order
PR-3688 - Use aws-java-sdk-v2.version from common
PR-3690 - Downgrade aws sdk v2 to match kafka on 7.7.x
PR-3682 - Ignore JSON schema fields not in the Java class
306f08dc - Upgrade mbknor library to 1.0.39.3
7505a200 - Handle default context properly for /config and /mode
PR-3664 - Log schema reads, writes and deletes
PR-3648 - Update dependency junit:junit to v4.13.1 [SECURITY] (7.1.x)
PR-3666 - Add RuleSet.isEmpty method
PR-3662 - Update the ZK notices text version under licenses
PR-3661 - Add new cache schema registry method
PR-3656 - Add minimal validation for certain KMS key IDs
PR-3641 - Add retry test for ser/de/restservice
PR-3640 - Handle URL-encoded paths in ContextFilter
PR-3636 - Support new CachedSchemaRegistryClient in SchemaRegistryClientFactory
PR-3631 - Deep copy for Schema
PR-3621 - Always override X-Forwarded-For header on follower call
PR-3619 - Expand semantic check when looking up schemas
PR-3581 - SR dek paginations
PR-3616 - Update test to use qualified subject names and fix a typo
PR-3615 - Upgrade to aws sdk 2.30.33
PR-3614 - Increase max length for kek and rule names
PR-3610 - Exclude an imported 3P util class from test coverage
PR-3609 - Add dek-registry module for coverage aggregation
PR-3608 - Test coverage: fix the module and updated the tests.
76c315ae - Ensure use of DEK object is thread-safe
PR-3605 - Update deps for CSPs
PR-3600 - Fix message reader to allow for interactive usage
PR-3599 - Improve test coverage (no feature change)
PR-3590 - Add retry for schema exporter upon IOException
PR-3582 - Add missing tests for DekRegistry
5e23bc86 - HostSslSocketFactory for bouncycastle fix.
PR-3592 - Enhance integration test w/additional lookup
PR-3591 - USTORAGE-1069: Call close on custom auth provider
PR-3584 - Upgrade json-skema to 0.20
PR-3578 - Pagination of SR APIs (Subject and Schema)
PR-3575 - Support Protobuf oneof fields in Data Contract rules
PR-3573 - Upgrade commons.validator to 1.9.0
PR-3561 - Ensure that DEK lookups use applicable aliases
PR-3559 - Setting default SSLSocketFactory from HttpsURLConnection in RestService.
PR-3555 - Ensure lookup by schema logic matches logic during register
PR-3544 - Upgrade everit json-schema to 1.14.5
PR-3542 - Bouncy Castle and SunJSSE compatibility fix (additional flows)
PR-3538 - Bouncy Castle and SunJSSE compatibility fix.
PR-3539 - Fix inline tag retrieval for JSON Schema with null in array
PR-3527 - Set pagination limit for subjects to INT_MAX
PR-3523 - Retry on NotLeaderOrFollowerException
Version 7.9.1
Released May 2025
Community Features
Kafka
9310f401 - Bump year of NOTICE
PR-19345 - Fix doc for remote.storage.enable (#19345)
PR-19127 - The kcontrollers must set kraft.version in ApiVersionsResponse (#19127)
988da9fc - Missing change for cherry-pick
PR-19223 - FetcherThread should match leader epochs between fetch request and fetch state (#19223)
PR-18852 - Better handle invalid records during replication (#18852)
PR-19188 - Fix onBatchRestored call in GlobalStateManagerImpl (#19188)
PR-19396 - Add Java 23 to CI (#19396)
PR-19213 - Reset interval.ms By Using kafka-client-metrics.sh (#19213)
PR-19221 - Add SecurityManagerCompatibility shim (#16522) (#19221)
PR-19310 - Upgrade spotbug to work under java 23 (3.9 backport) (#19310)
PR-19307 - Update Scala version to 2.13.15 for support Java 23 (3.9 backport) (#19307)
PR-19309 - Fix “this-escape” compiler warnings (MultiThreadedEventPr… (#19309)
PR-19308 - Fix “this-escape” compiler warnings (BrokerTopicMetrics) … (#19308)
PR-19303 - Fix foreign key INNER join on change of FK from/to a null value (#19303)
PR-19005 - Fix FK Left-Join result race condition (#19005)
PR-19150 - Cancel RemoteLogReader gracefully (#19150)
PR-19312 - Update EosIntegrationTest for EOSv1 (#19312)
PR-19164 - Kafka Streams incorrectly commits TX during task revokation (#19164)
PR-19138 - High CPU usage when using Log4j2 (#19138)
PR-19058 - Stale features information in QuorumController#registerBroker (#19058)
PR-18387 - Kafka is improperly validating non-advertised listeners for routable controller addresses (#18387)
PR-1592 - [3.9] Update netty to 4.1.118.Final
PR-18916 - The acls would appear at the wrong level of the metadata shell “tree” (#18916)
Version 7.9.0
Released February 2025
Community Features
Common
ae46dddf - update jetty
d1341a9b - add commons codec to dependency management
fbb9acf3 - pin version of mina-core to override version from jetty
9277c65c - update netty to 4.1.115
35ba77cd - Change version of bctls-fips to 1.0.13
bbde81e9 - Change version of bctls-fips to 1.0.13
c3786289 - Change version of bctls-fips to 1.0.13
f78bf5b6 - Change version of bctls-fips to 1.0.13
da4ebe39 - Change version of bctls-fips to 1.0.13
86e4f1e2 - Change version of bctls-fips to 1.0.13
93da41d2 - Change version of bctls-fips to 1.0.13
60e02333 - Change in bouncycastle bctls due to downstream failures
3bb5287b - Change in bouncycastle
16ab459f - Change in bouncycastle
9af7b9a3 - Change in bouncycastle
f478c73e - Change in bouncycastle
644fbf03 - Change in bouncycastle
c02b71d4 - Change in bouncycastle
62ad6c9a - Change in bouncycastle
PR-708 - Change in bouncycastle fips libraries upgrade
PR-706 - rename okio -> okio-jvm
7fa06075 - update cyclonedx plugin( #704)
fb4f806f - add okio-jvm to dependencyManagement to match ce-kafka
PR-688 - Merge Conflict Resolution (from 7.6.x to 7.7.x)
PR-687 - update jetty to 9.4.56
PR-684 - define version of commons-io and add it to dependencyManagement
79d5047d - upgrade avro to 1.11.4 to patch AVRO-3985
39d5e6aa - upgrade avro to 1.11.4 to patch AVRO-3985
Kafka
PR-18833 - KAFKA-18758: NullPointerException in shutdown following InvalidConfigurationException (#18833)
PR-1579 - CCS CP release test regex updates
PR-18843 - KAFKA-806 Index may not always observe log.index.interval.bytes (#18843)
PR-18767 - KAFKA-18675 Add unit test to verify space separated brokers won’t cause exception for 3.8 and 3.9 (#18767)
PR-17836 - KAFKA-18028 the effective kraft version of –no-initial-controllers should be 1 rather than 0 (#17836)
PR-17773 - KAFKA-18001: Support UpdateRaftVoterRequest in KafkaNetworkChannel (#17773)
PR-18741 - KAFKA-18171: Revert the strict config validation for 3.8 and 3.9 (#18741)
PR-18736 - KAFKA-18663: Metadata v0-v3 should be undeprecated (#18736)
PR-1553 - [3.9] Update jetty to 9.4.57.v20241219
PR-18690 - KAFKA-18597 Fix max-buffer-utilization-percent is always 0 (#18690)
PR-17510 - KAFKA-17792: Efficiently parse decimals with large exponents in Connect Values (#17510)
PR-18657 - KAFKA-18583; Fix getPartitionReplicaEndpoints for KRaft (#18657)
PR-18607 - KAFKA-17402: DefaultStateUpdated should transit task atomically (#18607)
PR-18587 - KAFKA-8862: Improve Producer error message for failed metadata update (#18587)
PR-18485 - Cherrypick lock backoff retry to 3.9 (#18485)
PR-18565 - KAFKA-18546: Use mocks instead of a real DNS lookup to the outside (#18565)
PR-18490 - KAFKA-18479: RocksDBTimeOrderedKeyValueBuffer not initialized correctly (#18490)
155d7720 - HOTIFX: fix broken build
PR-18281 - KAFKA-18330: Update documentation to remove controller deployment limitations (#18281)
PR-17728 - KAFKA-17973: Relax Restriction for Voters Set Change (#17728)
PR-17527 - KAFKA-17455: fix stuck producer when throttling or retrying (#17527)
PR-18287 - KAFKA-18326: fix merge iterator with cache tombstones (#18287)
PR-18333 - KAFKA-18272: Deprecated protocol api usage should be logged at info level (3.9) (#18333)
PR-18323 - KAFKA-18352: DeleteGroups v0 incorrectly tagged as deprecated (3.9) (#18323)
PR-18306 - KAFKA-18342 Use File.exist instead of File.exists to ensure the Vagrantfile works with Ruby 3.2+ (#18306)
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-18206 - KAFKA-17507; WriteTxnMarkers API must not return until markers are written and materialized in group coordinator’s cache (#18168) (#18206)
PR-18180 - KAFKA-18237: Upgrade system tests from using 3.7.1 to 3.7.2 (#18180)
PR-18207 - KAFKA-18263; Group lock must be acquired when reverting static membership rejoin (#18207)
PR-18127 - KAFKA-18199; Fix size calculation for nullable tagged structs (#18127)
PR-17352 - KAFKA-17030; Unattached voters will fetch from bootstrap servers (#17352)
PR-17920 - KAFKA-18047: Add org.apache.kafka.automatic.config.providers to System Properties section (#17920)
PR-17970 - KAFKA-18100 Using block suppresses all errors (#17970)
PR-17919 - KAFKA-17299: add unit tests for previous fix (#17919)
PR-17899 - KAFKA-17299: Fix Kafka Streams consumer hang issue (#17899)
PR-17883 - KAFKA-18051: Disallow creating ACLs with principals that do not contain a colon (#17883)
PR-17898 - KAFKA-18063: SnapshotRegistry should not leak memory (#17898)
PR-17711 - KAFKA-17850: fix leaking internal exception in state manager (#17711)
PR-17713 - KAFKA-17954: Error getting oldest-iterator-open-since-ms from JMX (#17713)
PR-17839 - KAFKA-18029 Fix quorum_reconfiguration_test.py (#17839)
PR-17817 - KAFKA-17994 Checked exceptions are not handled (#17817)
PR-17794 - KAFKA-17995: Fix errors in remote segment cleanup when retention.ms is large (#17794)
PR-17799 - Update javadoc on split to mention first matching (#17799)
6ea2ed3d - KAFKA-17801: RemoteLogManager may compute inaccurate upperBoundOffset for aborted txns (#17676) (#1 7733)
PR-17710 - KAFKA-17872: Update consumed offsets on records with invalid timestamp (#17710)
PR-17723 - KAFKA-17969 Fix StorageToolTest for 3.9 (#17723)
PR-17686 - KAFKA-17635: Ensure only committed offsets are returned for purging (#17686)
cc53a632 - Bump version to 3.9.0
PR-17683 - Removed Set.of usage (#17683)
PR-1510 - RCCA-23509: Modified Set.of usage in ReplicationControlManagerTest.java to resolve build failures.
PR-17604 - [KAFKA-17870] Fail CreateTopicsRequest if total number of partitions exceeds 10k (#17604)
PR-17597 - KAFKA-17868: Do not ignore –feature flag in kafka-storage.sh (#17597)
PR-1498 - [MINOR]: Fix version check in util.py
PR-17504 - KAFKA-17794: Add some formatting safeguards for KIP-853 (#17504)
PR-17499 - KAFKA-17031: Make RLM thread pool configurations public and fix default handling (#17499)
PR-1452 - Bump commonsIo to version 2.16.0
5989c2b1 - Revert “KAFKA-17520 align the low bound of ducktape version (#17481)”
86380a21 - Revert “KAFKA-17520 Align ducktape version in tests/docker/Dockerfile and tests/setup.py (#17482)”
71839deb - KBROKER-295: Ignore failing quota_test
PR-17501 - KAFKA-17790: Document that control.plane.listener should be removed before ZK migration is finished (#17501)
796ce212 - KAFKA-17788: During ZK migration, always include control.plane.listener.name in advertisedBrokerListeners
0bc10f33 - KBROKER-295: Ignore failing quota_test
PR-17508 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960) (#17461) (#17508)
PR-1438 - KNET-15450: disable flakey test
PR-17481 - KAFKA-17520 align the low bound of ducktape version (#17481)
PR-17482 - KAFKA-17520 Align ducktape version in tests/docker/Dockerfile and tests/setup.py (#17482)
PR-17453 - KAFKA-17753 Update protobuf and commons-io dependencies (#17453)
PR-17461 - KAFKA-17193: Pin all external GitHub Actions to the specific git hash (#16960) (#17461)
44f15cc2 - KAFKA-17749: Fix Throttler metrics name
PR-16387 - KAFKA-16972 Move BrokerTopicMetrics to org.apache.kafka.storage.log.metrics (#16387)
PR-17431 - KAFKA-17731: Removed timed waiting signal for client telemetry close (#17431)
PR-17430 - KAFKA-17749: Fix Throttler metrics name (#17430)
PR-17421 - KAFKA-17735: release.py must not use home.apache.org (#17421)
PR-17436 - KAFKA-17753: Update protobuf and commons-io dependencies (#17436)
PR-17434 - KAFKA-17751; fix pollTimeout calculation in pollFollowerAsVoter (#17434)
PR-17400 - KAFKA-17714 Fix StorageToolTest.scala to compile under Scala 2.12 (#17400)
PR-16770 - KAFKA-17146 Include note to remove migration znode (#16770)
PR-17363 - KAFKA-16927; Handle expanding leader endpoints (#17363)
PR-17359 - KAFKA-17062: handle dangling “copy_segment_start” state when deleting… (#17359)
596bb90c - Bump protobuf to 3.25.5
PR-1438 - KNET-15450: disable flakey test
PR-17305 - KAFKA-17636 Fix missing SCRAM bootstrap records (#17305)
PR-17146 - KAFKA-17608, KAFKA-17604, KAFKA-16963; KRaft controller crashes when active controller is removed (#17146)
PR-17081 - KAFKA-16963: Ducktape test for KIP-853 (#17081)
PR-17278 - KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258) (#17278)
PR-17258 - KAFKA-17584: Fix incorrect synonym handling for dynamic log configurations (#17258)
PR-16337 - KAFKA-16955: fix synchronization of streams threadState (#16337)
PR-17250 - KAFKA-17459 Stabilize reassign_partitions_test.py (#17250)
PR-17210 - KAFKA-17543: Improve and clarify the error message about generated broker IDs in migration (#17210)
PR-17218 - Revert “KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)” (#17218)
PR-17192 - KAFKA-17543: Enforce that broker.id.generation.enable is not used when migrating to KRaft (#17192)
PR-17169 - KAFKA-17527: Fix NPE for null RecordContext (#17169)
PR-17159 - KAFKA-16468: verify that migrating brokers provide their inter.broker.listener (#17159)
PR-17115 - KAFKA-17489: Do not handle failed tasks as tasks to assign (#17115)
PR-17147 - KAFKA-17506 KRaftMigrationDriver initialization race (#17147)
PR-17004 - KAFKA-15793 Fix ZkMigrationIntegrationTest#testMigrateTopicDeletions (#17004)
PR-17084 - KAFKA-17458 Add 3.8 to transactions_upgrade_test.py, transactions_mixed_versions_test.py, and kraft_upgrade_test.py (#17084)
PR-17128 - KAFKA-17492 skip features with minVersion of 0 instead of replacing 0 with 1 when BrokerRegistrationRequest < 4 (#17128)
PR-17131 - KAFKA-17497 Add e2e for zk migration with old controller (#17131)
PR-17101 - KAFKA-17417 Backport KAFKA-15751 and KAFKA-15752 to 3.8 and Enable KRaft for BaseAdminIntegrationTest and SaslSslAdminIntegrationTest (#15175) (#17101)
PR-17119 - KAFKA-17457 Don’t allow ZK migration to start without transactions (#17094) (#17119)
PR-17118 - KAFKA-15648 Update leader volatile before handleLeaderChange in LocalLogManager (#17118)
PR-17094 - KAFKA-17457 Don’t allow ZK migration to start without transactions (#17094)
PR-17054 - KAFKA-16448: Add timestamp to error handler context (#17054)
PR-17067 - KAFKA-17454 Fix failed transactions_mixed_versions_test.py when running with 3.2 (#17067)
PR-17051 - KAFKA-17412: add doc for unclean.leader.election.enable in KRaft (#17051)
PR-16873 - KAFKA-17331 Throw unsupported version exception if the server does NOT support EarliestLocalSpec and LatestTieredSpec (#16873)
PR-17024 - KAFKA-17434: Do not test impossible scenarios in upgrade_test.py (#17024)
PR-16959 - KAFKA-17062: handle dangling “copy_segment_start” state when deleting remote logs (#16959)
PR-16866 - KAFKA-12670: Support configuring unclean leader election in KRaft (#16866)
PR-16620 - KAFKA-15746: KRaft support in ControllerMutationQuotaTest (#16620)
PR-16904 - KAFKA-15406: Add the ForwardingManager metrics from KIP-938 (#16904)
PR-17017 - KAFKA-17426; Check node directory id for KRaft (#17017)
PR-16990 - KAFKA-17335 Lack of default for URL encoding configuration for OAuth causes NPE (#16990)
PR-17012 - KAFKA-17422: Adding copySegmentLatch countdown after expiration task is over (#17012)
PR-16995 - KAFKA-17360 local log retention ms/bytes “-2” is not treated correctly (#16995)
PR-16932 - KAFKA-17360 local log retention ms/bytes “-2” is not treated correctly (#16932)
PR-16876 - KAFKA-17331 Set correct version for EarliestLocalSpec and LatestTieredSpec (#16876)
PR-16858 - KAFKA-17315 Fix the behavior of delegation tokens that expire immediately upon creation in KRaft mode (#16858)
PR-16893 - KAFKA-17336 Add IT to make sure the production MV does not use unstable version of LIST_OFFSET (#16893)
PR-16848 - KAFKA-17305; Check broker registrations for missing features (#16848)
PR-16900 - KAFKA-17333; ResignedState should not notify of leader change (#16900)
PR-16934 - KAFKA-17279: Handle retriable errors from offset fetches (#16826) (#16934)
PR-16659 - KAFKA-17169: Add EndpointsTest (#16659)
PR-16907 - KAFKA-17332; Controller always flush and can call resign on observers (#16907)
PR-16892 - KAFKA-16842; Fix config validation and support unknown voters (#16892)
PR-16775 - KAFKA-17238 Move VoterSet and ReplicaKey from raft.internals to raft (#16775)
PR-16870 - KAFKA-17326 The LIST_OFFSET request is removed from the “Api Keys” page (#16870)
PR-16862 - KAFKA-17304; Make RaftClient API for writing to log explicit (#16862)
PR-16865 - KAFKA-17319 change ListOffsetsRequest latestVersionUnstable to false (#16865)
PR-16836 - KAFKA-17300: Add document for new tiered storage feature in v3.9.0. (#16836)
PR-16863 - Kafka 16887 : Upgrade the document to add remote copy/fetch quotas metrics values. (#16863)
PR-16841 - KAFKA-17018: update MetadataVersion for the Kafka release 3.9 (#16841)
PR-16672 - KAFKA-17190: AssignmentsManager gets stuck retrying on deleted topics (#16672)
PR-16856 - KAFKA-17310 locking the offline dir can destroy the broker exceptionally (#16856)
PR-16820 - KAFKA-17067; Fix KRaft transition to CandidateState (#16820)
PR-16837 - KAFKA-16534; Implement update voter sending (#16837)
PR-16774 - KAFKA-16523; kafka-metadata-quorum: support add-controller and remove-controller (#16774)
PR-16753 - KAFKA-17223 Retrying the call after encountering UnsupportedVersionException will cause ConcurrentModificationException (#16753)
PR-16830 - KAFKA-16521: Have Raft endpoints printed as name://host:port (#16830)
PR-16773 - KAFKA-17242: Do not log spurious timeout message for MirrorCheckpointTask sync store startup (#16773)
PR-16767 - KAFKA-17232: Do not generate task configs in MirrorCheckpointConnector if initial consumer group load times out (#16767)
PR-16765 - KAFKA-17236: Handle local log deletion when remote.log.copy.disabled=true (#16765)
PR-16819 - KAFKA-17276; replicaDirectoryId for Fetch and FetchSnapshot should be ignorable (#16819)
PR-16709 - KAFKA-16584: Make log processing summary configurable or debug–update upgrade-guide (#16709)
PR-16811 - KAFKA-17227: Refactor compression code to only load codecs when used (#16782) (#16811)
PR-16782 - KAFKA-17227: Refactor compression code to only load codecs when used (#16782)
PR-16789 - KAFKA-17235 system test test_performance_service.py failed (#16789)
81edb74c - KAFKA-16533; Update voter handling
PR-16669 - KAFKA-16518: Implement KIP-853 flags for storage-tool.sh (#16669)
PR-16763 - KAFKA-17227: Update zstd-jni lib (#16763)
PR-16783 - KAFKA-16154: Broker returns offset for LATEST_TIERED_TIMESTAMP (#16783)
PR-16745 - KAFKA-16448: Unify error-callback exception handling (#16745)
PR-16653 - KAFKA-16855: remote log disable policy in KRaft (#16653)
PR-16693 - KAFKA-17205: Allow topic config validation in controller level in KRaft mode (#16693)
PR-16781 - KAFKA-16480: ListOffsets change should have an associated API/IBP version update (#16781)
PR-16780 - KAFKA-17245: Revert TopicRecord changes. (#16780)
PR-16715 - KAFKA-16390: add group.coordinator.rebalance.protocols=classic,consumer to broker configs when system tests need the new coordinator (#16715)
PR-16776 - KAFKA-16448: Update documentation (#16776)
PR-16748 - KAFKA-16666 Migrate GroupMetadataMessageFormatter` to tools module (#16748)
PR-16678 - KAFKA-17192 Fix MirrorMaker2 worker config does not pass config.provi… (#16678)
PR-16759 - KAFKA-16521; kafka-metadata-quorum describe command changes for KIP-853 (#16759)
PR-16300 - KAFKA-16448: Handle processing exceptions in punctuate (#16300)
PR-16736 - KAFKA-16448: Unify class cast exception handling for both key and value (#16736)
PR-16738 - Revert “KAFKA-16508: Streams custom handler should handle the timeout exceptions (#16450)” (#16738)
PR-16287 - KAFKA-16934: Clean up and refactor release.py (#16287)
PR-16689 - KAFKA-16666 Migrate OffsetMessageFormatter to tools module (#16689)
PR-16675 - KAFKA-16448: Handle fatal user exception during processing error (#16675)
PR-16726 - KAFKA-17214: Add 3.8.0 version to core and client system tests (#16726)
PR-16728 - KAFKA-17214: Add 3.8.0 version to streams system tests (#16728)
PR-16650 - KAFKA-15469: Add documentation for configuration providers (#16650)
PR-16432 - KAFKA-16448: Add ErrorHandlerContext in deserialization exception handler (#16432)
PR-16433 - KAFKA-16448: Add ErrorHandlerContext in production exception handler (#16433)
f26f0b66 - tests/kafkatest/version.py: Add 3.9.0 as DEV_VERSION
PR-16711 - KAFKA-17210: Broker fixes for smooth concurrent fetches on share partition (#16711)
PR-16637 - KAFKA-16953; Properly implement the sending of DescribeQuorumResponse (#16637)
PR-16702 - KAFKA-17202 surround consumer with try-resource statement (#16702)
PR-16599 - KAFKA-14569: Migrate Connect’s integration test EmbeddedKafkaCluster from ZK to KRaft mode (#16599)
PR-16683 - KAFKA-17060 Rename LegacyKafkaConsumer to ClassicKafkaConsumer (#16683)
PR-16682 - KAFKA-17194 Don’t create cluster for MetadataQuorumCommandTest#testCommandConfig (#16682)
PR-16674 - KAFKA-17177 reviewers.py should grep “authors” to offer more candidates of reviewers information (#16674)
PR-16668 - KAFKA-16915; LeaderChangeMessage supports directory id (#16668)
PR-16670 - KAKFA-16537; Implement remove voter RPC (#16670)
PR-16183 - KAFKA-16192: Introduce transaction.version and usage of flexible records to coordinators (#16183)
PR-16692 - KAFKA-17204: KafkaStreamsCloseOptionsIntegrationTest.before leaks AdminClient (#16692)
PR-16663 - KAFKA-16448: Fix processing exception handler (#16663)
PR-16373 - KAFKA-16558: Implemented HeartbeatRequestState toStringBase() and added a test for it (#16373)
PR-16688 - KAFKA-17195 remove generated code path from test scope of sourceSets (#16688)
PR-16671 - KAFKA-17176 Move FileLock to server-common module (#16671)
PR-16200 - KAFKA-15999 Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder (#16200)
PR-16576 - KAFKA-16765: Close leaked accepted sockets in EchoServer, NioEchoServer, ServerShutdownTest (#16576)
PR-16019 - KAFKA-16666 Migrate TransactionLogMessageFormatter to tools module (#16019)
PR-16500 - KAFKA-17021 Migrate AclCommandTest to new test infra (#16500)
PR-16639 - KAFKA-17160 Determine mockitoArtifactName based on mockitoVersion instead of JavaVersion (#16639)
PR-16656 - KAFKA-17179 Remove integration tag in class level when using ClusterTestExtensions (#16656)
PR-16558 - KAFKA-17104 InvalidMessageCrcRecordsPerSec is not updated in validating LegacyRecord (#16558)
PR-16657 - KAFKA-17168 Remove the logPrefix to print the thread name (#16657)
PR-16638 - KAFKA-17163 revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure (#16638)
PR-16509 - KAFKA-16584 Make log processing summary configurable or debug (#16509)
PR-16647 - KAFKA-16068: Use TestPlugins mechanism in ConnectorValidationIntegrationTest to prevent ERROR-level log spam in unrelated test suites (#16647)
PR-16645 - KAFKA-17149 Move ProducerStateManagerTest to storage module (#16645)
771b9576 - Bump version to 3.8.0
PR-16499 - KAFKA-16791 Add thread detection to ClusterTestExtensions (#16499)
9db5c248 - KAFKA-16535; Implement KRaft add voter handling
PR-16633 - KAFKA-17159 Make sure kafka-cluster-test-kit-executor get down when closing KafkaClusterTestKit (#16633)
PR-16641 - KAFKA-17166 Use NoOpScheduler to rewrite LogManagerTest#testLogRecoveryMetrics (#16641)
PR-16614 - KAFKA-17142 Fix deadlock caused by LogManagerTest#testLogRecoveryMetrics (#16614)
PR-16642 - KAFKA-17168 The logPrefix of RemoteLogReader/RemoteStorageThreadPool is not propagated correctly (#16642)
PR-16601 - KAFKA-17082 replace kafka.utils.LogCaptureAppender with org.apache.kafka.common.utils.LogCaptureAppender (#16601)
PR-16618 - KAFKA-17153 KafkaMetricsGroup#newGauge should accept functional interface instead of com.yammer.metrics.core.Gague (#16618)
PR-16635 - KAFKA-17144 Retract unimplemented ListGroups v6 added in error (#16635)
PR-16609 - KAFKA-17152 Make sure zk session tracker gets down when closing embedded zk (#16609)
PR-16640 - KAFKA-17172 Add @Tag(“integration”) to ClusterTest, ClusterTemplate, and ClusterTests (#16640)
PR-16587 - KAFKA-17132 Revisit testMissingOffsetNoResetPolicy for AsyncConsumer (#16587)
PR-16624 - KAFKA-17121 junit-platform.properties files in published artifacts pollute the test classpath of consumers (#16624)
PR-16093 - KAFKA-16448: Catch and handle processing exceptions (#16093)
PR-16569 - KAFKA-16984: Complete consumer leave on response to leave request (#16569)
PR-16623 - KAFKA-17095 Fix the typo from “CreateableTopicConfig” to “CreatableTopicConfig” (#16623)
PR-16540 - KAFKA-17077 The node.id is inconsistent to broker.id when “broker.id.generation.enable=true”. (#16540)
PR-16590 - KAFKA-17122 Change the type of clusterId from UUID to String (#16590)
PR-16622 - KAFKA-17118 remove useless code in StorageTool (#16622)
PR-16372 - KAFKA-16975 The error message of creating __cluster_metadata should NOT be “Authorization failed” (#16372)
PR-16543 - KAFKA-15773 Group protocol configuration should be validated (#16543)
PR-16603 - KAFKA-17135 Add unit test for ProducerStateManager#readSnapshot and ProducerStateManager#writeSnapshot (#16603)
PR-16612 - KAFKA-17141 ‘DescribeTopicPartitions API is not supported’ warning message confuses users (#16612)
PR-16617 - KAFKA-17148: Remove print MetaPropertiesEnsemble from kafka-storage tool (#16607) (3.8) (#16617)
PR-16608 - KAFKA-17150: Use Utils.loadClass instead of Class.forName to resolve aliases correctly (#16608)
PR-16581 - KAFKA-17105: Prevent redundant restarts for newly-created connectors (#16581)
PR-16607 - KAFKA-17148: Remove print MetaPropertiesEnsemble from kafka-storage tool (#16607)
PR-16502 - KAFKA-16853: Split RemoteLogManagerScheduledThreadPool (#16502)
PR-16598 - KAFKA-16383: Ensure tasks have already polled their consumers before producing verified records in MirrorConnectorsIntegrationBaseTest::testReplicateFromLatest (#16598)
PR-16449 - KAFKA-17017 AsyncKafkaConsumer#unsubscribe clean the assigned partitions (#16449)
PR-16451 - KAFKA-16943: Synchronously verify Connect worker startup failure in InternalTopicsIntegrationTest (#16451)
PR-16230 - KAFKA-16772: Introduce kraft.version to support KIP-853 (#16230)
e1bf1552 - KAFKA-17055; Use random replica ids in kraft protocol tests
PR-16461 - KAFKA-16730: Initial version of share group consumer client code (#16461)
PR-16588 - KAFKA-17133 add unit test to make sure ConsumerRecords#recoreds returns immutable object (#16588)
PR-16572 - KAFKA-17073 Deprecate ReplicaVerificationTool (#16572)
PR-14372 - KAFKA-14401: Fail kafka log read end requests if underneath work thread fails (#14372)
PR-16557 - KAFKA-17102 FetchRequest#forgottenTopics would return incorrect data (#16557)
PR-16574 - KAFKA-16743,KAFKA-16744: KafkaApis support for share group heartbeat and describe (#16574)
PR-15918 - KAFKA-16667 Avoid stale read in KRaftMigrationDriver (#15918)
PR-16573 - KAFKA-16741: Add ShareGroupHeartbeat API support - 2/N (KIP-932) (#16573)
PR-16571 - KAFKA-17097 Add replace.null.with.default configuration to ValueToKey and ReplaceField (#16571)
PR-16221 - KAFKA-16661: Added a lower log.initial.task.delay.ms value (#16221)
PR-16249 - KAFKA-16916: Fixing error in completing future (#16249)
PR-16217 - KAFKA-16905: Fix blocking DescribeCluster call in AdminClient DescribeTopics (#16217)
PR-16589 - KAFKA-17129 Revisit FindCoordinatorResponse in KafkaConsumerTest (#16589)
PR-16566 - KAFKA-17110 Enable valid test case in KafkaConsumerTest for AsyncKafkaConsumer (#16566)
PR-16564 - KAFKA-17106 enable testFetchProgressWithMissingPartitionPosition for AsyncConsumer (#16564)
PR-16518 - KAFKA-16532; Support for first leader bootstrapping the voter set (#16518)
PR-16559 - KAFKA-17096 Fix kafka_log4j_appender.py (#16559)
PR-16529 - KAFKA-17061 Improve the performance of isReplicaOnline (#16529)
PR-16541 - KAFKA-17092 Revisit KafkaConsumerTest#testBeginningOffsetsTimeout for AsyncConsumer (#16541)
PR-16570 - KAFKA-17098: Re-add task to state updater if transit to RUNNING fails (#16570)
PR-16565 - KAFKA-17111: explicitly register Afterburner module in JsonSerializer and JsonDeserializer (#16565)
PR-16561 - KAFKA-17085: Handle tasks in state updater before tasks in task registry (#16555) (#16561)
PR-16421 - KAFKA-17011: Fix a bug preventing features from supporting v0 (#16421)
PR-16506 - KAFKA-15853 Refactor ShareGroupConfig with AbstractConfig (#16506)
PR-16539 - KAFKA-17090 Add reminder to CreateTopicsResult#config for null values of type and documentation (#16539)
PR-16426 - KAFKA-17016 Align the behavior of GaugeWrapper and MeterWrapper (#16426)
PR-16555 - KAFKA-17085: Handle tasks in state updater before tasks in task registry (#16555)
PR-16475 - KAFKA-16228: Add remote log metadata flag to the dump log tool (#16475)
PR-16132 - KAFKA-16851: Add remote.log.disable.policy (#16132)
PR-15475 - KAFKA-16345: Optionally URL-encode clientID and clientSecret in authorization header (#15475)
PR-16532 - KAFKA-16684: Remove caching in FetchResponse.responseData (#16532)
PR-15999 - KAFKA-16254: Allow MM2 to fully disable offset sync feature (#15999)
PR-16530 - KAFKA-17071: SharePartition - Add more unit tests and minor enhancement (#16530)
PR-1398 - fixed downstream trigger
PR-16550 - KAFKA-10199: Close pending active tasks to init on partitions lost (#16545) (#16550)
PR-1394 - 3.8 fixed downstream trigger
PR-15756 - KAFKA-15838: KIP-1040: Add replace.null.with.default to InsertField, ExtractField, HeaderFrom, Cast, SetSchemaMetadata, TimestampConverter, MaskField transforms (#15756)
PR-16545 - KAFKA-10199: Close pending active tasks to init on partitions lost (#16545)
PR-16524 - KAFKA-17081 Tweak GroupCoordinatorConfig: re-introduce local attributes and validation (#16524)
PR-16488 - KAFKA-16731: Added share group metrics class. (#16488)
PR-11438 - KAFKA-13403 Fix broker crash due to race condition when deleting topics (#11438)
PR-16301 - KAFKA-16806 Explicitly declare JUnit dependencies for all test modules (#16301)
PR-16533 - KAFKA-17083: Update LATEST_STABLE_METADATA_VERSION in system tests (#16533)
PR-1413 - Update service.yml to use strings instead of floats for branches
PR-16508 - KAFKA-4374 Update log message for clarity metadata response errors (#16508)
PR-16523 - KAFKA-17059 Remove dynamicConfigOverride from KafkaConfig (#16523)
PR-16526 - Fix compilation error (#16526)
PR-16504 - KAFKA-16944; Rewrite Range Assignor (#16504)
PR-16516 - KAFKA-16741: Add share group classes for Heartbeat API (1/N) (KIP-932) (#16516)
PR-16498 - KAFKA-17058; Extend CoordinatorRuntime to support non-atomic writes (#16498)
PR-16086 - KAFKA-17069: Remote log copy throttle metrics (#16086)
PR-16454 - KAFKA-16529; Implement raft response handling (#16454)
PR-16477 - KAFKA-10816: Add health check endpoint for Kafka Connect (#16477)
PR-16513 - KAFKA-16754: Removing partitions from release API (KIP-932) (#16513)
PR-15302 - KAFKA-15917: Wait for zombie sink tasks’ consumers to commit offsets before trying to modify their offsets in integration tests (#15302)
PR-16459 - KAFKA-17026: Implement updateCacheAndOffsets functionality on LSO movement (#16459)
PR-16515 - Update License binary file with missing updates (#16515)
PR-16087 - KAFKA-15265: Remote fetch throttle metrics (#16087)
PR-16474 - KAFKA-17047: Refactored group coordinator classes to modern package (KIP-932) (#16474)
PR-16460 - KAFKA-17032 NioEchoServer should generate meaningful id instead of incremental number (#16460)
PR-16485 - KAFKA-16550 add integration test for LogDirsCommand (#16485)
PR-16480 - KAFKA-17051 ApiKeys#toHtml should exclude the APIs having unstable latest version (#16480)
PR-16403 - KAFKA-3346 Rename Mode to ConnectionMode (#16403)
PR-16400 - Revert “KAFKA-16154” and mark MV 3.8-IV0 as the latest production (#16400)
PR-1359 - [master] removes mk-include
PR-1368 - 3.8 removed mk-include and make init-ci from semaphore
PR-16457 - KAFKA-16750: Added acknowledge code in SharePartitionManager including unit tests (#16457)
PR-16482 - KAFKA-17050: Revert group.version (#16482)
PR-15224 - KAFKA-15727: Added KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest (#15224)
PR-16458 - KAFKA-16909 Refactor GroupCoordinatorConfig with AbstractConfig (#16458)
PR-16469 - KAFKA-17046 Upgrade netty version to 4.1.111.Final (#16469)
PR-16450 - KAFKA-16508: Streams custom handler should handle the timeout exceptions (#16450)
PR-16489 - KAFKA-17052: Downgrade ShadowJarPlugin to 8.1.3 (#16489)
PR-16478 - KAFKA-17050: Revert group.version from 3.8 (#16478)
PR-1351 - CONFLUENT: Downgrade io.github.goooler.shadow plugin to 8.1.3
PR-16312 - KAFKA-16000: Migrated MembershipManagerImplTest away from ConsumerTestBuilder (#16312)
PR-16399 - KAFKA-16536; Use BeginQuorumEpoch as leader heartbeat (#16399)
PR-16455 - KAFKA-17022 Fix error-prone in KafkaApis#handleFetchRequest (#16455)
ebaa1089 - KAFKA-16968: Introduce 3.8-IV0, 3.9-IV0, 3.9-IV1
PR-1346 - fixed RAT on CI builds
PR-16467 - KAFKA-10787 Apply spotless to all module (#16467)
PR-16054 - KAFKA-16822: Abstract consumer group to share functionality with share group (KIP-932) (#16054)
PR-16430 - KAFKA-16754: Implemented release acquired records functionality to SharePartition (#16430)
PR-16447 - KAFKA-15623 Remove junit 4 from stream module (#16447)
PR-16446 - KAFKA-16751: Implemented release acquired records functionality in SharePartitionManager (#16446)
PR-16431 - KAFKA-17003: Implemented SharePartitionManager close() functionality (#16431)
PR-16235 - KAFKA-16527; Implement request handling for updated KRaft RPCs (#16235)
PR-16448 - KAFKA-17034 Tweak some descriptions in FeatureUpdate (#16448)
PR-16441 - Revert “KAFKA-16275: Update kraft_upgrade_test.py to support KIP-848’s group protocol config (#16409) (#16441)
PR-15915 - KAFKA-16949: Fixing test_dynamic_logging in system test connect_distributed_test (#15915)
PR-16439 - KAFKA-16551 add integration test with bootstrap controller for ClusterTool (#16439)
PR-16440 - KAFKA-17028: FindCoordinator v6 initial implementation (#16440)
PR-16429 - KAFKA-16650 add integration test for Admin#abortTransaction (#16429)
PR-16257 - KAFKA-16855 : Part 1 - New fields tieredEpoch and tieredState (#16257)
PR-16424 - KAFKA-15623 (5/N) Migrate KafkaStreamsTest to JUnit 5 (#16424)
PR-16414 - KAFKA-16755: Implement lock timeout functionality in SharePartition (#16414)
PR-16344 - KAFKA-16965: Throw cause of TimeoutException (#16344)
PR-16413 - KAFKA-17013 RequestManager#ConnectionState#toString() should use %s (#16413)
PR-16408 - KAFKA-16551 add integration test for ClusterTool (#16408)
PR-16396 - KAFKA-15623 (4/N) Migrate streams tests (processor) module to JUnit 5 (#16396)
PR-16410 - KAFKA-16998 Fix warnings in our Github actions (#16410)
PR-16423 - KAFKA-17009 Add unit test to query nonexistent replica by describeReplicaLogDirs (#16423)
PR-15830 - KAFKA-15713 KRaft support in AclCommandTest (#15830)
PR-1312 - skipped build, compile, validations in public CI
PR-16409 - Revert “KAFKA-16275: Update kraft_upgrade_test.py to support KIP-848’s group protocol config (#16409)
PR-16377 - KAFKA-16749: Implemented share fetch messages (KIP-932) (#16377)
PR-16415 - KAFKA-17012 Enable CONSUMER protocol for some tests of KafkaConsumerTest (#16415)
PR-16416 - KAFKA-17007 Fix SourceAndTarget#equal (#16416)
PR-16397 - KAFKA-16999: Integrating persister API in Partition initialization (KIP-932) (#16397)
PR-16412 - KAFKA-10787 apply spotless to connect:runtime module (#16412)
PR-16211 - KAFKA-16531: calculate check-quorum when leader is not in voter set (#16211)
PR-16303 - KAFKA-16862: Refactor ConsumerTaskTest to be deterministic and avoid tight loops (#16303)
PR-16295 - KAFKA-16803: Change fork, update ShadowJavaPlugin to 8.1.7 (#16295)
PR-16356 - KAFKA-15623 (3/N) Migrate test of Stream module to Junit5 (Stream state) (#16356)
PR-16259 - KAFKA-16923 New Unit Test for stripDotPathComponents method (#16259)
PR-16401 - KAFKA-17000 Separating creation and configuration of Authorizer in AuthorizerTest (#16401)
PR-16394 - KAFKA-16976 Update the current/dynamic config inside RemoteLogManagerConfig (#16394)
PR-16393 - KAFKA-10787 Apply spotless to clients module (#16393)
PR-1308 - do not depend on vault on public CI
PR-16367 - KAFKA-16973; Fix caught-up condition (#16367)
PR-16317 - KAFKA-16939 Revisit ConfigCommandIntegrationTest (#16317)
PR-16360 - KAFKA-15623 (2/N) Migrate remaining tests in streams module to JUnit 5 (integration & internals) (#16360)
PR-1303 - removed vault secrets
PR-16368 - KAFKA-16725: Adjust share group configs to match KIP (#16368)
PR-16380 - KAFKA-15774: use the default dsl store supplier for fkj subscriptions (#16380)
PR-16383 - KAFKA-16921 [6/N] Remove junit 4 dependency from connect:runtime module (#16383)
PR-16392 - KAFKA-10787 Apply spotless to core module (#16392)
PR-16370 - KAFKA-16957 Enable KafkaConsumerTest#configurableObjectsShouldSeeGeneratedClientId to work with CLASSIC and CONSUMER (#16370)
PR-16385 - KAFKA-16989 Use StringBuilder instead of String concatenation (#16385)
PR-16339 - KAFKA-16753: Implement share acknowledge API in partition (KIP-932) (#16339)
PR-16333 - KAFKA-16952: Do not bump broker epoch when re-registering the same incarnation (#16333)
PR-16379 - KAFKA-16988: add 1 more node for test_exactly_once_source system test (#16379)
PR-16378 - KAFKA-10787 apply spotless to streams:examples and streams-scala (#16378)
PR-16348 - KAFKA-16958 add STRICT_STUBS to EndToEndLatencyTest, OffsetCommitCallbackInvokerTest, ProducerPerformanceTest, and TopologyTest (#16348)
PR-16355 - KAFKA-16547 Add test for DescribeConfigsOptions#includeDocumentation (#16355)
PR-16350 - KAFKA-16921 [5/N] Migrate test of connect module to Junit5 (Runtime subpackage) (#16350)
PR-16351 - KAFKA-16921 [4/N] Migrate test of connect module to Junit5 (Runtime direct) (#16351)
PR-16376 - KAFKA-16954: fix consumer close to release assignment in background (#16376)
PR-16353 - KAFKA-15265: Reapply dynamic remote configs after broker restart (#16353)
PR-16366 - KAFKA-16969: Log error if config conflicts with MV (#16366)
PR-16369 - [MINOR] Add a note for JBOD support for tiered storage (#16369)
PR-16343 - KAFKA-16954: fix consumer close to release assignment in background (#16343)
PR-15175 - KAFKA-15751, KAFKA-15752: Enable KRaft for BaseAdminIntegrationTest and SaslSslAdminIntegrationTest (#15175)
PR-16359 - KAFKA-16970 Fix hash implementation of ScramCredentialValue, ScramCredentialData, and ContextualRecord (#16359)
PR-16357 - KAFKA-10787 Apply spotless to stream:test-utils and :streams:upgrade-system-tests-xxxx (#16357)
PR-16309 - KAFKA-16673; Simplify GroupMetadataManager#toTopicPartitions by using ConsumerProtocolSubscription instead of ConsumerPartitionAssignor.Subscription (#16309)
PR-15924 - KAFKA-16669 Remove extra collection copy when generating DescribeAclsResource (#15924)
PR-16354 - KAFKA-16219 set SO_TIMEOUT in EchoServer (#16354)
PR-16280 - KAFKA-10190 Set dynamic broker configs for entity default (#16280)
PR-16341 - KAFKA-16898 move TimeIndexTest and TransactionIndexTest to storage module (#16341)
PR-16358 - KAFKA-16971 Fix the incorrect format string in QuorumConfigs#parseBootstrapServer (#16358)
PR-16338 - KAFKA-16932: Add documentation for the native docker image (#16338)
PR-16297 - KAFKA-10787 Apply spotless to metadata and server and storage module (#16297)
PR-16335 - KAFKA-16950: Define Persister interfaces and RPCs (#16335)
PR-16340 - KAFKA-16740: Added additional APIs for Share Partition (#16340)
PR-15986 - Revert new configurations from KAFKA-16525; Dynamic KRaft network manager and channel (#15986)
PR-16278 - KAFKA-10787 Apply spotless to raft module (#16278)
c29260f3 - Revert “KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs”
PR-16210 - KAFKA-16895 fix off-by-one bug in RemoteCopyLagSegments (#16210)
PR-16310 - KAFKA-16637 AsyncKafkaConsumer removes offset fetch responses from cache too aggressively (#16310)
PR-16319 - KAFKA-16946: Utils.getHost/getPort cannot parse SASL_PLAINTEXT://host:port (#16319)
PR-16330 - KAFKA-16921 [3/N] migrate connect module to junit 5 (#16330)
PR-16328 - KAFKA-16921 [2/N] migrate connect module to junit 5 (#16328)
PR-16250 - KAFKA-16917 DescribeTopicsResult should use mutable map in order to keep compatibility (#16250)
PR-16116 - KAFKA-15853: Move KafkaConfig.configDef out of core (#16116)
PR-16263 - KAFKA-16747: Implemented share sessions and contexts for share fetch requests (#16263)
PR-16272 - KAFKA-16933: New consumer unsubscribe close commit fixes (#16272)
PR-16321 - KAFKA-16948: Reset tier lag metrics on becoming follower (#16321)
PR-16231 - KAFKA-12708 Rewrite org.apache.kafka.test.Microbenchmarks by JMH (#16231)
PR-16331 - KAFKA-15045: (KIP-924 pt. 26) default standby task assignment nit (#16331)
PR-16274 - KAFKA-16752: Implemented acquire functionality for Fetch (KIP-932) (#16274)
PR-16254 - KAFKA-15623 (1/N) Migrate streams tests module to JUnit 5 (#16254)
PR-16298 - KAFKA-10787 Apply spotless to group-coordinator and group-coordinator-api (#16298)
PR-16266 - KAFKA-16879 SystemTime should use singleton mode (#16266)
PR-16282 - KAFKA-16076 Fix Missing thread interrupt call in RestClient class (#16282)
PR-16140 - KAFKA-16001: Migrated ConsumerNetworkThreadTest away from ConsumerTestBuilder (#16140)
PR-16322 - KAFKA-15045: (KIP-924 pt. 25) Rename old internal StickyTaskAssignor to LegacyStickyTaskAssignor (#16322)
PR-16253 - KAFKA-16921 [1/N] Migrate all junit 4 code to junit 5 for connect module (#16253)
PR-15890 - KAFKA-16643 Add ModifierOrder checkstyle rule (#15890)
PR-16318 - KAFKA-15045: (KIP-924 pt. 24) internal TaskAssignor rename to LegacyTaskAssignor (#16318)
PR-16291 - KAFKA-16557 Implemented OffsetFetchRequestState toStringBase and added a test for it (#16291)
PR-16227 - KAFKA-16901 Add unit tests for ConsumerRecords#records(String) (#16227)
PR-16302 - KAFKA-16938 non-dynamic props gets corrupted due to circular reference between DynamicBrokerConfig and DynamicConfig. (#16302)
PR-16237 - KAFKA-16890: Compute valid log-start-offset when deleting overlapping remote segments (#16237)
PR-16288 - KAFKA-16935: Automatically wait for cluster startup in embedded Connect integration tests (#16288)
PR-16244 - KAFKA-16897 Move OffsetIndexTest and OffsetMapTest to storage module (#16244)
PR-16292 - KAFKA-15045: (KIP-924 pt. 23) More TaskAssignmentUtils tests (#16292)
PR-13277 - KAFKA-8206: KIP-899: Allow client to rebootstrap (#13277)
PR-16229 - KAFKA-16570 FenceProducers API returns “unexpected error” when succes… (#16229)
PR-16136 - KAFKA-16865: Add IncludeTopicAuthorizedOperations option for DescribeTopicPartitionsRequest (#16136)
PR-16296 - KAFKA-10787 Apply spotless to log4j-appender, trogdor, jmh-benchmarks, examples, shell and generator (#16296)
PR-16078 - KAFKA-15265: Dynamic broker configs for remote fetch/copy quotas (#16078)
PR-16299 - KAFKA-10787 Apply spotless to connect module (#16299)
PR-16215 - KAFKA-16770; [2/2] Coalesce records into bigger batches (#16215)
PR-16107 - KAFKA-10199: Enable state updater by default (#16107)
PR-16294 - KAFKA-15045: (KIP-924 pt. 22) Add RackAwareOptimizationParams and other minor TaskAssignmentUtils changes (#16294)
PR-16255 - KAFKA-16922 Adding unit tests for NewTopic (#16255)
PR-15820 - KAFKA-15265: Integrate RLMQuotaManager for throttling copies to remote storage (#15820)
PR-15993 - KAFKA-16541 Fix potential leader-epoch checkpoint file corruption (#15993)
PR-16269 - KAFKA-15045: (KIP-924 pt. 21) UUID to ProcessId migration (#16269)
PR-16283 - KAFKA-16930; UniformHeterogeneousAssignmentBuilder throws NPE when one member has no subscriptions (#16283)
PR-16106 - KAFKA-16520: Support KIP-853 in DescribeQuorum (#16106)
PR-16209 - KAFKA-16904: Metric to measure the latency of remote read requests (#16209)
PR-16281 - KAFKA-16373: KIP-1028: Modifying download url for kafka dockerfile (#16281)
PR-16267 - KAFKA-16373: KIP-1028: Adding 3.7.0 docker official images static assets (#16267)
PR-16268 - KAFKA-16914: Added share group dynamic and broker configs (#16268)
PR-16203 - KAFKA-15776: Support added to update remote.fetch.max.wait.ms dynamically (#16203)
PR-16256 - KAFKA-16885 Renamed the enableRemoteStorageSystem to isRemoteStorageSystemEnabled (#16256)
PR-16199 - KAFKA-16884 Refactor RemoteLogManagerConfig with AbstractConfig (#16199)
PR-14778 - KAFKA-15776: Introduce remote.fetch.max.timeout.ms to configure DelayedRemoteFetch timeout (#14778)
PR-16180 - KAFKA-16882 Migrate RemoteLogSegmentLifecycleTest to ClusterInstance infra (#16180)
PR-16173 - KAFKA-16880 Update equals and hashcode methods for two attributes (#16173)
PR-16154 - KAFKA-16852 Adding two thread pools kafka-16852 (#16154)
PR-16153 - KAFKA-16859 Cleanup check if tiered storage is enabled (#16153)
PR-16170 - KAFKA-16785 Migrate TopicBasedRemoteLogMetadataManagerRestartTest to new test infra (#16170)
PR-16152 - KAFKA-16866 Used the right constant in RemoteLogManagerTest#testFetchQuotaManagerConfig (#16152)
PR-16262 - KAFKA-10787 Apply spotless to tools and tools-api module (#16262)
68070c94 - KAFKA-16724: Added support for fractional throughput and monotonic payload in kafka-producer-perf-test.sh
PR-16260 - add slf4jlog4j in tool (#16260)
PR-16053 - KAFKA-9228: Restart tasks on runtime-only connector config changes (#16053)
PR-16043 - KAFKA-16764: New consumer should throw InvalidTopicException on poll when invalid topic in metadata. (#16043)
PR-16261 - [MINOR] KAFKA-16373: KIP-1028: Modifying dockerfile comments (#16261)
PR-16226 - modifying Readme for Docker official images (#16226)
PR-16158 - KAFKA-14509; [4/4] Handle includeAuthorizedOperations in ConsumerGroupDescribe API (#16158)
PR-16188 - KAFKA-16448: Add ProcessingExceptionHandler in Streams configuration (#16188)
PR-16157 - KAFKA-15718: Refactor UncleanLeaderElectionTest to enable KRaft later (#16157)
PR-16245 - KAFKA-15045: (KIP-924 pt. 20) Custom task assignment configuration fix (#16245)
PR-16201 - KAFKA-15045: (KIP-924 pt. 18) Better assignment testing (#16201)
PR-16252 - KAFKA-16920: close BrokerLifecycleManager in tests (#16252)
PR-16172 - KAFKA-10787 Apply spotless to transaction-coordinator and server-common (#16172)
PR-16236 - KAFKA-16878 Remove powermock and easymock from code base (#16236)
PR-16232 - KAFKA-16886: Detect replica demotion in AssignmentsManager (#16232)
PR-16248 - KAFKA-16916: Disable blocking test temporarily (#16248)
7879f1c0 - KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs
PR-15869 - KAFKA-16493: Avoid unneeded subscription regex check if metadata version unchanged (#15869)
PR-15834 - KAFKA-16606 Gate JBOD configuration on 3.7-IV2 (#15834)
PR-16031 - KAFKA-16200: Enforce that RequestManager implementations respect user-provided timeout (#16031)
PR-16214 - KAFKA-16786: Remove old assignment strategy usage in new consumer (#16214)
PR-16234 - KAFKA-16912 Migrate ConsumerNetworkThreadTest.testPollResultTimer() to NetworkClientDelegateTest (#16234)
PR-16126 - KAFKA-16223 Migrate KafkaConfigBackingStoreTest to Mockito (#16126)
PR-16219 - KAFKA-15045: (KIP-924 pt. 19) Update to new AssignmentConfigs (#16219)
PR-16222 - KAFKA-16903: Consider produce error of different task (#16222)
PR-16198 - KAFKA-14701; Move PartitionAssignor to new group-coordinator-api module (#16198)
PR-16187 - KAFKA-16448: Add ProcessingExceptionHandler interface and implementations (#16187)
PR-16079 - KAFKA-16530: Fix high-watermark calculation to not assume the leader is in the voter set (#16079)
PR-16165 - KAFKA-16814 KRaft broker cannot startup when partition.metadata is missing (#16165)
PR-16194 - KAFKA-15045: (KIP-924 pt. 17) State store computation fixed (#16194)
PR-16147 - KAFKA-15045: (KIP-924 pt. 16) TaskAssignor.onAssignmentComputed handling (#16147)
PR-15689 - KAFKA-12317: Update FK-left-join documentation (#15689)
PR-15790 - KAFKA-16573: Specify node and store where serdes are needed (#15790)
PR-16161 - KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas (#16161)
PR-16071 - KAFKA-15265: Integrate RLMQuotaManager for throttling fetches from remote storage (#16071)
PR-16186 - KAFKA-16888 Fix failed StorageToolTest.testFormatSucceedsIfAllDirectoriesAreAvailable and StorageToolTest.testFormatEmptyDirectory (#16186)
PR-16176 - KAFKA-10787 Update spotless version and remove support JDK8 (#16176)
PR-16184 - KAFKA-16740: Adding skeleton code for Share Fetch and Acknowledge RPC (KIP-932) (#16184)
PR-16105 - KAFKA-16483: Remove preAppendErrors from createPutCacheCallback (#16105)
9ceed8f1 - KAFKA-16535: Implement AddVoter, RemoveVoter, UpdateVoter RPCs
PR-16156 - KAFKA-15305 The background thread should try to process the remaining task until the shutdown timer is expired. (#16156)
PR-16178 - KAFKA-15852: Move LinuxIoMetricsCollector to server module (#16178)
PR-16118 - KAFKA-16583: Handle PartitionChangeRecord without directory IDs (#16118)
PR-16068 - KAFKA-16821; Member Subscription Spec Interface (#16068)
PR-16122 - KAFKA-16837, KAFKA-16838: Ignore task configs for deleted connectors, and compare raw task configs before publishing them (#16122)
PR-16151 - KAFKA-16047: Use REQUEST_TIMEOUT_MS_CONFIG in AdminClient.fenceProducers (#16151)
PR-16144 - KAFKA-16664; Re-add EventAccumulator.poll(long, TimeUnit) (#16144)
PR-16134 - KAFKA-16715: Create KafkaShareConsumer interfaces (#16134)
PR-15165 - KAFKA-16105: Reset read offsets when seeking to beginning in TBRLMM (#15165)
PR-16163 - KAFKA-16861: Don’t convert to group to classic if the size is larger than group max size. (#16163)
PR-16175 - KAFKA-16881: InitialState type leaks into the Connect REST API OpenAPI spec (#16175)
PR-16169 - KAFKA-15156 Update cipherInformation correctly in DefaultChannelMetadataRegistry (#16169)
PR-16022 - KAFKA-16713: Define initial set of RPCs for KIP-932 (#16022)
PR-16097 - KAFKA-10787 Add import ordering checkstyle rule and configure an automatic formatter (#16097)
PR-16164 - KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (#16164)
PR-16042 - KAFKA-16807 DescribeLogDirsResponseData#results#topics have unexpected topics having empty partitions (#16042)
PR-15945 - KAFKA-16757: Fix broker re-registration issues around MV 3.7-IV2 (#15945)
PR-15863 - KAFKA-16574 The metrics of LogCleaner disappear after reconfiguration (#15863)
PR-15862 - KAFKA-16652 add unit test for ClusterTemplate offering zero ClusterConfig (#15862)
PR-16017 - KAFKA-16639 Ensure HeartbeatRequestManager generates leave request regardless of in-flight heartbeats. (#16017)
PR-16088 - KAFKA-16864; Optimize uniform (homogenous) assignor (#16088)
PR-16149 - KAFKA-16860; [2/2] Introduce group.version feature flag (#16149)
PR-16120 - KAFKA-16860; [1/2] Introduce group.version feature flag (#16120)
PR-16025 - KAFKA-16809: Run Javadoc in CI (#16025)
PR-15840 - KAFKA-16629 Add broker-related tests to ConfigCommandIntegrationTest (#15840)
ksqlDB
4354d07a - unpin jetty
PR-10635 - Added Warn Logger for Orphan Topics (UnknownTopicOrPartitionException) & for Command Topic Size exceeding threshold
PR-10614 - Merge Conflict Resolution (from 7.3.x to 7.4.x)
PR-10612 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
PR-10608 - Fix close query context error
PR-10610 - Merge Conflict Resolution (from 7.3.x to 7.4.x)
PR-10607 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
PR-10601 - Optimize Latency in POST /ksql API for describe streams Due to Orphan Topics
PR-10602 - adding cp-jar-build semaphoreCI block
355538b3 - Add OAuth Support in KSQL CLI
PR-10581 - Merge Conflict Fix and Build
PR-10578 - fix: for dependency update for jsonschema
PR-10551 - feat: add error log for logging topic client errors
PR-10506 - Fix the argument list for HttpAccessTokenRetriever.
PR-10503 - Fix classloader after connect starts
PR-10482 - Updated the args as per changes in kafka
PR-10478 - Update netty version from 4.1.108.Final to 4.1.113.Final.
PR-10481 - Fix for Arg Count Mismatch
bb335fa1 - nit
PR-157 - Remove KSQL internal topics from the list topic results. Sort the top
PR-156 - improve test coverage for cli
PR-10468 - adding PR CI gating config in service.yml for cc-service-bot to enable cp jar build
10d04ca5 - Change configType to PASSWORD
3213368f - Update netty version from 4.1.108.final to 1.1.113.Final.
58125e73 - address reviews
f5c31c27 - address reviews
aee1218e - Update netty version from 4.1.108.Final to 4.1.113.Final.
1ef32457 - Update netty version from 4.1.108.Final to 4.1.113.Final.
PR-132 - Proper error message when with clause is not set correctly.
PR-10441 - fix base_dir as / causing java.net.UnknownHostException: etc
PR-10414 - Added Debug Capability and Updated ReadMe
REST Proxy
bf7e380a - change imports to confluent package
a9c69e6f - unpin jetty-servlets
PR-515 - Add DoSFilter from Jetty 9.4.53
PR-1322 - Fix visibility for stopRest function
PR-1318 - Change to manageRest to make the name consistent for all release branch
PR-1311 - Allow to start kafka rest separately so that the integration test can be more customisable
PR-1312 - Update codeowners
PR-1293 - chore: update repo by service bot
PR-1292 - Fix build breaks due to upstream changes
PR-524 - Backport http2 support changes to 7.5.x
02615956 - update async_http_client without upgrade of major version
PR-511 - Add @confluentinc/kora-networking as Codeowner
48e03221 - remove the hibernate-validator exclusion no longer needed due to updated jersey-bean-validation
302da1b6 - add a comment
c6a50d88 - Add access.control.expose.headers into the CORS filters
PR-12 - Added more REST exceptions
PR-10 - Add RestConstraintViolationException for better error codes for some constraint violations.
PR-491 - Add configuration hsts.header.enable to control whether we response with HSTS header
Schema Registry
PR-3517 - making buildConnectionProtected
PR-3455 - add pagination for get all subjects
PR-3515 - Fix equivalence checks for JSON and Protobuf
PR-3512 - Ensure message reader can return multiple records
PR-3509 - Fix handling of nested Protobuf types when generating descriptor
PR-3505 - Merge Conflict Resolution (from 7.8.x to 7.9.x)
d4c0fcd8 - Update parent POM version in new module
PR-3498 - Fix parent POM version in new module
PR-3497 - Fix parent POM version in new module
PR-3489 - adding cp-jar-build block for 79x
PR-3500 - Prevent overwriting argLine execution variable
e13dac33 - Update generated files
cd5df0be - add codeartifact paths
7f75e155 - Update parent pom
13d494b6 - Don’t overwrite argLine var (https://stackoverflow.com/a/23605812)
749e1c9b - Merge conflicts
PR-3462 - Enable SonarQube reporting
PR-3496 - Fix parent POM version in new module
PR-3495 - Fix parent POM version in new module
PR-3494 - Fix parent POM version in new module
PR-3484 - Prioritize the Shutdown of the Leader Elector
PR-3481 - Fix retry logic for callables that return void
PR-3478 - Fix JSON Schema dependency
PR-3461 - Add test to ensure Protobuf map entry option is preserved
PR-3468 - Ensure json-skema validator is called if possible
PR-3449 - Add composite deserializer for migration use cases
PR-3459 - Optimization to use confluent:version if available
PR-3458 - Enhance lookup match to be more lenient wrt confluent:version
PR-3457 - Revert “Ensure map_entry option is not emitted (#3444)”
PR-3453 - Port AWS KMS integration code to AWS SDK v2
PR-3447 - Pass IP address so that requests sent to leader can forward the IP
PR-3444 - Ensure map_entry option is not emitted
PR-3441 - Added config for not waiting for kafka reader on store init and leader election
PR-3440 - remove pin of bouncycastle to favor version defined in common
PR-3437 - fix: Config for not throwing timeout exception when waiting for Kafka reader on init
PR-3434 - Fix transformation of fields in JSON Schema definitions
PR-3430 - Fix merge 7.4.x to 7.5.x
PR-3424 - Add retry logic to RestService
PR-3427 - Add config to specify packages to scan when deriving JSON Schema
PR-3425 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
PR-3394 - remove pin of bouncycastle to favor version defined in common
PR-3423 - Downgrade JSONata to 2.4.5
PR-3417 - Revert “Upgrade json-schema to 1.14.4 (#3400)”
PR-3415 - Fix merge issue
PR-3414 - Fix merge issue
PR-3402 - Upgrade wire to 5.1.0
ebf23a1d - Upgrade jsonata to 2.4.9
PR-3401 - Upgrade json-skema to 0.19.0
PR-3400 - Upgrade json-schema to 1.14.4
PR-3399 - Upgrade tink to 1.15
PR-3397 - Upgrade cel-java to 0.4.5
PR-3396 - Remove scala dependency for mbknor library
PR-3404 - Added kafka-tools dependency
PR-3392 - Handle schema migrations for Proto message types after first
PR-3393 - remove hibernate-validator exclusion and pin as the updated dependency uses new version
PR-3390 - More robust retries in RetryExecutor
PR-3391 - Return 404 instead of 429 if schema lookup fails
PR-3389 - Retry on 500
PR-3388 - Add test that uses both JSONata and CEL
PR-3384 - Fix javadoc annotations to have no errors
PR-3382 - Handle refs with version of -1 when looking up schemas
PR-3379 - Allow empty fragment (#) in $schema prop for JSON Schema
PR-3378 - Handle doubly nested CombinedSchema when getting tags
PR-3373 - Revert #3224 to resolve CP Packaging 7.9.x build
PR-3359 - Add latest caches at the SR client level
PR-3361 - Don’t create a new version if latest is equivalent
PR-3351 - Ensure InvalidSchemaException is thrown from parseSchema
PR-3354 - Add test to ensure MD5 does not change for schema values
PR-3352 - Minor optimization to reduce schema ID lookups
PR-3348 - Reapply “Fix race condition when getting decoder for sensitive metadata”
PR-3349 - Reapply “Allow SR to ignore confluent:version when matching
PR-3347 - Enable semaphore pipeline on sr release branch
PR-3346 - Include sonarqube
PR-3343 - Revert “Allow SR to ignore confluent:version when matching
PR-3342 - Revert “Fix race condition when getting decoder for sensitive metadata”
PR-3334 - Revert change to default rule actions
PR-3339 - Revert “Fix race condition when getting decoder for sensitive metadata”
PR-3337 - Fix pint merge 7.4.x to 7.5.x
PR-3333 - Ensure encoders are synced when decoding sensitive metadata
PR-3332 - Fix NPE when listing versions by id
PR-3327 - Add additional tests for draft 2019-09 (#81)
PR-3328 - Add dedupe test for same schema w/different version (#82)
PR-3322 - Allow SR to ignore confluent:version when matching schemas
PR-3265 - Add performanceMetric to get config metadata API
PR-3271 - chore: update repo by service bot
PR-57 - Changed id from long to int.
14ca9b60 - Fix master branch
PR-3224 - Fix Build After Migration of JaasTestUtils to Java