Confluent Platform Component Changelogs

This topic provides changelogs for the individual Confluent Platform components.

Version 7.5.7

Released December 2024

Community Features

Common

  • c3786289 - change bctls-fips to 1.0.13
  • 9af7b9a3 - change bouncycastle
  • 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
  • PR-663 - disable CI gating workflow for master branch
  • 948d59f6 - Upgrade Netty
  • PR-657 - update protobuf to 3.25.5 (#16) (#654) (#17)
  • PR-654 - update protobuf to 3.25.5
  • PR-646 - update bouncycastle to version 2.0 (#11)
  • PR-637 - adding cp-jar-build ci gating

Kafka

  • PR-1502 - Fix version check in util.py
  • PR-1488 - Update jetty to 9.4.56.v20240826
  • PR-1480 - Added commonsIo to libs variable.
  • PR-1459 - Bump commonsIo to version 2.16.0 in 3.5
  • 8393f531 - Ignore failing quota_test
  • PR-1437 - disable flakey test

ksqlDB

  • 0a63de1d - Fix commons-io version
  • bb335fa1 - nit
  • PR-157 - Remove KSQL internal topics from the list topic results. Sort the top
  • PR-156 - improve test coverage for cli
  • 3213368f - Update netty version from 4.1.108.final to 1.1.113.Final.
  • 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-10442 - Ensure Deterministic UDF Loading by Avoiding Context ClassLoader Interference
  • 70e7ffbf - Update netty version from 4.1.108.Final to 4.1.113.Final.
  • PR-140 - Delimited mode deserializer now can handle null values.
  • PR-139 - sanity check for persistent queries
  • PR-138 - Added props to the sanity check.
  • f923a1ea - Downgrade git commit id plugin version from 9.0.1 to 4.9.10 for Java 8 compatibility.
  • ec48c835 - Upgrade git commit id plugin version from 2.2.6 to 9.0.1 and include git.commit.id property only.
  • PR-10413 - Fix for select struct->* for Pull Queries
  • PR-10443 - updating cp-jar-build block in semaphore pipeline

REST Proxy

  • PR-1290 - adding cp jar build workflow as PR ci gating
  • PR-500 - skipping cp jar builds on master branch PRs
  • PR-492 - adding cp-jar-build block for PR builds

Schema Registry

  • PR-3359 - Add latest caches at the SR client level
  • PR-3351 - Ensure correct exception is thrown from parseSchema
  • PR-3352 - Minor optimization to reduce schema ID lookups
  • PR-3348 - Reapply “Fix for decoding of sensitve metadata”
  • PR-3342 - remove fix for decoding of sensitive metadata
  • PR-3339 - remove fix for decoding of 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-3316 - Return encrypted value instead of throwing exception
  • PR-3311 - Fix 7.1.x merge conflicts
  • PR-3265 - Add performanceMetric to get config metadata API
  • PR-3264 - Add performanceMetric to list schema refs API
  • PR-3263 - Add performanceMetric to global delete config API
  • PR-3307 - Fix pint merge from 7.3.x to 7.4.x
  • PR-3244 - Handle 401/403 errors appropriately
  • PR-72 - Fixed the wait timeout in the KafkaStoreReaderThread. Fixes #54
  • PR-3262 - remove azure-identity definition, update azure-keyvault version (#49)
  • PR-3278 - Use concurrent hash maps in serde members (#61)
  • PR-3276 - Add format query param to APIs that return a schema (#46)
  • PR-3252 - Add CSFLE tests with pre-canned data (#42)
  • PR-3250 - Allow oneofs to be flattened in Protobuf converter (#41)
  • PR-3256 - adding cp jar build CI gating block (#38)

Version 7.5.6

Released August 2024

Community Features

Common

  • PR-2 - Remove IntelliJ and build output and add it to .gitignore.
  • ab0d4be5 - Update pom.xml
  • 2add2049 - pin classgraph
  • 1825f6c2 - update azure-identity to 1.12.2
  • 57dce6aa - Remove bouncy property
  • 3753b015 - Remove bcprov-jdk15on

Kafka

  • PR-1391 - 3.5 fixed downstream trigger

ksqlDB

  • PR-63 - Checkstyle fixes
  • PR-62 - Remove unnecessary exclusions
  • PR-61 - Remove unused imports
  • PR-60 - Removed the imlicit topic generation from th estatement executor.
  • PR-59 - Added partition by clause to CSAS statement
  • PR-52 - Inherit from common POM, clean up dependencies
  • PR-50 - json processing
  • PR-49 - Fixed the issue with COUNT(*).
  • PR-47 - Make tabular output for ‘DESCRIBE …’ statements a little prettier
  • PR-37 - Remove custom JSON (de)serialization, use Jackson’s ObjectMapper instead
  • PR-10398 - Package kafka streams in api client
  • PR-10397 - Increase time limit for the pipeline
  • PR-10392 - Change classgraph version to 4.8.59
  • PR-9 - Leverage ARG (Avro Random Generator) in DataGen class
  • 3116084b - Use range version instead of pinned nano-versions
  • 88704d16 - Use range version instead of pinned nano-versions
  • ea2c84c9 - Use range version instead of pinned nano-versions
  • af2b0440 - Use range version instead of pinned nano-versions
  • e65fd80d - Use range version instead of pinned nano-versions
  • ddcda7d2 - Use range version instead of pinned nano-versions(to fix build failure)
  • PR-10369 - Add kafka streams dependency on ksqldb api client

REST Proxy

Schema Registry

  • PR-33 - Moved key serialization to a JSON serializer.
  • PR-30 - APIs changed to refer to subjects. Retrieval by globally unique schema id
  • PR-3235 - Fix Pint Merge Error
  • PR-11 - Moves hard-coded configs
  • 0f4860f3 - Revert “Upgrade JSONata dependency to 2.5.0”
  • 64e420b4 - Clean up LocalKmsClient
  • 8c5aaa96 - Upgrade JSONata dependency

Version 7.5.5

Released June 2024

Community Features

Common

  • ac056ff0 - Remove dependency-check-maven plugin
  • 199fb826 - [skip ci] Copy CODEOWNERS from the default branch
  • 2d18feed - [skip ci] Copy CODEOWNERS from the default branch
  • a4ce2aa5 - [skip ci] Copy CODEOWNERS from the default branch
  • c3161ee3 - [skip ci] Copy CODEOWNERS from the default branch
  • 7bb3031e - [skip ci] Copy CODEOWNERS from the default branch
  • 7101444c - [skip ci] Copy CODEOWNERS from the default branch
  • 1161cd16 - [skip ci] Copy CODEOWNERS from the default branch
  • 35bb1580 - [skip ci] Copy CODEOWNERS from the default branch
  • 4de5f345 - [skip ci] Copy CODEOWNERS from the default branch
  • 56cf025c - [skip ci] Copy CODEOWNERS from the default branch
  • b1986c77 - [skip ci] Copy CODEOWNERS from the default branch
  • 99e2d3ee - [skip ci] Copy CODEOWNERS from the default branch
  • a2532765 - [skip ci] Copy CODEOWNERS from the default branch
  • d447e722 - [skip ci] Copy CODEOWNERS from the default branch
  • 4074cb43 - [skip ci] Copy CODEOWNERS from the default branch
  • fb60a228 - [skip ci] Copy CODEOWNERS from the default branch
  • c68a9779 - [skip ci] Copy CODEOWNERS from the default branch
  • 754d9b81 - [skip ci] Copy CODEOWNERS from the default branch
  • fb5fd4f1 - [skip ci] Copy CODEOWNERS from the default branch
  • a8fe8bde - [skip ci] Copy CODEOWNERS from the default branch
  • 709008c3 - [skip ci] Copy CODEOWNERS from the default branch
  • 87965aeb - [skip ci] Copy CODEOWNERS from the default branch
  • 324ea0c2 - [skip ci] Copy CODEOWNERS from the default branch
  • 1e75bf2e - [skip ci] Copy CODEOWNERS from the default branch
  • dbc2808e - [skip ci] Copy CODEOWNERS from the default branch
  • 37299738 - [skip ci] Copy CODEOWNERS from the default branch
  • 6834d31e - [skip ci] Copy CODEOWNERS from the default branch
  • f672f0b7 - [skip ci] Copy CODEOWNERS from the default branch
  • 1552a6ae - [skip ci] Copy CODEOWNERS from the default branch
  • c2e6d1d9 - [skip ci] Copy CODEOWNERS from the default branch
  • 58752026 - [skip ci] Copy CODEOWNERS from the default branch
  • 257e5583 - [skip ci] Copy CODEOWNERS from the default branch
  • d805ea52 - [skip ci] Copy CODEOWNERS from the default branch
  • a51cbedc - [skip ci] Copy CODEOWNERS from the default branch
  • bae0cc2b - [skip ci] Copy CODEOWNERS from the default branch
  • 05c3c21f - [skip ci] Copy CODEOWNERS from the default branch
  • 19382638 - [skip ci] Copy CODEOWNERS from the default branch
  • 8a85ced7 - [skip ci] Copy CODEOWNERS from the default branch
  • 745ad6e0 - [skip ci] Copy CODEOWNERS from the default branch
  • b471ca1e - [skip ci] Copy CODEOWNERS from the default branch
  • e4657f76 - [skip ci] Copy CODEOWNERS from the default branch
  • 58210d7e - [skip ci] Copy CODEOWNERS from the default branch
  • 54023e05 - [skip ci] Copy CODEOWNERS from the default branch
  • 4849bf6c - [skip ci] Copy CODEOWNERS from the default branch
  • 513505a4 - [skip ci] Copy CODEOWNERS from the default branch
  • 3b923d23 - [skip ci] Copy CODEOWNERS from the default branch
  • 3baac0ca - [skip ci] Copy CODEOWNERS from the default branch
  • f981b476 - [skip ci] Copy CODEOWNERS from the default branch
  • c6202053 - [skip ci] Copy CODEOWNERS from the default branch
  • f90b2358 - [skip ci] Copy CODEOWNERS from the default branch
  • 0a75e912 - [skip ci] Copy CODEOWNERS from the default branch
  • fec34ca6 - [skip ci] Copy CODEOWNERS from the default branch
  • 955a9d56 - [skip ci] Copy CODEOWNERS from the default branch
  • 7be2463a - [skip ci] Copy CODEOWNERS from the default branch
  • 4a39583c - [skip ci] Copy CODEOWNERS from the default branch
  • 54ba479f - [skip ci] Copy CODEOWNERS from the default branch
  • 1bcdaa2d - [skip ci] Copy CODEOWNERS from the default branch
  • 61cfbd02 - [skip ci] Copy CODEOWNERS from the default branch
  • 6674005e - [skip ci] Copy CODEOWNERS from the default branch
  • 1c0f4d21 - [skip ci] Copy CODEOWNERS from the default branch
  • 22befdbe - [skip ci] Copy CODEOWNERS from the default branch
  • 068cab4e - [skip ci] Copy CODEOWNERS from the default branch
  • e16dfe4f - [skip ci] Copy CODEOWNERS from the default branch
  • 303b2ee4 - [skip ci] Copy CODEOWNERS from the default branch
  • c121708d - [skip ci] Copy CODEOWNERS from the default branch
  • 7cf721e2 - [skip ci] Copy CODEOWNERS from the default branch
  • 0ee7493f - [skip ci] Copy CODEOWNERS from the default branch
  • 18c80b08 - [skip ci] Copy CODEOWNERS from the default branch
  • 360f8390 - [skip ci] Copy CODEOWNERS from the default branch
  • 06020135 - [skip ci] Copy CODEOWNERS from the default branch
  • a6f16e5b - [skip ci] Copy CODEOWNERS from the default branch
  • 0617a389 - [skip ci] Copy CODEOWNERS from the default branch
  • fd1c2566 - [skip ci] Copy CODEOWNERS from the default branch
  • b0452bf1 - [skip ci] Copy CODEOWNERS from the default branch
  • ab852844 - [skip ci] Copy CODEOWNERS from the default branch
  • a211badc - [skip ci] Copy CODEOWNERS from the default branch
  • 9b6902db - [skip ci] Copy CODEOWNERS from the default branch
  • b1b20738 - [skip ci] Copy CODEOWNERS from the default branch
  • a7a4cc7a - [skip ci] Copy CODEOWNERS from the default branch
  • 91490ad5 - [skip ci] Copy CODEOWNERS from the default branch
  • 17da8567 - [skip ci] Copy CODEOWNERS from the default branch
  • 766a751b - [skip ci] Copy CODEOWNERS from the default branch
  • 1fbbb32a - [skip ci] Copy CODEOWNERS from the default branch
  • 3825d594 - [skip ci] Copy CODEOWNERS from the default branch
  • a40b2814 - [skip ci] Copy CODEOWNERS from the default branch
  • d5cae13d - [skip ci] Copy CODEOWNERS from the default branch
  • 6bde5187 - [skip ci] Copy CODEOWNERS from the default branch
  • 1de74570 - [skip ci] Copy CODEOWNERS from the default branch
  • 7b2523a9 - [skip ci] Copy CODEOWNERS from the default branch
  • 9c81bb26 - [skip ci] Copy CODEOWNERS from the default branch
  • 5a9cc14b - [skip ci] Copy CODEOWNERS from the default branch
  • eff4902e - [skip ci] Copy CODEOWNERS from the default branch
  • c78d91e0 - [skip ci] Copy CODEOWNERS from the default branch
  • f06f7364 - [skip ci] Copy CODEOWNERS from the default branch
  • 1e32c541 - [skip ci] Copy CODEOWNERS from the default branch
  • b200e9b2 - [skip ci] Copy CODEOWNERS from the default branch
  • 8759b329 - [skip ci] Copy CODEOWNERS from the default branch
  • 8f5cc526 - [skip ci] Copy CODEOWNERS from the default branch
  • 66fe85c0 - [skip ci] Copy CODEOWNERS from the default branch
  • 394c99ad - [skip ci] Copy CODEOWNERS from the default branch
  • c346275b - [skip ci] Copy CODEOWNERS from the default branch
  • 3fccf1c0 - [skip ci] Copy CODEOWNERS from the default branch
  • 283327a3 - [skip ci] Copy CODEOWNERS from the default branch
  • d8f9e18c - [skip ci] Copy CODEOWNERS from the default branch
  • 00c0eb82 - [skip ci] Copy CODEOWNERS from the default branch
  • 19efc04e - [skip ci] Copy CODEOWNERS from the default branch
  • 227118f8 - [skip ci] Copy CODEOWNERS from the default branch
  • 07bdd844 - [skip ci] Copy CODEOWNERS from the default branch
  • 3ff06154 - [skip ci] Copy CODEOWNERS from the default branch
  • 603fbeea - [skip ci] Copy CODEOWNERS from the default branch
  • 25321bce - [skip ci] Copy CODEOWNERS from the default branch
  • 7f0ab7b9 - [skip ci] Copy CODEOWNERS from the default branch
  • aca775c6 - [skip ci] Copy CODEOWNERS from the default branch
  • f654da0e - [skip ci] Copy CODEOWNERS from the default branch
  • 44028ac6 - [skip ci] Copy CODEOWNERS from the default branch
  • a513edb4 - [skip ci] Copy CODEOWNERS from the default branch
  • abf422bb - [skip ci] Copy CODEOWNERS from the default branch
  • 739d4812 - [skip ci] Copy CODEOWNERS from the default branch
  • 02f185fc - [skip ci] Copy CODEOWNERS from the default branch
  • 9b73ab9e - [skip ci] Copy CODEOWNERS from the default branch
  • 52ff6ef2 - [skip ci] Copy CODEOWNERS from the default branch
  • e1f6c689 - [skip ci] Copy CODEOWNERS from the default branch
  • 8d7ca7c1 - [skip ci] Copy CODEOWNERS from the default branch
  • ad60fa3e - [skip ci] Copy CODEOWNERS from the default branch
  • 0fc5ca14 - [skip ci] Copy CODEOWNERS from the default branch
  • e1edccb6 - [skip ci] Copy CODEOWNERS from the default branch
  • d4f4daae - [skip ci] Copy CODEOWNERS from the default branch
  • 4cbed2ca - [skip ci] Copy CODEOWNERS from the default branch
  • 0ae51d8e - [skip ci] Copy CODEOWNERS from the default branch
  • 06eb50f2 - [skip ci] Copy CODEOWNERS from the default branch
  • d1657566 - [skip ci] Copy CODEOWNERS from the default branch
  • 52d310eb - [skip ci] Copy CODEOWNERS from the default branch
  • 6eeee637 - [skip ci] Copy CODEOWNERS from the default branch
  • 01caa623 - [skip ci] Copy CODEOWNERS from the default branch
  • 691709b1 - [skip ci] Copy CODEOWNERS from the default branch
  • 8dbe4889 - [skip ci] Copy CODEOWNERS from the default branch
  • ca9ea7c3 - [skip ci] Copy CODEOWNERS from the default branch
  • 29aa3e26 - [skip ci] Copy CODEOWNERS from the default branch
  • f6b3349a - [skip ci] Copy CODEOWNERS from the default branch
  • c133160a - [skip ci] Copy CODEOWNERS from the default branch
  • 495ab211 - [skip ci] Copy CODEOWNERS from the default branch
  • 29c3f474 - [skip ci] Copy CODEOWNERS from the default branch
  • 1327ab0b - [skip ci] Copy CODEOWNERS from the default branch
  • e29041b8 - [skip ci] Copy CODEOWNERS from the default branch
  • 8cdd5e86 - [skip ci] Copy CODEOWNERS from the default branch
  • bf2249de - [skip ci] Copy CODEOWNERS from the default branch
  • d04c0fa0 - [skip ci] Copy CODEOWNERS from the default branch
  • 1ec0f1c9 - [skip ci] Copy CODEOWNERS from the default branch
  • 0238cfb8 - [skip ci] Copy CODEOWNERS from the default branch
  • f428b4a2 - [skip ci] Copy CODEOWNERS from the default branch
  • 23944f1d - [skip ci] Copy CODEOWNERS from the default branch
  • 61e6fa60 - [skip ci] Copy CODEOWNERS from the default branch
  • cc315d24 - [skip ci] Copy CODEOWNERS from the default branch
  • b17fae65 - [skip ci] Copy CODEOWNERS from the default branch
  • 799a4798 - [skip ci] Copy CODEOWNERS from the default branch
  • e03d34a4 - [skip ci] Copy CODEOWNERS from the default branch
  • 6d8fc018 - [skip ci] Copy CODEOWNERS from the default branch
  • e17def72 - [skip ci] Copy CODEOWNERS from the default branch
  • 9e2cd086 - [skip ci] Copy CODEOWNERS from the default branch
  • 812e85c4 - [skip ci] Copy CODEOWNERS from the default branch
  • 47dc8ded - [skip ci] Copy CODEOWNERS from the default branch
  • 8700b8b8 - [skip ci] Copy CODEOWNERS from the default branch
  • 68241084 - [skip ci] Copy CODEOWNERS from the default branch
  • 55746933 - [skip ci] Copy CODEOWNERS from the default branch
  • 1aa59696 - [skip ci] Copy CODEOWNERS from the default branch
  • 12669c89 - [skip ci] Copy CODEOWNERS from the default branch
  • 3cd026a6 - [skip ci] Copy CODEOWNERS from the default branch
  • 5bae6ca7 - [skip ci] Copy CODEOWNERS from the default branch
  • 459789ed - [skip ci] Copy CODEOWNERS from the default branch
  • 7d9c8c26 - [skip ci] Copy CODEOWNERS from the default branch
  • 3f003df7 - [skip ci] Copy CODEOWNERS from the default branch
  • 2a44c926 - [skip ci] Copy CODEOWNERS from the default branch
  • 6ddf5d33 - [skip ci] Copy CODEOWNERS from the default branch
  • d329f7eb - [skip ci] Copy CODEOWNERS from the default branch
  • 9a722234 - [skip ci] Copy CODEOWNERS from the default branch
  • 97836fb2 - [skip ci] Copy CODEOWNERS from the default branch
  • e9232f50 - add aws-sdk bom instead of just core
  • e5506701 - unify versions of aws and azure sdks with ce-kafka
  • 664220bd - add correct version of tls_fips
  • 70c2d3e7 - add bcpkix to the pack
  • 1ee85034 - add version definitions of bouncycastle fips dependencies
  • 4f0ba3a2 - Update pom.xml
  • PR-604 - netty-bom version should be picked up from netty.version property
  • 5e9c5ab4 - add new line
  • 5099df8f - Fix codeowners
  • c6e03ed1 - Update bouncycastle version to 1.78
  • 4caab334 - replace EOL plugin with ant-run invocation
  • c2f222bf - update bouncycastle
  • e21ffc4e - revert #595 to remediate downstream build failures
  • e29ec833 - update netty to 4.1.108-final
  • 64ff93dc - Update pom.xml
  • 8d984cba - Version bump for Jackson Databind package
  • b59f48d2 - update ZooKeeper to 3.8.4
  • ada22e3c - update netty to 4.1.108.Final
  • 0fe414fb - downgrade fips library to a version that is certified compliant

Kafka

  • PR-1318 - Update refs to confluent-packaging-tools
  • PR-1263 - Upgrade zookeeper 3.8.3 -> 3.8.4 (#15480)
  • PR-1237 - Updated netty version to 4.1.108.Final
  • PR-1170 - update tags and added seamphore tags as part of semaphore migration
  • PR-14995 - Allow restricting File and Directory ConfigProviders to specific paths
  • PR-1365 - removed mk-include and make init-ci from semaphore

ksqlDB

  • 4781375c - Update ref to confluent-packaging-tools
  • e12817d4 - [skip ci] Copy CODEOWNERS from the default branch
  • d5a611b2 - [skip ci] Copy CODEOWNERS from the default branch
  • c0a5ceb7 - [skip ci] Copy CODEOWNERS from the default branch
  • 24fb159d - [skip ci] Copy CODEOWNERS from the default branch
  • 2edfb831 - [skip ci] Copy CODEOWNERS from the default branch
  • 70b4d119 - [skip ci] Copy CODEOWNERS from the default branch
  • db68a852 - [skip ci] Copy CODEOWNERS from the default branch
  • 22a7f2cc - [skip ci] Copy CODEOWNERS from the default branch
  • PR-10355 - MINOR: Update snapshot URLs.
  • PR-10346 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10338 - fix for vertx dependency.
  • 72cd094c - Update plugin version
  • PR-10330 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10329 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10328 - Fix for janino dependency.
  • PR-10321 - Check if directory exists before cleanup 7.2.x
  • PR-10323 - Check if directory exists before cleanup 7.4.x
  • PR-10322 - Check if directory exists before cleanup 7.3.x
  • PR-10311 - Migrate 7.3.x to ranges
  • PR-10312 - Migrate 7.2.x to ranges
  • PR-10309 - Migrate 7.5.x to ranges
  • PR-10310 - Migrate 7.4.x to ranges
  • PR-10313 - Migrate 7.1.x to ranges
  • PR-10314 - Migrate 7.0.x to ranges
  • PR-10315 - Migrate 6.2.x to ranges
  • PR-10318 - Merge Conflict Resolution (from 7.3.x to 7.4.x)
  • PR-10317 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
  • PR-10316 - Merge Conflict Resolution (from 7.1.x to 7.2.x)
  • PR-10304 - Update netty version to stable one
  • PR-10297 - Fix 7.5.x build
  • PR-10303 - Update netty version to stable one
  • PR-10294 - Update common version
  • PR-10365 - add cp-jar-build tasks when running pr workflows

REST Proxy

  • 774a275a - [skip ci] Copy CODEOWNERS from the default branch
  • 2f76a249 - [skip ci] Copy CODEOWNERS from the default branch
  • 3facf7f9 - [skip ci] Copy CODEOWNERS from the default branch
  • 4554dfe9 - [skip ci] Copy CODEOWNERS from the default branch
  • 4abee2fc - [skip ci] Copy CODEOWNERS from the default branch
  • 1a685495 - [skip ci] Copy CODEOWNERS from the default branch
  • c27f5683 - [skip ci] Copy CODEOWNERS from the default branch
  • 2a857aaa - [skip ci] Copy CODEOWNERS from the default branch
  • 886a5b87 - [skip ci] Copy CODEOWNERS from the default branch
  • c752dafa - [skip ci] Copy CODEOWNERS from the default branch
  • c439ed86 - [skip ci] Copy CODEOWNERS from the default branch
  • d56cdf08 - [skip ci] Copy CODEOWNERS from the default branch
  • 269ae5ce - [skip ci] Copy CODEOWNERS from the default branch
  • 649812b7 - [skip ci] Copy CODEOWNERS from the default branch
  • e23b1069 - [skip ci] Copy CODEOWNERS from the default branch
  • a48787a6 - [skip ci] Copy CODEOWNERS from the default branch
  • a555f83b - [skip ci] Copy CODEOWNERS from the default branch
  • 25a878bd - [skip ci] Copy CODEOWNERS from the default branch
  • 6b90e34d - [skip ci] Copy CODEOWNERS from the default branch
  • 52480dcd - [skip ci] Copy CODEOWNERS from the default branch
  • 4cba4ab3 - [skip ci] Copy CODEOWNERS from the default branch
  • 93eebbfe - [skip ci] Copy CODEOWNERS from the default branch
  • 16e9be7f - [skip ci] Copy CODEOWNERS from the default branch
  • 6e7fec5d - [skip ci] Copy CODEOWNERS from the default branch
  • 0eb00fb9 - [skip ci] Copy CODEOWNERS from the default branch
  • e69a6353 - [skip ci] Copy CODEOWNERS from the default branch
  • 3d5ebd5c - [skip ci] Copy CODEOWNERS from the default branch
  • 882de29e - [skip ci] Copy CODEOWNERS from the default branch
  • d6244bc5 - [skip ci] Copy CODEOWNERS from the default branch
  • a6eb93d8 - [skip ci] Copy CODEOWNERS from the default branch
  • 47cb7427 - [skip ci] Copy CODEOWNERS from the default branch
  • f75dec56 - [skip ci] Copy CODEOWNERS from the default branch
  • d2fa2ab6 - [skip ci] Copy CODEOWNERS from the default branch
  • 08ace774 - [skip ci] Copy CODEOWNERS from the default branch
  • d12e4ef0 - [skip ci] Copy CODEOWNERS from the default branch
  • b5e7597f - [skip ci] Copy CODEOWNERS from the default branch
  • 393c3171 - [skip ci] Copy CODEOWNERS from the default branch
  • 0bd46b13 - [skip ci] Copy CODEOWNERS from the default branch
  • 92cf9612 - [skip ci] Copy CODEOWNERS from the default branch
  • 87fe599c - [skip ci] Copy CODEOWNERS from the default branch
  • 23d0b6c8 - [skip ci] Copy CODEOWNERS from the default branch
  • 2cc87ba0 - [skip ci] Copy CODEOWNERS from the default branch
  • cedb3f53 - [skip ci] Copy CODEOWNERS from the default branch
  • f85ab60a - [skip ci] Copy CODEOWNERS from the default branch
  • f3579e99 - [skip ci] Copy CODEOWNERS from the default branch
  • fd35be2f - [skip ci] Copy CODEOWNERS from the default branch
  • eff691a1 - [skip ci] Copy CODEOWNERS from the default branch
  • 6813d52e - [skip ci] Copy CODEOWNERS from the default branch
  • e6cb79bb - [skip ci] Copy CODEOWNERS from the default branch
  • 94b22bbb - [skip ci] Copy CODEOWNERS from the default branch
  • b92d1e9c - [skip ci] Copy CODEOWNERS from the default branch
  • 064872a8 - [skip ci] Copy CODEOWNERS from the default branch
  • ac9cc7d7 - [skip ci] Copy CODEOWNERS from the default branch
  • fa5006bd - [skip ci] Copy CODEOWNERS from the default branch
  • 57c115c6 - [skip ci] Copy CODEOWNERS from the default branch
  • 8eeec592 - [skip ci] Copy CODEOWNERS from the default branch
  • 97afb2c5 - [skip ci] Copy CODEOWNERS from the default branch
  • 348fa979 - [skip ci] Copy CODEOWNERS from the default branch
  • f25f5030 - [skip ci] Copy CODEOWNERS from the default branch
  • 70083072 - [skip ci] Copy CODEOWNERS from the default branch
  • 20f66171 - [skip ci] Copy CODEOWNERS from the default branch
  • 87dcb105 - [skip ci] Copy CODEOWNERS from the default branch
  • e9d454e4 - [skip ci] Copy CODEOWNERS from the default branch
  • 9a486cd3 - [skip ci] Copy CODEOWNERS from the default branch
  • 773a53ed - [skip ci] Copy CODEOWNERS from the default branch
  • 36228772 - [skip ci] Copy CODEOWNERS from the default branch
  • 671a662e - [skip ci] Copy CODEOWNERS from the default branch
  • c32b44c0 - [skip ci] Copy CODEOWNERS from the default branch
  • 75e24bd7 - [skip ci] Copy CODEOWNERS from the default branch
  • b49d8bf7 - [skip ci] Copy CODEOWNERS from the default branch
  • 1506289e - [skip ci] Copy CODEOWNERS from the default branch
  • 96e37339 - [skip ci] Copy CODEOWNERS from the default branch
  • 545b2304 - [skip ci] Copy CODEOWNERS from the default branch
  • 7129dd13 - [skip ci] Copy CODEOWNERS from the default branch
  • fa40654f - [skip ci] Copy CODEOWNERS from the default branch
  • 7ff44938 - [skip ci] Copy CODEOWNERS from the default branch
  • 298d1ad8 - [skip ci] Copy CODEOWNERS from the default branch
  • ad0ca7d1 - [skip ci] Copy CODEOWNERS from the default branch
  • 242fdc5e - [skip ci] Copy CODEOWNERS from the default branch
  • f1527a52 - [skip ci] Copy CODEOWNERS from the default branch
  • 281d1c07 - [skip ci] Copy CODEOWNERS from the default branch
  • 18502365 - [skip ci] Copy CODEOWNERS from the default branch
  • 0412aec7 - [skip ci] Copy CODEOWNERS from the default branch
  • 93fe15a0 - [skip ci] Copy CODEOWNERS from the default branch
  • 1d4cfdc9 - [skip ci] Copy CODEOWNERS from the default branch
  • d61c01f6 - [skip ci] Copy CODEOWNERS from the default branch
  • e9e05a34 - [skip ci] Copy CODEOWNERS from the default branch
  • 72bbd1ba - [skip ci] Copy CODEOWNERS from the default branch
  • 9b2859f7 - [skip ci] Copy CODEOWNERS from the default branch
  • 984f9ebe - [skip ci] Copy CODEOWNERS from the default branch
  • e8c2397c - [skip ci] Copy CODEOWNERS from the default branch
  • 23654fb6 - [skip ci] Copy CODEOWNERS from the default branch
  • 52233121 - [skip ci] Copy CODEOWNERS from the default branch
  • 106a24a4 - [skip ci] Copy CODEOWNERS from the default branch
  • 1e820d71 - [skip ci] Copy CODEOWNERS from the default branch
  • a8593f20 - [skip ci] Copy CODEOWNERS from the default branch
  • b8d06800 - [skip ci] Copy CODEOWNERS from the default branch
  • bf7af88d - [skip ci] Copy CODEOWNERS from the default branch
  • 7d8a4273 - [skip ci] Copy CODEOWNERS from the default branch
  • 690700f6 - [skip ci] Copy CODEOWNERS from the default branch
  • 9c45f589 - [skip ci] Copy CODEOWNERS from the default branch
  • 2c84fdb8 - [skip ci] Copy CODEOWNERS from the default branch
  • e22120e2 - [skip ci] Copy CODEOWNERS from the default branch
  • 10d65d5a - [skip ci] Copy CODEOWNERS from the default branch
  • 5c0a489f - [skip ci] Copy CODEOWNERS from the default branch
  • dcdce23b - [skip ci] Copy CODEOWNERS from the default branch
  • 56c28056 - [skip ci] Copy CODEOWNERS from the default branch
  • acb411e7 - [skip ci] Copy CODEOWNERS from the default branch
  • 9809b9a4 - [skip ci] Copy CODEOWNERS from the default branch
  • 397d9ccb - [skip ci] Copy CODEOWNERS from the default branch
  • 1ac1b615 - [skip ci] Copy CODEOWNERS from the default branch
  • eb59efd6 - [skip ci] Copy CODEOWNERS from the default branch
  • 42532879 - [skip ci] Copy CODEOWNERS from the default branch
  • 28c6f5aa - [skip ci] Copy CODEOWNERS from the default branch
  • 25dd1fd2 - [skip ci] Copy CODEOWNERS from the default branch
  • d04cb214 - [skip ci] Copy CODEOWNERS from the default branch
  • 87b3fe2c - [skip ci] Copy CODEOWNERS from the default branch
  • d813536a - [skip ci] Copy CODEOWNERS from the default branch
  • 2960da0c - [skip ci] Copy CODEOWNERS from the default branch
  • 33859dad - [skip ci] Copy CODEOWNERS from the default branch
  • 164f769e - [skip ci] Copy CODEOWNERS from the default branch
  • 4a09142e - [skip ci] Copy CODEOWNERS from the default branch
  • 31c85eff - [skip ci] Copy CODEOWNERS from the default branch
  • babfde85 - [skip ci] Copy CODEOWNERS from the default branch
  • 105dff8c - [skip ci] Copy CODEOWNERS from the default branch
  • eab7db7d - [skip ci] Copy CODEOWNERS from the default branch
  • 3fae42c7 - [skip ci] Copy CODEOWNERS from the default branch
  • a2dbc03b - [skip ci] Copy CODEOWNERS from the default branch
  • 77364140 - [skip ci] Copy CODEOWNERS from the default branch
  • a67cdb63 - [skip ci] Copy CODEOWNERS from the default branch
  • 585f4c00 - [skip ci] Copy CODEOWNERS from the default branch
  • 6b72f354 - [skip ci] Copy CODEOWNERS from the default branch
  • 484eeda4 - [skip ci] Copy CODEOWNERS from the default branch
  • d80e01da - [skip ci] Copy CODEOWNERS from the default branch
  • 7d405e7c - [skip ci] Copy CODEOWNERS from the default branch
  • 17f39316 - [skip ci] Copy CODEOWNERS from the default branch
  • 6ffe0fb0 - [skip ci] Copy CODEOWNERS from the default branch
  • 2c04ab95 - [skip ci] Copy CODEOWNERS from the default branch
  • 092f3080 - [skip ci] Copy CODEOWNERS from the default branch
  • 2a60cc1d - [skip ci] Copy CODEOWNERS from the default branch
  • 4d603536 - [skip ci] Copy CODEOWNERS from the default branch
  • 9e5032a1 - [skip ci] Copy CODEOWNERS from the default branch
  • 2b072aaa - [skip ci] Copy CODEOWNERS from the default branch
  • 422e4220 - [skip ci] Copy CODEOWNERS from the default branch
  • 5f597920 - [skip ci] Copy CODEOWNERS from the default branch
  • 41bd2d15 - [skip ci] Copy CODEOWNERS from the default branch
  • 3a8c9c12 - [skip ci] Copy CODEOWNERS from the default branch
  • 65e1f1a5 - [skip ci] Copy CODEOWNERS from the default branch
  • 447c3f2e - [skip ci] Copy CODEOWNERS from the default branch
  • bc3ef444 - [skip ci] Copy CODEOWNERS from the default branch
  • ad938c69 - [skip ci] Copy CODEOWNERS from the default branch
  • 0a371184 - [skip ci] Copy CODEOWNERS from the default branch
  • f2e545c0 - [skip ci] Copy CODEOWNERS from the default branch
  • bba70807 - [skip ci] Copy CODEOWNERS from the default branch
  • 3f2657f7 - [skip ci] Copy CODEOWNERS from the default branch
  • f23ac904 - [skip ci] Copy CODEOWNERS from the default branch
  • 6f51c550 - [skip ci] Copy CODEOWNERS from the default branch
  • ed6e78eb - [skip ci] Copy CODEOWNERS from the default branch
  • dbc5874f - [skip ci] Copy CODEOWNERS from the default branch
  • 3363227c - [skip ci] Copy CODEOWNERS from the default branch
  • df562073 - [skip ci] Copy CODEOWNERS from the default branch
  • 2dca0656 - [skip ci] Copy CODEOWNERS from the default branch
  • cf22f710 - [skip ci] Copy CODEOWNERS from the default branch
  • 978f40e8 - [skip ci] Copy CODEOWNERS from the default branch
  • 28d996af - [skip ci] Copy CODEOWNERS from the default branch
  • aa256602 - [skip ci] Copy CODEOWNERS from the default branch
  • 3b2bebd3 - [skip ci] Copy CODEOWNERS from the default branch
  • 166bf231 - [skip ci] Copy CODEOWNERS from the default branch
  • 9674993c - Removing /tmp/confluent as the DSTDIR check from Makefile
  • f7da1047 - Checking if removing the comment helps this pass in the upstream build
  • 6b994366 - Disabling flakey test
  • 3ac1df6b - Fix flakey test similar to
  • a2297ef2 - [skip ci] Copy CODEOWNERS from the default branch
  • 651f40c4 - [skip ci] Copy CODEOWNERS from the default branch
  • 76e35b41 - [skip ci] Copy CODEOWNERS from the default branch
  • 33bac739 - [skip ci] Copy CODEOWNERS from the default branch
  • f1f413ce - [skip ci] Copy CODEOWNERS from the default branch
  • 5c62f5d1 - [skip ci] Copy CODEOWNERS from the default branch
  • b6536e06 - [skip ci] Copy CODEOWNERS from the default branch
  • 207d6e13 - [skip ci] Copy CODEOWNERS from the default branch
  • 5c8bba63 - [skip ci] Copy CODEOWNERS from the default branch
  • 5b880bf9 - [skip ci] Copy CODEOWNERS from the default branch
  • 65f9900a - [skip ci] Copy CODEOWNERS from the default branch
  • 218e7118 - [skip ci] Copy CODEOWNERS from the default branch
  • 4872ccee - [skip ci] Copy CODEOWNERS from the default branch
  • c278841a - [skip ci] Copy CODEOWNERS from the default branch
  • ae87efe5 - [skip ci] Copy CODEOWNERS from the default branch
  • c782d6df - [skip ci] Copy CODEOWNERS from the default branch
  • ab63e4bf - [skip ci] Copy CODEOWNERS from the default branch
  • e32252f7 - [skip ci] Copy CODEOWNERS from the default branch
  • 4b0825aa - [skip ci] Copy CODEOWNERS from the default branch
  • c712a7b6 - [skip ci] Copy CODEOWNERS from the default branch
  • 5a865ad1 - [skip ci] Copy CODEOWNERS from the default branch
  • 6d5db24c - [skip ci] Copy CODEOWNERS from the default branch
  • 89b92bd2 - [skip ci] Copy CODEOWNERS from the default branch
  • ad5830c8 - [skip ci] Copy CODEOWNERS from the default branch
  • 9905c26a - [skip ci] Copy CODEOWNERS from the default branch
  • 74ab9454 - [skip ci] Copy CODEOWNERS from the default branch
  • 2e88469c - [skip ci] Copy CODEOWNERS from the default branch
  • 60a62854 - [skip ci] Copy CODEOWNERS from the default branch
  • 53a84c75 - [skip ci] Copy CODEOWNERS from the default branch
  • 86859186 - [skip ci] Copy CODEOWNERS from the default branch
  • c679c697 - [skip ci] Copy CODEOWNERS from the default branch
  • c98d6ca5 - [skip ci] Copy CODEOWNERS from the default branch
  • f54b5869 - [skip ci] Copy CODEOWNERS from the default branch
  • 82b88384 - [skip ci] Copy CODEOWNERS from the default branch
  • 8e2dd726 - [skip ci] Copy CODEOWNERS from the default branch
  • 5c328be7 - [skip ci] Copy CODEOWNERS from the default branch
  • a113fa42 - [skip ci] Copy CODEOWNERS from the default branch
  • 1a593b91 - [skip ci] Copy CODEOWNERS from the default branch
  • 776697e6 - [skip ci] Copy CODEOWNERS from the default branch
  • 624fe9e4 - [skip ci] Copy CODEOWNERS from the default branch
  • 87036a01 - [skip ci] Copy CODEOWNERS from the default branch
  • f38d54a5 - [skip ci] Copy CODEOWNERS from the default branch
  • 9c7ff08b - [skip ci] Copy CODEOWNERS from the default branch
  • 19196fdf - [skip ci] Copy CODEOWNERS from the default branch
  • da00d80b - [skip ci] Copy CODEOWNERS from the default branch
  • 280aae15 - [skip ci] Copy CODEOWNERS from the default branch
  • f3ccff55 - [skip ci] Copy CODEOWNERS from the default branch
  • ae43c59c - [skip ci] Copy CODEOWNERS from the default branch
  • 3c753719 - [skip ci] Copy CODEOWNERS from the default branch
  • ef0265b2 - [skip ci] Copy CODEOWNERS from the default branch
  • 855a3f92 - [skip ci] Copy CODEOWNERS from the default branch
  • 2c0bd775 - [skip ci] Copy CODEOWNERS from the default branch
  • ccd4c3ff - [skip ci] Copy CODEOWNERS from the default branch
  • 611dfcc1 - [skip ci] Copy CODEOWNERS from the default branch
  • 718c96af - [skip ci] Copy CODEOWNERS from the default branch
  • adde81bc - [skip ci] Copy CODEOWNERS from the default branch
  • c7def207 - [skip ci] Copy CODEOWNERS from the default branch
  • bcbca6f3 - [skip ci] Copy CODEOWNERS from the default branch
  • fd8daf34 - [skip ci] Copy CODEOWNERS from the default branch
  • c8415273 - [skip ci] Copy CODEOWNERS from the default branch
  • 2fbb320f - [skip ci] Copy CODEOWNERS from the default branch
  • 61ae4210 - [skip ci] Copy CODEOWNERS from the default branch
  • 1549a733 - [skip ci] Copy CODEOWNERS from the default branch
  • 0234a19e - [skip ci] Copy CODEOWNERS from the default branch
  • 4b905680 - [skip ci] Copy CODEOWNERS from the default branch
  • 4b4879f9 - [skip ci] Copy CODEOWNERS from the default branch
  • fc07f523 - [skip ci] Copy CODEOWNERS from the default branch
  • fcac05cc - [skip ci] Copy CODEOWNERS from the default branch
  • 5a863941 - [skip ci] Copy CODEOWNERS from the default branch
  • 0c68cb91 - [skip ci] Copy CODEOWNERS from the default branch
  • f6e07609 - [skip ci] Copy CODEOWNERS from the default branch
  • 7bc4eb1d - [skip ci] Copy CODEOWNERS from the default branch
  • b99068e4 - [skip ci] Copy CODEOWNERS from the default branch
  • d0954367 - [skip ci] Copy CODEOWNERS from the default branch
  • 0a58c76a - [skip ci] Copy CODEOWNERS from the default branch
  • a552df85 - [skip ci] Copy CODEOWNERS from the default branch
  • 44629de2 - [skip ci] Copy CODEOWNERS from the default branch
  • e48e59f7 - [skip ci] Copy CODEOWNERS from the default branch
  • 38ab6618 - [skip ci] Copy CODEOWNERS from the default branch
  • 531668ac - [skip ci] Copy CODEOWNERS from the default branch
  • e70d2084 - [skip ci] Copy CODEOWNERS from the default branch
  • fc97d1d2 - [skip ci] Copy CODEOWNERS from the default branch
  • c6b58d0c - [skip ci] Copy CODEOWNERS from the default branch
  • 264002d6 - [skip ci] Copy CODEOWNERS from the default branch
  • 65b47b1b - [skip ci] Copy CODEOWNERS from the default branch
  • 0961d44c - [skip ci] Copy CODEOWNERS from the default branch
  • fe0e4319 - [skip ci] Copy CODEOWNERS from the default branch
  • 6ece1e71 - [skip ci] Copy CODEOWNERS from the default branch
  • 63e16f69 - [skip ci] Copy CODEOWNERS from the default branch
  • a1421f92 - [skip ci] Copy CODEOWNERS from the default branch
  • 0bb5993b - [skip ci] Copy CODEOWNERS from the default branch
  • 2ce35d18 - [skip ci] Copy CODEOWNERS from the default branch
  • 92b470e2 - [skip ci] Copy CODEOWNERS from the default branch
  • 6e3e59aa - [skip ci] Copy CODEOWNERS from the default branch
  • 9af44114 - [skip ci] Copy CODEOWNERS from the default branch
  • e4e51111 - [skip ci] Copy CODEOWNERS from the default branch
  • d451937c - [skip ci] Copy CODEOWNERS from the default branch
  • e10cc47e - [skip ci] Copy CODEOWNERS from the default branch
  • bc74f98d - [skip ci] Copy CODEOWNERS from the default branch
  • bbc9e470 - [skip ci] Copy CODEOWNERS from the default branch
  • e8b39d23 - [skip ci] Copy CODEOWNERS from the default branch
  • d95c69bf - [skip ci] Copy CODEOWNERS from the default branch
  • bcb4ab33 - [skip ci] Copy CODEOWNERS from the default branch
  • f6c17454 - [skip ci] Copy CODEOWNERS from the default branch
  • 79b1c2b9 - [skip ci] Copy CODEOWNERS from the default branch
  • 261756df - [skip ci] Copy CODEOWNERS from the default branch
  • e25becd7 - [skip ci] Copy CODEOWNERS from the default branch
  • 7cba7835 - [skip ci] Copy CODEOWNERS from the default branch
  • 46b43fcc - [skip ci] Copy CODEOWNERS from the default branch
  • e7096662 - [skip ci] Copy CODEOWNERS from the default branch
  • 832238d1 - [skip ci] Copy CODEOWNERS from the default branch
  • a9cc866e - [skip ci] Copy CODEOWNERS from the default branch
  • 8497b008 - [skip ci] Copy CODEOWNERS from the default branch
  • 66222b44 - [skip ci] Copy CODEOWNERS from the default branch
  • 0ceb19d9 - [skip ci] Copy CODEOWNERS from the default branch
  • a9c9c07c - [skip ci] Copy CODEOWNERS from the default branch
  • 8a6e8125 - [skip ci] Copy CODEOWNERS from the default branch
  • 6c871751 - [skip ci] Copy CODEOWNERS from the default branch
  • ef6f3b5b - [skip ci] Copy CODEOWNERS from the default branch
  • a931e891 - [skip ci] Copy CODEOWNERS from the default branch
  • b17d2f4f - [skip ci] Copy CODEOWNERS from the default branch
  • 67391bbf - [skip ci] Copy CODEOWNERS from the default branch
  • 84ff0461 - [skip ci] Copy CODEOWNERS from the default branch
  • 2742dbc0 - [skip ci] Copy CODEOWNERS from the default branch
  • 63020b73 - [skip ci] Copy CODEOWNERS from the default branch
  • 605fef38 - [skip ci] Copy CODEOWNERS from the default branch
  • 212207b3 - [skip ci] Copy CODEOWNERS from the default branch
  • 81ffa922 - [skip ci] Copy CODEOWNERS from the default branch
  • 9de1ae76 - [skip ci] Copy CODEOWNERS from the default branch
  • f230d01d - [skip ci] Copy CODEOWNERS from the default branch
  • d8161abf - [skip ci] Copy CODEOWNERS from the default branch
  • 33e3fd19 - [skip ci] Copy CODEOWNERS from the default branch
  • 8bab397c - [skip ci] Copy CODEOWNERS from the default branch
  • 4d0c897c - [skip ci] Copy CODEOWNERS from the default branch
  • 56ade566 - [skip ci] Copy CODEOWNERS from the default branch
  • 610d46ce - [skip ci] Copy CODEOWNERS from the default branch
  • 7515dada - [skip ci] Copy CODEOWNERS from the default branch
  • 0982fd7c - [skip ci] Copy CODEOWNERS from the default branch
  • c0f5c52e - [skip ci] Copy CODEOWNERS from the default branch
  • 64cc2ea1 - [skip ci] Copy CODEOWNERS from the default branch
  • e89fd8e6 - [skip ci] Copy CODEOWNERS from the default branch
  • a5f01619 - [skip ci] Copy CODEOWNERS from the default branch
  • e89907a3 - [skip ci] Copy CODEOWNERS from the default branch
  • 1ffb1e9a - [skip ci] Copy CODEOWNERS from the default branch
  • 02b448a5 - [skip ci] Copy CODEOWNERS from the default branch
  • 6f198a06 - [skip ci] Copy CODEOWNERS from the default branch
  • 75fef45f - [skip ci] Copy CODEOWNERS from the default branch
  • 75bd69c5 - [skip ci] Copy CODEOWNERS from the default branch
  • da298ea9 - [skip ci] Copy CODEOWNERS from the default branch
  • 9a93de46 - [skip ci] Copy CODEOWNERS from the default branch
  • 1332b4dd - [skip ci] Copy CODEOWNERS from the default branch
  • 3e4d40cb - [skip ci] Copy CODEOWNERS from the default branch
  • 1d82ebb3 - [skip ci] Copy CODEOWNERS from the default branch
  • b0736e52 - [skip ci] Copy CODEOWNERS from the default branch
  • 38128cc3 - [skip ci] Copy CODEOWNERS from the default branch
  • bdafc89e - [skip ci] Copy CODEOWNERS from the default branch
  • a95839e4 - [skip ci] Copy CODEOWNERS from the default branch
  • 7a6754dc - [skip ci] Copy CODEOWNERS from the default branch
  • 7a9a85bf - [skip ci] Copy CODEOWNERS from the default branch
  • 82c25098 - [skip ci] Copy CODEOWNERS from the default branch
  • d7c96d1e - [skip ci] Copy CODEOWNERS from the default branch
  • f46091f9 - [skip ci] Copy CODEOWNERS from the default branch
  • fd4b3181 - [skip ci] Copy CODEOWNERS from the default branch
  • 79345bb0 - [skip ci] Copy CODEOWNERS from the default branch
  • d9fcedd3 - [skip ci] Copy CODEOWNERS from the default branch
  • 338182a1 - [skip ci] Copy CODEOWNERS from the default branch
  • 11c8d4f6 - [skip ci] Copy CODEOWNERS from the default branch
  • 0b632a37 - [skip ci] Copy CODEOWNERS from the default branch

Schema Registry

  • b862eb19 - fix merge issue
  • 6a9d6e22 - Fix Protobuf custom option for single-entry map
  • 2d3c4736 - Revert “do not reinstantiate objectmapper as it’s expensive (#2686) (#2695)”
  • cdf34e52 - Fix deserialization of Avro unions with logical types
  • 0e4552fe - [skip ci] Copy CODEOWNERS from the default branch
  • be973d31 - [skip ci] Copy CODEOWNERS from the default branch
  • 3d20da54 - [skip ci] Copy CODEOWNERS from the default branch
  • cfc91482 - [skip ci] Copy CODEOWNERS from the default branch
  • b6b122d1 - [skip ci] Copy CODEOWNERS from the default branch
  • de2dd7a1 - [skip ci] Copy CODEOWNERS from the default branch
  • a26607ff - [skip ci] Copy CODEOWNERS from the default branch
  • fff14afd - [skip ci] Copy CODEOWNERS from the default branch
  • 65f9cbae - [skip ci] Copy CODEOWNERS from the default branch
  • 0a19a7ec - [skip ci] Copy CODEOWNERS from the default branch
  • 1c67c003 - [skip ci] Copy CODEOWNERS from the default branch
  • 21ab9974 - [skip ci] Copy CODEOWNERS from the default branch
  • f1d74be3 - [skip ci] Copy CODEOWNERS from the default branch
  • 57dcb51d - [skip ci] Copy CODEOWNERS from the default branch
  • cc1b888a - [skip ci] Copy CODEOWNERS from the default branch
  • 3cca8c8e - [skip ci] Copy CODEOWNERS from the default branch
  • e6415268 - [skip ci] Copy CODEOWNERS from the default branch
  • be8789c8 - [skip ci] Copy CODEOWNERS from the default branch
  • d51dadef - [skip ci] Copy CODEOWNERS from the default branch
  • 053ffc65 - [skip ci] Copy CODEOWNERS from the default branch
  • 48f95eab - [skip ci] Copy CODEOWNERS from the default branch
  • 9fb80938 - [skip ci] Copy CODEOWNERS from the default branch
  • d666957e - [skip ci] Copy CODEOWNERS from the default branch
  • 7e1384c1 - [skip ci] Copy CODEOWNERS from the default branch
  • 3807e0b1 - [skip ci] Copy CODEOWNERS from the default branch
  • db0d92da - [skip ci] Copy CODEOWNERS from the default branch
  • f58b9a44 - [skip ci] Copy CODEOWNERS from the default branch
  • c9bfdf85 - [skip ci] Copy CODEOWNERS from the default branch
  • 44053962 - [skip ci] Copy CODEOWNERS from the default branch
  • e919a53a - [skip ci] Copy CODEOWNERS from the default branch
  • 3b139777 - [skip ci] Copy CODEOWNERS from the default branch
  • 1f8e55ec - [skip ci] Copy CODEOWNERS from the default branch
  • 315a93f0 - [skip ci] Copy CODEOWNERS from the default branch
  • 87f176c6 - [skip ci] Copy CODEOWNERS from the default branch
  • c2ea7f63 - [skip ci] Copy CODEOWNERS from the default branch
  • c4583749 - [skip ci] Copy CODEOWNERS from the default branch
  • 9338e69f - [skip ci] Copy CODEOWNERS from the default branch
  • 1c81c926 - [skip ci] Copy CODEOWNERS from the default branch
  • fc42617c - [skip ci] Copy CODEOWNERS from the default branch
  • 46ef3a10 - [skip ci] Copy CODEOWNERS from the default branch
  • 2fbc38dc - [skip ci] Copy CODEOWNERS from the default branch
  • 9b568526 - [skip ci] Copy CODEOWNERS from the default branch
  • b6df6407 - [skip ci] Copy CODEOWNERS from the default branch
  • 59ebf04b - [skip ci] Copy CODEOWNERS from the default branch
  • d9034596 - [skip ci] Copy CODEOWNERS from the default branch
  • 3b4269c7 - [skip ci] Copy CODEOWNERS from the default branch
  • ddfcc5a6 - [skip ci] Copy CODEOWNERS from the default branch
  • 070fdd65 - [skip ci] Copy CODEOWNERS from the default branch
  • b60a8b91 - [skip ci] Copy CODEOWNERS from the default branch
  • 48553994 - [skip ci] Copy CODEOWNERS from the default branch
  • b5d123c0 - [skip ci] Copy CODEOWNERS from the default branch
  • 7ed17673 - [skip ci] Copy CODEOWNERS from the default branch
  • e3dbf432 - [skip ci] Copy CODEOWNERS from the default branch
  • a46c233b - [skip ci] Copy CODEOWNERS from the default branch
  • cd927005 - [skip ci] Copy CODEOWNERS from the default branch
  • d85eb75d - [skip ci] Copy CODEOWNERS from the default branch
  • ebebe49c - [skip ci] Copy CODEOWNERS from the default branch
  • 7d051458 - [skip ci] Copy CODEOWNERS from the default branch
  • 7184dd8b - [skip ci] Copy CODEOWNERS from the default branch
  • 05b2fb73 - [skip ci] Copy CODEOWNERS from the default branch
  • d6c639a9 - [skip ci] Copy CODEOWNERS from the default branch
  • 0ed0b521 - [skip ci] Copy CODEOWNERS from the default branch
  • 99c7c7e7 - [skip ci] Copy CODEOWNERS from the default branch
  • 336d8daf - [skip ci] Copy CODEOWNERS from the default branch
  • 64a2fa5c - [skip ci] Copy CODEOWNERS from the default branch
  • 9dd607a4 - [skip ci] Copy CODEOWNERS from the default branch
  • 85a6c0cf - [skip ci] Copy CODEOWNERS from the default branch
  • babc9618 - [skip ci] Copy CODEOWNERS from the default branch
  • 2e7d8d90 - [skip ci] Copy CODEOWNERS from the default branch
  • 0ea0881b - [skip ci] Copy CODEOWNERS from the default branch
  • 8906b866 - [skip ci] Copy CODEOWNERS from the default branch
  • 85a686de - [skip ci] Copy CODEOWNERS from the default branch
  • 20edd638 - [skip ci] Copy CODEOWNERS from the default branch
  • 8f58bf4a - [skip ci] Copy CODEOWNERS from the default branch
  • 2c0e8d1e - [skip ci] Copy CODEOWNERS from the default branch
  • 9006d494 - [skip ci] Copy CODEOWNERS from the default branch
  • f266e7b3 - [skip ci] Copy CODEOWNERS from the default branch
  • 0c451364 - [skip ci] Copy CODEOWNERS from the default branch
  • d9b6a7b7 - [skip ci] Copy CODEOWNERS from the default branch
  • 697c92a3 - [skip ci] Copy CODEOWNERS from the default branch
  • 87e39d99 - [skip ci] Copy CODEOWNERS from the default branch
  • 6f592077 - [skip ci] Copy CODEOWNERS from the default branch
  • 568c3c9c - [skip ci] Copy CODEOWNERS from the default branch
  • 55572bc9 - [skip ci] Copy CODEOWNERS from the default branch
  • f795cfdd - [skip ci] Copy CODEOWNERS from the default branch
  • 79fca338 - [skip ci] Copy CODEOWNERS from the default branch
  • 4fbc5a0b - [skip ci] Copy CODEOWNERS from the default branch
  • 4e14f53f - [skip ci] Copy CODEOWNERS from the default branch
  • 1f979acc - [skip ci] Copy CODEOWNERS from the default branch
  • 7bc6f359 - [skip ci] Copy CODEOWNERS from the default branch
  • fcf7aa68 - [skip ci] Copy CODEOWNERS from the default branch
  • aba7c810 - [skip ci] Copy CODEOWNERS from the default branch
  • 809080e6 - [skip ci] Copy CODEOWNERS from the default branch
  • d4aa15e6 - [skip ci] Copy CODEOWNERS from the default branch
  • 385ec04e - [skip ci] Copy CODEOWNERS from the default branch
  • 54610aae - [skip ci] Copy CODEOWNERS from the default branch
  • 88f3532c - [skip ci] Copy CODEOWNERS from the default branch
  • 7762ec8c - [skip ci] Copy CODEOWNERS from the default branch
  • fde9940a - [skip ci] Copy CODEOWNERS from the default branch
  • a7cd7bd3 - [skip ci] Copy CODEOWNERS from the default branch
  • d365a238 - [skip ci] Copy CODEOWNERS from the default branch
  • 979935fa - [skip ci] Copy CODEOWNERS from the default branch
  • 52b6315b - [skip ci] Copy CODEOWNERS from the default branch
  • 5a6640b3 - [skip ci] Copy CODEOWNERS from the default branch
  • 148cebf7 - [skip ci] Copy CODEOWNERS from the default branch
  • 25c7e31e - [skip ci] Copy CODEOWNERS from the default branch
  • b604f8f1 - [skip ci] Copy CODEOWNERS from the default branch
  • cbb507b5 - [skip ci] Copy CODEOWNERS from the default branch
  • e4d12664 - [skip ci] Copy CODEOWNERS from the default branch
  • f29827d0 - [skip ci] Copy CODEOWNERS from the default branch
  • 2976d5f2 - [skip ci] Copy CODEOWNERS from the default branch
  • e0492a62 - [skip ci] Copy CODEOWNERS from the default branch
  • b109d01f - [skip ci] Copy CODEOWNERS from the default branch
  • 41fb4c4e - [skip ci] Copy CODEOWNERS from the default branch
  • 448c2e7d - [skip ci] Copy CODEOWNERS from the default branch
  • e09a3f27 - [skip ci] Copy CODEOWNERS from the default branch
  • 5f17cc99 - [skip ci] Copy CODEOWNERS from the default branch
  • b682add5 - [skip ci] Copy CODEOWNERS from the default branch
  • 83018694 - [skip ci] Copy CODEOWNERS from the default branch
  • 2ada8010 - [skip ci] Copy CODEOWNERS from the default branch
  • 17d1911e - [skip ci] Copy CODEOWNERS from the default branch
  • 3532d7fd - [skip ci] Copy CODEOWNERS from the default branch
  • 075ef6e7 - [skip ci] Copy CODEOWNERS from the default branch
  • 48b2c056 - [skip ci] Copy CODEOWNERS from the default branch
  • 3505dab8 - [skip ci] Copy CODEOWNERS from the default branch
  • a38799c5 - [skip ci] Copy CODEOWNERS from the default branch
  • 040d788d - [skip ci] Copy CODEOWNERS from the default branch
  • c3df6822 - [skip ci] Copy CODEOWNERS from the default branch
  • 715dd1a5 - [skip ci] Copy CODEOWNERS from the default branch
  • b60bcd82 - [skip ci] Copy CODEOWNERS from the default branch
  • 9544e2f4 - [skip ci] Copy CODEOWNERS from the default branch
  • 822e09d4 - [skip ci] Copy CODEOWNERS from the default branch
  • 5491f42f - [skip ci] Copy CODEOWNERS from the default branch
  • ebe31fd9 - [skip ci] Copy CODEOWNERS from the default branch
  • d1407b91 - [skip ci] Copy CODEOWNERS from the default branch
  • d71c4cf0 - [skip ci] Copy CODEOWNERS from the default branch
  • 08118171 - [skip ci] Copy CODEOWNERS from the default branch
  • 4ac1cac3 - [skip ci] Copy CODEOWNERS from the default branch
  • a90d3299 - [skip ci] Copy CODEOWNERS from the default branch
  • 823b5bb4 - [skip ci] Copy CODEOWNERS from the default branch
  • c5558b8a - [skip ci] Copy CODEOWNERS from the default branch
  • 6b962a95 - [skip ci] Copy CODEOWNERS from the default branch
  • fb07b501 - [skip ci] Copy CODEOWNERS from the default branch
  • e6eed195 - [skip ci] Copy CODEOWNERS from the default branch
  • 57da7b81 - [skip ci] Copy CODEOWNERS from the default branch
  • 9a0fac41 - [skip ci] Copy CODEOWNERS from the default branch
  • 2c70ff4d - [skip ci] Copy CODEOWNERS from the default branch
  • dc54354e - [skip ci] Copy CODEOWNERS from the default branch
  • edbe009a - [skip ci] Copy CODEOWNERS from the default branch
  • 228193cf - [skip ci] Copy CODEOWNERS from the default branch
  • 0c3d40dc - [skip ci] Copy CODEOWNERS from the default branch
  • 79ec0638 - [skip ci] Copy CODEOWNERS from the default branch
  • 5a02cb97 - [skip ci] Copy CODEOWNERS from the default branch
  • eafb0d45 - [skip ci] Copy CODEOWNERS from the default branch
  • 1d031141 - [skip ci] Copy CODEOWNERS from the default branch
  • f5726d05 - [skip ci] Copy CODEOWNERS from the default branch
  • 30d1b76f - [skip ci] Copy CODEOWNERS from the default branch
  • 434730c1 - [skip ci] Copy CODEOWNERS from the default branch
  • 8f83e416 - [skip ci] Copy CODEOWNERS from the default branch
  • bfeba831 - [skip ci] Copy CODEOWNERS from the default branch
  • fd35b90e - [skip ci] Copy CODEOWNERS from the default branch
  • 41447b05 - [skip ci] Copy CODEOWNERS from the default branch
  • d4e486a1 - [skip ci] Copy CODEOWNERS from the default branch
  • 966c6d3f - [skip ci] Copy CODEOWNERS from the default branch
  • 01585c10 - [skip ci] Copy CODEOWNERS from the default branch
  • 4dd9d4d5 - [skip ci] Copy CODEOWNERS from the default branch
  • f2d717da - [skip ci] Copy CODEOWNERS from the default branch
  • 285302b2 - [skip ci] Copy CODEOWNERS from the default branch
  • 75f07a5f - update azure-identity
  • 2c980a77 - More robust usage of ServiceLoader
  • 79d50b79 - Add comment
  • 2c6c783c - Enhance Avro error with type name
  • f98a7075 - Fix checkstyle
  • d81d0f49 - Unwrap IllegalStateException if possible
  • fdc39bff - Fix handleDeleteSubject to pass right oldSchemaValue
  • de17bc6e - Support passing keystore/truststore to Vault KMS client
  • PR-3110 - Revert jackson to 2.14.2
  • 57308f0b - upgrade jackson package to fix build
  • c3520a33 - Removing /tmp/confluent as the DSTDIR check from Makefile
  • PR-3098 - Fix build due to Jackson upgrade to 2.16.2
  • fa9545cc - Ensure consistent lookup of rule params
  • b36c62ae - Support const in JSONSchemaConverter
  • 2c32a50d - Refactor storage value to entity conversions
  • 8eeaf335 - Add disabled override
  • 93d8d2f8 - Allow rule onFailure/onSuccess to be overriden by rule type
  • 4d377d80 - Allow rule onFailure/onSuccess to be overriden via props
  • af548bf0 - Update Apache commons-compress to 1.26.1
  • c0cbc3c8 - Add test
  • fce6aaf6 - Ensure sensitive values are decoded during listVersionsForId
  • 01d8b72b - Fix NPE in deser when use.latest=true and RecordNameStrategy
  • aab7e57f - Scrub Avro namespace when scrub.invalid.names=true
  • 7917b812 - Fix dek search
  • eb059309 - Fix comparator for DataEncryptionKeyId
  • c025d150 - Fix comparator for DataEncryptionKeyId
  • 07ea0e03 - Add DekRegistry to SR properties for easier access
  • 79947071 - Cache checkpoint for cacheInitialized before reader thread starts

Version 7.5.4

Released April 2024

Community Features

Common

  • 4fb11814 - Remove auto-generated CODEOWNERS. It’s inaccurate.
  • 52b0f806 - Remove CODEOWNERS file
  • 7a96a215 - Add service.yml
  • c4b849a5 - update jose4j
  • 4c8d3021 - update jetty to 9.4.54
  • PR-581 - fix: no implicit activation of docker-arm profile
  • PR-563 - added a new docker-arm profile to build docker containers in arm64

Kafka

  • PR-1127 - Update jose4j to 0.9.4 (#15284)
  • PR-1073 - Update jetty to 9.4.54.v20240208
  • PR-1015 - update bcprov-jdk15on
  • PR-15177 - Checkpoint restored offsets instead of written offsets (#15177)

ksqlDB

  • PR-10243 - Update Commons-Compress and commons-io
  • PR-10238 - Update apache.io.version
  • PR-10237 - Update commons-compress
  • PR-10223 - Change groupID to a more secure name
  • 2f84873b - Change groupID to a more secure name
  • 5612f336 - Increase execution time limit to 6 hours.
  • PR-10198 - Set timeout to 6 hours on branches starting on 7.3.x
  • 30544a65 - Cherry pick the replacement of easymock to mockito from newer branches.
  • PR-10195 - Add pinned nano version for common on 7.3.x
  • PR-10196 - Add pinned nano version for common for 7.4.x
  • f969d5c0 - Enable pinned nanoversions.
  • b49bbcbb - Specify type parameter for CommandStatus.
  • c7288dd0 - Remove maven cache restore.
  • cea27ec9 - set java version to 8
  • cd59a75a - Increase the execution time limit.
  • 26db19fd - Fixed the extra args in service.yml file.
  • PR-10189 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
  • PR-10175 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
  • PR-10178 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
  • 37e06168 - Fix the parent version in commons.
  • 5467ea20 - set java version to 8
  • 0a1cf171 - Increase the execution time limit.
  • db81cd09 - Fixed the extra args in service.yml file.

REST Proxy

  • PR-1250 - Allow to set KafkaAvroSerializerConfig in KafkaRestConfig (#1229)
  • 05925773 - cluster_id is not validated [cp version]
  • PR-1235 - Deflake KafkaConsumerManagerTest.testBackoffMsControlsPollCalls test
  • PR-1236 - disable flakey test

Schema Registry

  • PR-3059 - fix: nested schemas were not considered in matching the correct Json Union schema
  • 38e98145 - Handle nulls in enum in JSON Schema converter
  • 78ae7f7b - Fix merge issue
  • c84f735e - Update client/src/main/java/io/confluent/kafka/schemaregistry/rules/RuleContext.java
  • PR-3038 - feat: Added ReferenceSchema support to allOf
  • 2808930e - Add test to register same schema with no ID in IMPORT mode
  • ae0e3140 - fix: invalid behaviour for stringSchema in allOfToConnectSchema
  • 6dcb41f7 - Fix tests
  • 6a138838 - Allow exact same schema to be re-imported
  • 814141db - Update ProtobufSchema.java
  • 885098ab - Update JsonSchema.java
  • ff5b2158 - Add support for CONDITION with CEL_FIELD
  • 22f36f3f - Optimization: cache Tink primitives
  • 8b8eebe0 - Fix checkstyle
  • 1063bb4c - Add check for FieldRuleExecutor
  • bc194452 - Add a CEL test with a tags expr in the guard
  • ff0b820b - Ensure specific Avro type is setup during configure
  • 6df56c8f - Optimization: remove known deps from ProtobufSchema
  • 16214b96 - Re-add schema parameter that was dropped during refactor
  • d6095ad3 - Fix checkstyle
  • 343ddff3 - First commit
  • PR-3012 - Minor: Apply service bot changes to earlier branches
  • 306dd5c5 - Add error message for PACKAGE_CHANGED
  • 2861cd88 - Fix checkstyle
  • abbab267 - Ensure package change for Protobuf is incompatible
  • 641a9bab - Fix checkstyle
  • d59f138d - Enhance healthy method
  • aed3b7d5 - Ensure correct GenericData is used
  • 26569386 - Optimization: remove extraneous KekInfo/DekInfo classes
  • be5c571b - Improve parameter handling in FieldEncryptionExecutor
  • 3bd1cdd5 - update common-compress
  • 77f4ed97 - Ensure Vault namespace is being passed
  • 98ffc914 - update azure-identity
  • 2ef767e3 - Fix merge issue for wire upgrade
  • 7684230c - Update pom.xml
  • 177af0d0 - Add Protobuf compat check for moving field into existing oneOf
  • PR-2969 - Add health check for SR and extensions
  • 82f51da1 - Support older versions of Tink library
  • bbe261f4 - exclude okio
  • 28d86634 - Don’t prefix KEK names with the context in the ContextFilter
  • 0cb664f1 - Fix sharedKeys cache to account for multiple use of kms key ID
  • PR-2943 - Update Bouncycastle dependencies
  • d08a0978 - fix NPE when value is nil when print.schema.ids=true is set
  • 7ec6fc8b - Fix breaking change ti ParsedSchema.validate method
  • 9408a386 - Improve err msg
  • df7effb2 - Handle alreadyExists in putKek
  • 87ca438c - Cache shared KEKs in DEK Registry
  • PR-2937 - Added num_keks_shared metric
  • 13848a40 - Improve the performance of invalid name scrubbing
  • 0bdb81e7 - Omit decrypted DEK when registering DEK in IMPORT mode
  • 0eb5a631 - Allow JSONata exprs to be used for CONDITION rules
  • 85a9e53c - Also support allOf to singleton; add tests
  • 26a3423e - Ensure logicalType flag passed to ReflectData
  • 414ce79f - Better handling of JSON Schema singleton combined types

Version 7.5.3

Released December 2023

Community Features

Common

  • e99d8b1a - exclude logback-core and logback-classic in line with the changes in kafka-rest
  • eb200670 - update zookeeper component to match version in ce-kafka
  • 0c034e86 - re-add dependencymanagement sections for old bouncycastle to satisfy downstream validation
  • 33734c5f - add additional version definition to ease the update of the downstream repos
  • 8e71caf2 - update bouncycastle

Kafka

  • PR-14293 - KAFKA-15372: Reconfigure dedicated MM2 connectors after leadership change (#14293)
  • PR-14235 - KAFKA-15102: Add release notes about the replication.policy.internal.topic.separator.enabled property for MirrorMaker 2 (#14235)
  • 1e35277f - CONFLUENT: Bump ZK to 3.8.3 for 7.5.x
  • PR-989 - KSECURITY-2090: Updated bcpkix version to 1.77
  • PR-14635 - KAFKA-15755: LeaveGroupResponse v0 - v2 loses its member under certain error conditions (#14635)
  • PR-14718 - KAFKA-15800: Prevent DataExceptions from corrupting KafkaOffsetBackingStore (#14718)
  • PR-14647 - KAFKA-15693: Immediately reassign lost connectors and tasks when scheduled rebalance delay is disabled (#14647)
  • 79de845b - fix build error
  • PR-14506 - KAFKA-15552 Fix Producer ID ZK migration (#14506)
  • PR-14674 - KAFKA-15771: fix concurrency bug in ProduceRequest#partitionSizes() (#14674)
  • PR-14216 - KAFKA-15319: Upgrade rocksdb (#14216)
  • ad925d25 - Revert “KAFKA-15093: Add 3.5 Streams upgrade system tests (#14602)”
  • PR-13315 - KAFKA-14767: Fix missing commitId build error after git gc (#13315)
  • PR-14602 - KAFKA-15093: Add 3.5 Streams upgrade system tests (#14602)
  • PR-14601 - KAFKA-15664: Add 3.4 Streams upgrade system tests (#14601)
  • PR-14539 - KAFKA-15378: fix streams upgrade system test (#14539)
  • PR-14587 - KAFKA-15607: Fix NPE in MirrorCheckpointTask::syncGroupOffset (#14587)
  • PR-13920 - KAFKA-15106: Fix AbstractStickyAssignor isBalanced predict (#13920)
  • PR-14317 - KAFKA-13973: Fix inflated block cache metrics (#14317)
  • PR-14190 - KAFKA-7438: Replace Easymock & Powermock with Mockito in RocksDBMetricsRecorderGaugesTest (#14190)
  • PR-14126 - Fix a Scala 2.12 compile issue (#14126)
  • PR-14458 - KAFKA-15498: upgrade to snappy 1.1.10.5 (#14458)
  • PR-14434 - KAFKA-15498: bump snappy-java version to 1.1.10.4 (#14434)
  • PR-14519 - KAFKA-15571: StateRestoreListener#onRestoreSuspended is never called because DelegatingStateRestoreListener doesn’t implement onRestoreSuspended (#14519)
  • PR-14500 - HOTIFX: fix Kafka versions for system tests (#14500)
  • PR-14438 - Upgrade Jetty to 9.4.52.v20230823 (#14438)
  • PR-14445 - KAFKA-15502: Update SslEngineValidator to handle large stores (#14445)
  • PR-14367 - KAFKA-15450 Don’t allow ZK migration with JBOD (#14367)
  • PR-14221 - KAFKA-15338: The metric group documentation for metrics added in KAFKA-13945 is incorrect (#14221)
  • PR-14326 - KAFKA-15429: reset transactionInFlight on StreamsProducer close (#14326)
  • PR-14325 - KAFKA-15429: catch+log errors from unsubscribe in streamthread shutdown (#14325)
  • c252e930 - KAFKA-15375: fix broken clean shutdown detection logic in LogManager
  • PR-14236 - KAFKA-15353: make sure AlterPartitionRequest.build() is idempotent (#14236)
  • PR-14039 - KAFKA-15211: Mock InvalidParameterException in DistributedConfigTest (#14039)
  • PR-14244 - KAFKA-15377: Don’t expose externalized secret values in tasks-config API endpoint (#14244)
  • PR-14278 - KAFKA-15393: Improve shutdown behavior in MM2 integration tests (#14278)
  • PR-14280 - KAFKA-15391: Handle concurrent dir rename which makes log-dir to be offline unexpectedly (#14280)
  • PR-14103 - HOTIFX: fix Kafka Streams upgrade path from 3.4 to 3.5 (#14103)
  • PR-14237 - KAFKA-15374 Handle case of default broker in config migration (#14237)
  • PR-14082 - KAFKA-15102: Add replication.policy.internal.topic.separator.enabled property to MirrorMaker 2 (KIP-949) (#14082)
  • PR-14187 - KAFKA-13197: fix GlobalKTable join/left-join semantics documentation. (#14187)
  • PR-14156 - KAFKA-15202: Fix MM2 offset translation when syncs are variably spaced (#14156)
  • PR-14141 - KAFKA-15100; KRaft data race with the expiration service (#14141)
  • PR-14125 - KAFKA-15271: Historicalterator can exposes elements that are too new (#14125)
  • PR-14162 - KAFKA-15312; Force channel before atomic file move (#14162)
  • PR-14115 - KAFKA-15263 Check KRaftMigrationDriver state in each event (#14115)
  • PR-14094 - KAFKA-15243: Set decoded user names to DescribeUserScramCredentialsResponse (#14094)
  • PR-14075 - KAFKA-15235: Fix broken coverage reports since migration to Gradle 8.x (#14075)
  • PR-14079 - KAFKA-15238: Move DLQ reporter setup from the DistributedHerder’s tick thread to the sink task thread (#14079)
  • PR-14044 - KAFKA-15216: InternalSinkRecord::newRecord should not ignore new headers (#14044)
  • PR-13948 - KAFKA-15091: Fix misleading Javadoc for SourceTask::commit (#13948)
  • PR-13284 - KAFKA-14718: Wait for MirrorMaker to start before executing test (#13284)
  • PR-13982 - KAFKA-15159: upgrade minor dependencies (#13982)
  • PR-13988 - [KAFKA-15137] Do not log entire request payload in KRaftControllerChannelManager (#13988)
  • PR-13955 - KAFKA-15145: Don’t re-process records filtered out by SMTs on Kafka client retriable exceptions in AbstractWorkerSourceTask (#13955)
  • PR-13950 - KAFKA-15140: Use TestUtils methods and add logs for assertion failure at TopicCommandIntegrationTest (#13950)
  • PR-13968 - KAFKA-15149: Fix handling of new partitions in dual-write mode (#13968)
  • PR-13904 - KAFKA-15114: Update StorageTool help for creating SCRAM credentials to specify name instead of user. (#13904)
  • PR-13831 - KAFKA-15053: Use case insensitive validator for security.protocol config (#13831)
  • PR-13895 - KAFKA-15098 Allow authorizers to be configured in ZK migration (#13895)
  • PR-13865 - KAFKA-15096: Update snappy-java to 1.1.10.1 (#13865)
  • PR-13843 - KAFKA-15080; Fetcher’s lag never set when partition is idle (#13843)
  • c97b88d5 - Bump version to 3.5.0

REST Proxy

  • PR-1230 - KREST-12372 Upgrade dependency to JDK 1.8 with version 1.77
  • PR-1221 - KREST-12630 Exclude logback from zookeeper dependency in tests
  • PR-1219 - KREST-12630 Add missing dependency due to zookeeper upgrade
  • PR-1212 - KREST-12277 semaphore migration to release branches
  • PR-440 - KREST-11812 upgrade jaxb-api dependency
  • ee8dd479 - KREST-12364: update bcpix
  • PR-427 - KRES-12288 migration semaphore release branches

Schema Registry

  • 01cc37a6 - Fix NPE for getAllVersionsById in MockSchemaRegistryClient
  • de9de139 - Handle all exceptions when rule action cannot be performed
  • 30fbe76c - Clean up test
  • e66c5c51 - Fix checkstyle
  • d0a9c3f9 - Fix copyright date
  • d6d92d65 - Add unit tests
  • 78b1947d - DGS-9450 Strip rule param prefix from configs
  • bfda9dd4 - Improve logging
  • 806989d7 - DGS-9450 More minor cleanup
  • ef077a85 - DGS-9450 Minor cleanup
  • 23b859ff - DGS-9451: Fix validateFields value in error message
  • 0b445986 - DGS-9450 Add command line tool to register/auto-rotate DEKs
  • 14936914 - Refactor getAead method so it can be overridden
  • 98a1a4de - update swagger core
  • 12166e07 - DGS-9402 In CEL, treat exception from guard as false
  • 3bc36b7a - DGS-9162: Address review feedback
  • PR-2888 - Apply service bot changes to version branches
  • PR-2887 - DGS-9059 Fix jmx prefix default
  • 1d415181 - DGS-9387 Ensure isKey flag is passed when reusing deserializers
  • ae313e51 - Add logging
  • 6683bd00 - Fix CSFLE dek rotation tests
  • c180f450 - Fix findbugs
  • 92a148cb - Temporarily disable DEK rotation tests
  • e3deb5dd - Fix CSFLE dek rotation test
  • PR-2879 - Update azure-identity and unpin azure-core
  • bafbad8c - DGS-9343 Allow removing enum in JSON Schema to be backward compatible
  • 897e6716 - further cleanup of method calls
  • f98d9a93 - change set.of to immutableset.of in AvroSchemaTest and ProtobufSchemaTest
  • 4d813665 - fix cannot find symbol error
  • eb68e9b2 - fix checkstyle
  • 0d57454c - Add unit tests and introduce validate fields config
  • PR-2874 - DGS-9048: Semaphore Migration of Version Branches
  • 089b1fb7 - Upgrade tink to 1.12.0
  • 899b38a2 - migrate to semaphore
  • 40c364a0 - address comments
  • 002f3b60 - address review feedback
  • 552ae00a - move reserved fields validation out of compatibility checks
  • 53982cac - DGS-9162: Metadata compatibility checks for forward and full
  • 7f7a7ab1 - add metrics-core to fix the build
  • 5aa50c15 - Fix test
  • 02a996b1 - Check multiple actions only valid for WRITEREAD and UPDOWN
  • 2f93432d - Add null check
  • 3f8d16f7 - Add initialized method to dek registry
  • cc24a287 - DGS-9106: Update log level for leader election
  • 5e7bf83d - DGS-9031 Add strings extension lib for CEL executor
  • b19aea83 - DGS-9067 Ensure keys for schema cache are not mutated
  • d3b1912d - upgrade com.squareup.okio:okio to 3.4.0
  • 3e5ecba2 - Add tests
  • a990ce0f - DGS-9031 Add builtin CEL validation functions
  • 828040f3 - DGS-7866: Set default for validateFields to false
  • 4aa97bb8 - DGS-7866: Use 35742 instead of $ as the prefix for reserved fields
  • c8ab3fd0 - Add log if encoding fails
  • 531cc692 - Add test
  • PR-2822 - Add deleted flag to create kek/dek requests
  • d81d5a53 - Encode subject names for Maven download plugin
  • PR-2820 - Cache ProtobufSchema.toDynamicSchema calls (#2818)
  • PR-2817 - Sort list of dek subjects before returning to client
  • PR-2816 - DGS-8960 Fix handling of diamond structure in Protobuf converter
  • PR-2815 - Update DEK Registry spec
  • 55c43766 - cherry-pick: DGS-7865 and DGS-7866

Version 7.5.2

Released October 2023

Community Features

Common

  • 35a1415d - APPSEC-3039: Update jetty and netty
  • 81295738 - update snappy to 1.10.5
  • aea31af8 - APPSEC-2796: add guava to dependencyManagement

Kafka

  • PR-968 - KSECURITY-2013: Upgraded Jetty to 9.4.53.v20231009 and Netty to 4.1.1
  • PR-955 - KAFKA-15498: bump snappy-java version to 1.1.10.5 (#14434)

REST Proxy

  • PR-408 - KREST-11276 - Tighten SSL auto cert reload
  • PR-409 - KREST-11276 - Fixing cert reload with multiple registered listeners

Schema Registry

  • PR-2806 - DGS-8908 Ensure tenant prefix is used for aliases
  • PR-2805 - DGS-8901 Ensure logical type config is applied to Reflect/Specific Avro data types
  • 61f94429 - DGS-5796: Optimize leader election
  • PR-2784 - DGS-8165 Add support for automatic DEK Rotation
  • PR-2790 - DGS-8088 Get the mode in scope rather that just for the subject
  • PR-2789 - DGS-8783 Add rulesToMerge/rulesToRemove to tags API
  • PR-2786 - DGS-8769 Upgrade vault lib; add namespace support
  • PR-2783 - DGS-8708 Add rule config to preserve source fields
  • PR-2773 - DGS-8615 Minor change to DlqAction
  • PR-2772 - DGS-8553: Updated create and delete DEK Registry API documented names
  • PR-2769 - DGS-8522 Support required fields in proto2 in CEL executor

Version 7.5.1

Released September 2023

Community Features

Common

  • 59440c88 - APPSEC-2855: add generation of SBOMs to maven based Java projects
  • PR-542 - update easymock support for java 17 support

Kafka

  • PR-939 - KSECURITY-1789: upgrading requests to v2.31.0 (3.5)

ksqlDB

  • PR-10065 - fix: import not picked back in fix

Schema Registry

  • PR-2748 - Ensure all SR client props are passed to FLE
  • PR-2746 - Create default KMS params in rule based on KMS key id
  • PR-2745 - Log DEK errors
  • PR-2744 - MINOR Added another constructor to DekRegistryConfig
  • PR-2742 - DGS-8169 Handle null compat groups for schemas
  • PR-2741 - Improve error handling during DEK creation
  • PR-2738 - Ensure kek name is prefixed with context
  • PR-2734 - DGS-8112 Allow properties to be omitted during serialization
  • PR-2730 - DGS-7826 DGS-7828 DGS-7830 Add kek/dek timestamp, dek version
  • PR-2764 - DGS-8336 Add ruleType filter to schemas endpoint
  • PR-2758 - DGS-8323 Always populate version metadata prop for tags API

Version 7.5.0

Released August 2023

Community Features

Common

  • b4334b94 - Pin jose4j version
  • 95ed5124 - Include snappy and jetty in the dependency management, cleanup jackson imports
  • 27a3c1ca - APPSEC-2796: update guava
  • PR-530 - Backport log redactor to CP patches.
  • 9cce6f1e - Add log redactor dependency
  • bd393b16 - AUDIT-1600: Updating logredactor version to 1.0.12

Kafka

  • PR-930 - KSECURIYT-1859: upgrading netty to 4.1.96.Final (3.5)
  • PR-13759 - KAFKA-15019: Improve handling of broker heartbeat timeouts (#13759)
  • PR-13735 - KAFKA-15003: Fix ZK sync logic for partition assignments (#13735)
  • PR-13758 - KAFKA-15010: ZK migration failover support (#13758)
  • PR-13757 - KAFKA-15017: Fix snapshot load in dual write mode for ClientQuotas and SCRAM (#13757)
  • PR-13786 - Upgrade snappy to v1.1.10.0 (#13786)
  • PR-13767 - KAFKA-15004: Fix configuration dual-write during migration (#13767)
  • PR-13781 - KAFKA-8713: JsonConverter replace.null.with.default should prevent emitting default for Struct fields (#13781)
  • PR-13742 - KAFKA-14996: Handle overly large user operations on the kcontroller (#13742)
  • PR-13741 - KAFKA-15009: Handle new ACLs in KRaft snapshot during migration (#13741)
  • PR-13732 - KAFKA-15007: Use the correct MetadataVersion in MetadataPropagator (#13732)
  • PR-13729 - KAFKA-14970: Fix SCRAM during migration dual-write (#13729)
  • PR-13745 - KAFKA-15015: Explicit load of reload4j (#13745)
  • PR-13723 - KAFKA-14980: Fix MirrorSourceConnector source consumer configuration (#13723)
  • PR-13717 - KAFKA-14994: Update jose4j (#13717)
  • PR-13690 - KAFKA-14978: ExactlyOnceWorkerSourceTask should remove parent metrics (#13690)
  • PR-13660 - KAFKA-14662: Update the ACL list in the doc (#13660)
  • PR-13688 - KAFKA-14974: Restore backward compatibility in KafkaBasedLog (#13688)
  • PR-13461 - KAFKA-14840: Support for snapshots during ZK migration (#13461)
  • PR-13628 - KAFKA-14859: SCRAM ZK to KRaft migration with dual write (#13628)
  • PR-13653 - KAFKA-14946: Fix NPE when merging the deltatable (#13653)
  • PR-13657 - KAFKA-14876: Document the new ‘PUT /connectors/{name}/stop’ REST API for Connect (#13657)
  • PR-13631 - KAFKA-14909: Check zkMigrationReady tag before migration (#13631)
  • PR-13407 - KAFKA-14805: KRaft controller supports pre-migration mode (#13407)
  • PR-13550 - KAFKA-14639: A single partition may be revoked and assign during a single round of rebalance (#13550)
  • PR-13606 - KAFKA-14918: Only send controller RPCs to migrating ZK brokers (#13606)
  • 33962e8b - KAFKA-14943: Fix ClientQuotaControlManager validation
  • PR-13429 - KAFKA-14666: Add MM2 in-memory offset translation index for offsets behind replication (#13429)
  • PR-13533 - KAFKA-12446: Update change encoding to use varint (#13533)
  • PR-13615 - KAFKA-14834: [12/N] Minor code cleanups relating to versioned stores (#13615)
  • PR-13592 - KAFKA-14862: Outer stream-stream join does not output all results with multiple input partitions (#13592)
  • PR-13587 - KAFKA-14876: Document the new ‘GET /connectors/{name}/offsets’ REST API for Connect (#13587)
  • PR-13575 - KAFKA-14905: Reduce flakiness in MM2 ForwardingAdmin test due to admin timeouts (#13575)
  • PR-13604 - KAFKA-14869: Bump coordinator value records to flexible versions (KIP-915, Part-2) (#13604)
  • 03b41b54 - KAFKA-14887: FinalizedFeatureChangeListener should not shut down when ZK session expires
  • 3f1e78ee - KAFKA-14887: FinalizedFeatureChangeListener should not shut down when ZK session expires
  • PR-13579 - KAFKA-14904: Pending state blocked verification of transactions (#13579)
  • PR-13614 - KAFKA-14586: Adding redirection for StreamsResetter (#13614)
  • PR-13609 - KAFKA-14834: [11/N] Update table joins to identify out-of-order records with isLatest (#13609)
  • PR-13513 - KAFKA-14881: Rework UserScramCredentialRecord (#13513)
  • PR-13526 - KAFKA-14869: Bump coordinator value records to flexible versions (KIP-915, Part-2) (#13526)
  • PR-13511 - KAFKA-14869: Ignore unknown record types for coordinators (KIP-915, Part-1) (#13511)
  • PR-13567 - Update zstd to 1.5.5 (#13567)
  • PR-12830 - KAFKA-8115: Reduce flakiness in Trogdor JsonRestServer shutdown (#12830)
  • PR-13534 - KAFKA-14054: Handle TimeoutException gracefully (#13534)
  • PR-13565 - KAFKA-14834: [9/N] Disable versioned-stores for unsupported operations (#13565)
  • PR-13477 - KAFKA-7499: Handle serialization error in ProductionExceptionHandler (#13477)
  • PR-13566 - KAFKA-14834: [10/N] Reserve repartition topic formats to include isLatest (#13566)
  • PR-13564 - KAFKA-14834: [8/N] Propagate isLatest as part of Change (#13564)
  • PR-13554 - KAFKA-14834: [7/N] Update VersionedKeyValueStore#put() to return validTo (#13554)
  • PR-13552 - KAFKA-14834: [6/N] Add tracking of versioned tables into graph nodes (#13552)
  • PR-13491 - KAFKA-14722: Make BooleanSerde public (an addition of upgrade.html changes) (#13491)
  • PR-13505 - KAFKA-14462: [5/N] Add EventAccumulator (#13505)
  • PR-13525 - KAFKA-14883: Expose observer state in KRaft metrics (#13525)
  • PR-13522 - KAFKA-14834: [5/N] Drop out-of-order records from FK join with versioned tables (#13522)
  • PR-13510 - KAFKA-14834: [4/N] Drop out-of-order records from table-table join with versioned tables (#13510)
  • PR-13391 - KAFKA-14561: Improve transactions experience for older clients by ensuring ongoing transaction (#13391)
  • PR-13509 - KAFKA-14834: [3/N] Timestamped lookups for stream-table joins (#13509)
  • PR-13541 - KAFKA-14894: MetadataLoader must call finishSnapshot after loading a snapshot (#13541)
  • PR-13462 - KAFKA-14857: Fix some MetadataLoader bugs (#13462)
  • PR-13520 - KAFKA-14462: [4/N] Add Group, Record and Result (#13520)
  • PR-13539 - KAFKA-14891: Fix rack-aware range assignor to assign co-partitioned subsets (#13539)
  • PR-13487 - KAFKA-9550: Copying log segments to tiered storage in RemoteLogManager (#13487)
  • PR-13497 - KAFKA-14834: [2/N] Test coverage for out-of-order data in joins (#13497)
  • PR-13496 - KAFKA-14834: [1/N] Add timestamped get to KTableValueGetter (#13496)
  • PR-13424 - KAFKA-14783: (KIP-875): New STOPPED state for connectors (#13424)
  • PR-10747 - KAFKA-12446: Call subtractor before adder if key is the same (#10747)
  • PR-13373 - KAFKA-14420: Use incrementalAlterConfigs API for syncing topic configurations in MirrorMaker 2 (KIP-894) (#13373)
  • PR-13449 - KAFKA-14491: [22/N] Add test for manual upgrade to versioned store (#13449)
  • PR-13345 - KAFKA-13020: Implement reading Snapshot log append timestamp (#13345)
  • PR-13489 - KAFKA-14617: Fill broker epochs to the AlterPartitionRequest (#13489)
  • PR-13269 - KAFKA-12634: enforce checkpoint after restoration (#13269)
  • PR-12992 - KAFKA-14376: Add ConfigProvider to make use of environment variables KIP-887 (#12992)
  • PR-13499 - KAFKA-14880: TransactionMetadata with producer epoch -1 should be expirable (#13499)
  • PR-13369 - KAFKA-14172: Should clear cache when active recycled from standby (#13369)
  • PR-13300 - KAFKA-10199: Add task updater metrics, part 2 (#13300)
  • PR-13442 - KAFKA-14491: [20/N] Add public-facing methods for versioned stores (#13442)
  • PR-13456 - KAFKA-14850: introduce InMemoryLeaderEpochCheckpoint (#13456)
  • PR-13318 - KAFKA-14533: Do not interrupt state-updater thread during shutdown (#13318)
  • PR-13374 - KAFKA-14765: and KAFKA-14776: Support for SCRAM at bootstrap with integration tests (#13374)
  • PR-13470 - KAFKA-14864: Close iterator in KStream windowed aggregation emit on window close (#13470)
  • PR-13431 - KAFKA-14491: [19/N] Combine versioned store RocksDB instances into one (#13431)
  • PR-13364 - KAFKA-14491: [16/N] Add recovery logic for store inconsistency due to failed write (#13364)
  • PR-13480 - Fix typos in security.html (#13480)
  • PR-13325 - KAFKA-14771: Include threads info in ConcurrentModificationException message (#13325)
  • PR-13350 - KAFKA-14452: Make sticky assignors rack-aware if client rack is configured (KIP-881) (#13350)
  • PR-13434 - KAFKA-14785: (KIP-875): Connect offset read REST API (#13434)
  • PR-13486 - Suppress exception in testExceptionInUpdateCoordinator (#13486)
  • PR-13458 - KAFKA-14838: Add flow/connector/task/role information to MM2 Kafka client.id configs (#13458)
  • PR-13474 - KAFKA-14867: Trigger rebalance when replica racks change if client.rack is configured (KIP-881) (#13474)
  • PR-13483 - Use readlock for reading epochs in LeaderEpochFIleCache (#13483)
  • PR-13408 - KAFKA-14617: Update AlterPartitionRequest and enable Kraft controller to reject stale request. (#13408)
  • PR-13482 - Switch to SplittableRandom in ProducerPerformance utility (#13482)
  • PR-13380 - KAFKA-14468: Committed API (#13380)
  • PR-13440 - KAFKA-14829: Consolidate reassignment logic into PartitionReassignmentReplicas (#13440)
  • PR-13472 - KAFKA-14774: the removed listeners should not be reconfigurable (#13472)
  • PR-13460 - KAFKA-14853: the serializer/deserialize which extends ClusterResourceListener is not added to Metadata (#13460)
  • PR-13445 - KAFKA-14843: Include Connect framework properties when retrieving connector config definitions (#13445)
  • PR-13148 - KAFKA-14645: Use plugin classloader when retrieving connector plugin config definitions (#13148)
  • PR-13446 - KAFKA-14837/14842: Avoid the rebalance caused by the addition and deletion of irrelevant groups for MirrorCheckPointConnector (#13446)
  • PR-13127 - KAFKA-14586: Moving StreamResetter to tools (#13127)
  • PR-13423 - KAFKA-14827: Support for StandardAuthorizer benchmark (#13423)
  • PR-13368 - KAFKA-14796: Migrate ACLs from AclAuthorizor to KRaft (#13368)
  • PR-13452 - KAFKA-14848: KafkaConsumer incorrectly passes locally-scoped serializers to FetchConfig (#13452)
  • PR-13326 - KAFKA-14774: the removed listeners should not be reconfigurable (#13326)
  • PR-13441 - Fix log DateTime format unit test (#13441)
  • PR-13393 - KAFKA-10244: An new java interface to replace ‘kafka.common.MessageReader’ (#13393)
  • PR-13425 - KAFKA-14365: Extract common logic from Fetcher (#13425)
  • PR-13438 - KAFKA-14835: Create ControllerMetadataMetricsPublisher (#13438)
  • PR-13382 - KAFKA-14722: Make BooleanSerde public (#13382)
  • PR-13385 - KAFKA-14800: Bump snappy-java version to 1.1.9.1 (#13385)
  • PR-13426 - KAFKA-14814: Skip Connect target state updates when the configs store has same state (#13426)
  • PR-13340 - KAFKA-14491: [15/N] Add integration tests for versioned stores (#13340)
  • PR-13409 - KAFKA-14491: [18/N] Update versioned store to check latest value on timestamped get (#13409)
  • PR-13292 - KAFKA-14491: [14/N] Set changelog topic configs for versioned stores (#13292)
  • PR-13420 - KAFKA-14740: Add source tag to MirrorSourceMetrics - KIP-911 (#13420)
  • PR-13419 - KAFKA-8713: Allow using null for field in JsonConverter (KIP-581) (#13419)
  • PR-13367 - KAFKA-14797: Emit offset sync when offset translation lag would exceed max.offset.lag (#13367)
  • PR-13404 - KAFKA-14812:ProducerPerformance still counting successful sending in console when sending failed (#13404)
  • PR-13398 - KAFKA-6891: send.buffer.bytes should be allowed to set -1 in KafkaConnect (#13398)
  • PR-13362 - KAFKA-14795: Provide message formatter for RemoteLogMetadata (#13362)
  • 361095a1 - KAFKA-14491: [17/N] Refactor segments cleanup logic
  • PR-13415 - KAFKA-14816: Only load SSL properties when issuing cross-worker requests to HTTPS URLs (#13415)
  • PR-13323 - KAFKA-14617: Add ReplicaState to FetchRequest (KIP-903) (#13323)
  • PR-13386 - KAFKA-14809: Fix logging conditional on WorkerSourceTask (#13386)
  • PR-13384 - KAFKA-14801: Encoded configs are not decoded before ZK migration (#13384)
  • PR-13396 - KAFKA-13884: Only voters flush on Fetch response (#13396)
  • PR-13378 - KAFKA-14793: Propagate Topic Ids to the Group Coordinator during Offsets Commit (#13378)
  • PR-13379 - KAFKA-14799: Ignore source task requests to abort empty transactions (#13379)
  • PR-13388 - KAFKA-14804: Update swagger plugin/dependencies to 2.2.8 (#13388)
  • PR-13349 - KAFKA-14452: Refactor AbstractStickyAssignor to prepare for rack-aware assignment (#13349)
  • PR-13258 - KAFKA-14447: remove stale TODO comment (#13258)
  • PR-13301 - KAFKA-14758: Extract inner classes from Fetcher for reuse in refactoring (#13301)
  • PR-13371 - Updating video links to ASF YouTube (#13371)
  • PR-12813 - KAFKA-14317: ProduceRequest timeouts are logged as network exceptions (#12813)
  • PR-13363 - KAFKA-14794: Decode base64 JSON string (#13363)
  • PR-13351 - KAFKA-14781: Downgrade MM2 log message severity when no ACL authorizer is configured on source broker (#13351)
  • PR-13067 - KAFKA-14524: Rewrite KafkaMetricsGroup in Java (#13067)
  • PR-13357 - KAFKA-14462: [3/N] Add onNewMetadataImage to GroupCoordinator interface (#13357)
  • PR-13354 - KAFKA-14753: Improve kafka producer example (#13354)
  • PR-13353 - KAFKA-14752: Improving the existing consumer examples (#13353)
  • PR-13303 - KAFKA-14761: Adding integration test for the prototype consumer (#13303)
  • PR-13359 - KAFKA-14792: Race condition in LazyIndex.get() (#13359)
  • PR-13116 - KAFKA-14351: Controller Mutation Quota for KRaft (#13116)
  • PR-13231 - KAFKA-14402: Update AddPartitionsToTxn protocol to batch and handle verifyOnly requests (#13231)
  • PR-13346 - KAFKA-14770: Allow dynamic keystore update for brokers if string representation of DN matches even if canonical DNs don’t match (#13346)
  • PR-13329 - KAFKA-14462: [2/N] Add ConsumerGroupHeartbeart to GroupCoordinator interface (#13329)
  • PR-13274 - KAFKA-14491: [13/N] Add versioned store builder and materializer (#13274)
  • PR-883 - Update tags to match standards
  • PR-13215 - KAFKA-14578: Move ConsumerPerformance to tools (#13215)
  • PR-13304 - KAFKA-14726: Move/rewrite of LogReadInfo, LogOffsetSnapshot, LogStartOffsetIncrementReason to storage module (#13304)
  • PR-13114 - KAFKA-14084: SCRAM support in KRaft. (#13114)
  • PR-13328 - KAFKA-14745: Cache the ReplicationPolicy instance in MirrorConnectorConfig (#13328)
  • PR-13264 - KAFKA-14491: [12/N] Relax requirement that KTable stores must be TimestampedKVStores (#13264)
  • PR-13182 - KAFKA-14649: Isolate failures during plugin path scanning to single plugin classes (#13182)
  • PR-13322 - KAFKA-14462: [1/N] Add new server configurations (KIP-848) (#13322)
  • PR-13095 - KAFKA-14580: Moving EndToEndLatency from core to tools module (#13095)
  • PR-13172 - KAFKA-14590: Move DelegationTokenCommand to tools (#13172)
  • PR-13270 - KAFKA-14729: The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread (#13270)
  • PR-13078 - KAFKA-13999: Add ProducerCount metrics (KIP-847) (#13078)
  • PR-12990 - KAFKA-14451: Rack-aware consumer partition assignment for RangeAssignor (KIP-881) (#12990)
  • PR-13102 - KAFKA-14371: Remove unused clusterId field from quorum-state file (#13102)
  • PR-13190 - KAFKA-12639: Exit upon expired timer to prevent tight looping (#13190)
  • PR-13184 - KAFKA-14671: Refactor PredicatedTransformation to not implement Transformation (#13184)
  • PR-13276 - KAFKA-14732: Use an exponential backoff retry mechanism while reconfiguring connector tasks (#13276)
  • PR-13193 - KAFKA-14659: source-record-write-[rate|total] metrics should exclude filtered records (#13193)
  • PR-13291 - KAFKA-14742: Throttle connectors in ExactlyOnceSourceIntegrationTest to fix flakey OOMEs (#13291)
  • PR-13191 - KAFKA-14060: Replace EasyMock and PowerMock with Mockito in AbstractWorkerSourceTaskTest (#13191)
  • PR-13279 - KAFKA-14295: FetchMessageConversionsPerSec meter not recorded (#13279)
  • PR-13297 - KAFKA-14743: update request metrics after callback (#13297)
  • PR-13021 - KAFKA-14468: Implement CommitRequestManager to manage the commit and autocommit requests (#13021)
  • PR-13206 - KAFKA-14685: Refactor logic to handle OFFSET_MOVED_TO_TIERED_STORAGE error (#13206)
  • PR-13252 - KAFKA-14491: [11/N] Add metered wrapper for versioned stores (#13252)
  • PR-13228 - KAFKA-10199: Add task updater metrics, part 1 (#13228)
  • PR-13205 - KAFKA-14680: Upgrade gradle version from 7.6 to 8.0.1 (#13205)
  • PR-13295 - KAFKA-14744: NPE while converting OffsetFetch from version < 8 to version >= 8 (#13295)
  • PR-13263 - KAFKA-14728: Don’t run ‘spotlessScalaCheck’ in CI (#13263)
  • PR-13052 - KAFKA-14545: Make MirrorCheckpointTask.checkpoint handle null OffsetAndMetadata gracefully (#13052)
  • PR-13181 - KAFKA-14610: Publish Mirror Maker 2 offset syncs in task commit() method (#13181)
  • PR-11818 - KAFKA-12558: Do not prematurely mutate internal partition state in Mirror Maker 2 (#11818)
  • PR-13161 - KAFKA-14128: Kafka Streams does not handle TimeoutException (#13161)
  • PR-13255 - KAFKA 14714: Move/Rewrite RollParams, LogAppendInfo, and LeaderHwChange to storage module. (#13255)
  • PR-13251 - KAFKA-14491: [10/N] Add changelogging wrapper for versioned stores (#13251)
  • PR-13025 - KAFKA-14299: Fix pause and resume with state updater (#13025)
  • PR-13192 - KAFKA-14675: Extract metadata-related tasks from Fetcher into MetadataFetcher 1/4 (#13192)
  • PR-13282 - KAKFA-14733: Added a few missing checks for Kraft Authorizer and updated AclAuthorizerTest to run tests for both zk and kraft (#13282)
  • PR-13273 - KAFKA-14731: Upgrade ZooKeeper to 3.6.4 (#13273)
  • PR-11976 - KAFKA-13771: Support to explicitly delete delegationTokens that have expired but have not been automatically cleaned up (#11976)
  • PR-13244 - [MINOR] assert the cache size for each operation in RemoteIndexCacheTest (#13244)
  • PR-13196 - KAFKA-14673: Add high watermark listener to Partition/Log layers (#13196)
  • PR-13250 - KAFKA-14491: [9/N] Add versioned bytes store and supplier (#13250)
  • PR-13248 - KAFKA-14717: KafkaStreams can’ get running if the rebalance happens be… (#13248)
  • PR-13234 - KAFKA-14706: Move/rewrite ShutdownableThread to server-common module. (#13234)
  • PR-13253 - KAFKA-14253: More informative logging (#13253)
  • PR-13262 - KAFKA-14727: Enable periodic offset commits for EOS source tasks (#13262)
  • PR-13168 - Kafka 14565: On failure, close AutoCloseable objects instantiated and configured by AbstractConfig (#13168)
  • PR-13238 - KAFKA-14708: Use Java thread instead of kafka library for example purpose (#13238)
  • PR-13208 - KAFKA-5756: Wait for concurrent source task offset flush to complete before starting next flush (#13208)
  • PR-13249 - KAFKA-14491: [8/N] Add serdes for ValueAndTimestamp with null value (#13249)
  • PR-13243 - KAFKA-14491: [7/N] Enforce strict grace period for versioned stores (#13243)
  • PR-13207 - KAFKA-14664: Fix inaccurate raft idle ratio metric (#13207)
  • b9754747 - KAFKA-14653: Use raw properties instead of post-resolution properties for MirrorMaker connectors(#13163)
  • PR-13227 - KAFKA-14693: Kafka node should halt instead of exit (#13227)
  • PR-13230 - KAFKA-14704: Follower should truncate before incrementing high watermark (#13230)
  • PR-13189 - KAFKA-14491: [6/N] Support restoring RocksDB versioned store from changelog (#13189)
  • PR-13241 - KAFKA-14711: kafaka-metadata-quorum.sh does not honor –command-confi… (#13241)
  • PR-13225 - KAFKA-6793: Unused configuration logging appears to be noisy and unnecessary (#13225)
  • PR-12366 - KAFKA-14021: Implement new KIP-618 APIs in MirrorSourceConnector (#12366)
  • PR-13211 - KAFKA-14676: Include all SASL configs in login cache key to ensure clients in a JVM can use different OAuth configs (#13211)
  • PR-13040 - KAFKA-14480: Move/Rewrite ProducerStateManager to storage module. (#13040)
  • PR-13188 - KAFKA-14491: [5/N] Basic operations for RocksDB versioned store (#13188)
  • PR-13202 - KAFKA-14513: Add broker side PartitionAssignor interface (#13202)
  • PR-13167 - KAFKA-14650: Synchronize access to tasks inside task manager (#13167)
  • PR-13183 - KAFKA-14668: Avoid unnecessary UMR during ZK migration (#13183)
  • PR-13137 - KAFKA-15086, KAFKA-9981: Intra-cluster communication for Mirror Maker 2 (#13137)
  • PR-12590 - KAFKA-7109: Close fetch sessions on close of consumer (#12590)
  • PR-12972 - KAFKA-14391: Add ConsumerGroupHeartbeat API (#12972)
  • PR-13203 - KAFKA-14048: Add new __consumer_offsets records from KIP-848 (#13203)
  • PR-12984 - KAFKA-14455: Kafka Connect create and update REST APIs should surface failures while writing to the config topic (#12984)
  • PR-13175 - KAFAK-14660: Fix divide-by-zero vulnerability (#13175)
  • PR-13213 - KAFKA-14688: Move package org.apache.kafka.server.log.internals to org.apache.kafka.storage.internals.log (#13213)
  • PR-13179 - KAFKA-10575: Add onRestoreSuspsnded to StateRestoreListener (#13179)
  • PR-13046 - KAFKA-14551: Move/Rewrite LeaderEpochFileCache and its dependencies to the storage module. (#13046)
  • PR-13200 - KAFKA-14678: Move __consumer_offsets records from core to group-coordinator (#13200)
  • PR-13107 - KAFKA-13972: Ensure replica state deleted after reassignment cancellation (#13107)
  • PR-13143 - KAFKA-14491: [3/N] Add logical key value segments (#13143)
  • PR-13186 - KAFKA-14491: [4/N] Improvements to segment value format for RocksDB versioned store (#13186)
  • PR-879 - Set Owner and role tags for Vagrant EC2 instances
  • PR-12777 - Replace EasyMock and PowerMock with Mockito - TimeOrderedWindowStoreTest (#12777)
  • PR-880 - KC-2332: Upgrade netty to 4.1.86
  • PR-13136 - KAFKA-14582: Move JmxTool to tools (#13136)
  • PR-13126 - KAFKA-14491: [1/N] Add segment value format for RocksDB versioned store (#13126)
  • PR-13169 - KAFKA-14658: Do not open broker ports until we are ready to accept traffic (#13169)
  • PR-12879 - KAFKA-14409: Clean ProcessorParameters from casting (#12879)
  • 2e1947d2 - Bump version to 3.4.0
  • PR-13142 - KAFKA-14491: [2/N] Refactor RocksDB store open iterator management (#13142)
  • PR-13159 - KAFKA-14656: Send UMR first during ZK migration (#13159)
  • PR-13131 - KAFKA-14628: Move CommandLineUtils and CommandDefaultOptions to tools (#13131)
  • PR-13166 - KAFKA-14623: OAuth’s HttpAccessTokenRetriever potentially leaks secrets in logging (#13119) (#13166)
  • PR-13140 - KAFKA-14644: Process should crash after failure in Raft IO thread (#13140)
  • PR-13151 - KRaft brokers and controllesr should fail on Authorizer failure (#13151)
  • 8c637b71 - Update muckrake version mapping
  • PR-13119 - KAFKA-14623: OAuth’s HttpAccessTokenRetriever potentially leaks secrets in logging (#13119)
  • PR-13156 - KAFKA-14533: re-enable ‘false’ and disable the ‘true’ parameter of SmokeTestDriverIntegrationTest (#13156)
  • PR-13144 - KAFKA-14463: Close ConnectorClientConfigOverridePolicy instances (#13144)
  • PR-13147 - KAFKA-14533: temporarily disable the ‘false’ parameter of SmokeTestDriverIntegrationTest (#13147)
  • PR-12802 - KAFKA-14311: Cleanly cleanly stop connectors/tasks on Connect worker shutdown (#12802)
  • PR-13080 - KAFKA-14575: Move ClusterTool to tools module (#13080)
  • PR-13139 - Update outdated documentation. (#13139)
  • PR-857 - CONFLUENT: Fix filter for not publishing streams upgrade test artifacts
  • PR-853 - CONFLUENT: Skip publishing for kafka-streams-upgrade-system-tests
  • PR-13112 - KAFKA-14367: Add internal APIs to the new GroupCoordinator interface (#13112)
  • PR-13129 - KAFKA-14638: Elaborate when transaction.timeout.ms resets (#13129)
  • PR-12821 - KAFKA-14132: Replace PowerMock and EasyMock with Mockito in streams tests (#12821)
  • PR-13130 - KAFKA-14637: Fix upgrade compatibility issue from older versions to 3.4 (#13130)
  • PR-12818 - Replace EasyMock with Mockito in streams tests (#12818)
  • PR-13117 - KAFKA-14621: Disallow authorizers during ZK migration (#13117)
  • PR-12902 - KAFKA-14367: Add OffsetDelete to the new GroupCoordinator interface (#12902)
  • PR-13115 - Update ProducerConfig.java (#13115)
  • PR-13108 - KAFKA-14618: Fix off by one error in snapshot id (#13108)
  • PR-13106 - KAFKA-13709: (follow-up): Avoid mention of ‘exactly-once delivery’ or ‘delivery guarantees’ in Connect (#13106)
  • PR-12901 - KAFKA-14367: Add TxnOffsetCommit to the new GroupCoordinator interface (#12901)
  • PR-13085 - KAFKA-14568: Move FetchDataInfo and related to storage module (#13085)
  • PR-13104 - KAFKA-14612: Make sure to write a new topics ConfigRecords to metadata log iff the topic is created (#13104)
  • 8478bbb5 - KAFKA-14601: Improve exception handling in KafkaEventQueue #13089
  • PR-12886 - KAFKA-14367: Add OffsetCommit to the new GroupCoordinator interface (#12886)
  • PR-13017 - KAFKA-14530: Check state updater more often (#13017)
  • PR-13103 - KAFKA-14304: Use boolean for ZK migrating brokers in RPC/record (#13103)
  • PR-12301 - KAFKA-14003: Kafka Streams JUnit4 to JUnit5 migration part 2 (#12301)
  • PR-13092 - KAFKA-14607: Move Scheduler/KafkaScheduler to server-common (#13092)
  • PR-857 - CONFLUENT: Fix filter for not publishing streams upgrade test artifacts
  • PR-13058 - KAFKA-14557: Lock metadata log dir (#13058)
  • PR-12870 - KAFKA-14367: Add OffsetFetch to the new GroupCoordinator interface (#12870)
  • PR-13032 - KAFKA-14540: Fix DataOutputStreamWritable#writeByteBuffer (#13032)
  • PR-13087 - KAFKA-14600: Reduce flakiness in ProducerIdExpirationTest (#13087)
  • PR-13077 - KAFKA-14279: Add 3.3.x streams system tests (#13077)
  • PR-12998 - KAFKA-14493: Introduce Zk to KRaft migration state machine STUBs in KRaft controller. (#12998)
  • PR-13072 - KAFKA-14570: Fix parenthesis in verifyFullFetchResponsePartitions output (#13072)
  • PR-13043 - KAFKA-14558: Move/Rewrite LastRecord, TxnMetadata, BatchMetadata, ProducerStateEntry, and ProducerAppendInfo to the storage module (#13043)
  • PR-13075 - KAFKA-9087: Replace log high watermark by future log high watermark wh… (#13075)
  • 347042cc - KAFKA-14458: Introduce RPC support during ZK migration #13028
  • PR-13001 - KAFKA-14446: Code style improvements for broker-to-controller forwarding (#13001)
  • PR-13020 - KAFKA-14529: Use the MetadataVersion from ClusterConfig in ZK tests (#13020)
  • PR-13076 - KAFKA-14279: Add 3.3.x to core compatibility tests (#13076)
  • PR-13065 - KAFKA-14482: Move LoadedLogOffsets to storage module (#13065)
  • 0e51a202 - KAFKA-14458: Introduce RPC support during ZK migration #13028
  • PR-13073 - KAFKA-14571: Include rack info in ZkMetadataCache.getClusterMetadata (#13073)
  • PR-13049 - KAFKA-14478: Move LogConfig/CleanerConfig and related to storage module (#13049)
  • PR-13070 - KAFKA-14564: Upgrade netty to 4.1.86
  • PR-13053 - KAFKA-13881: Add Storage package info (#13053)
  • PR-13039 - KAFKA-14550: Move SnapshotFile and CorruptSnapshotException to storage module (#13039)
  • PR-13061 - [MINOR] Update upgrade documentation for 3.4 (#13061)
  • PR-13016 - KAFKA-14498: reduce the startup nodes to avoid timeout error (#13016)
  • PR-12008 - KAFKA-13439: move upgrade note to stream upgrade doc (#12008)
  • PR-12937 - KAFKA-13881: Add Connect package infos (#12937)
  • PR-12613 - MINOT: Fix punctuation marks (#12613)
  • PR-12166 - KAFKA-13817: Always sync nextTimeToEmit with wall clock (#12166)
  • PR-853 - CONFLUENT: Skip publishing for kafka-streams-upgrade-system-tests
  • PR-13048 - KAFKA-14554: Move ClassLoaderAwareRemoteStorageManagerTest to storage module (#13048)
  • PR-13038 - KAFKA-14543: Move LogOffsetMetadata to storage module (#13038)
  • PR-12936 - KAFKA-13881: Add Streams package infos (#12936)
  • PR-12979 - KAFKA-14544: The “is-future” should be removed from metrics tags after future log becomes current log (#12979)
  • PR-13042 - KAFKA-14476: Move OffsetMap and related to storage module (#13042)
  • PR-13041 - KAFKA-14549: Move LogDirFailureChannel to storage module (#13041)
  • PR-13036 - KAFKA-14534: Reduce flakiness in TransactionsExpirationTest (#13036)
  • PR-13012 - KAFKA-14477: Move LogValidator and related to storage module (#13012)
  • PR-12947 - KAFKA-6586: Refactor ConnectDistributed and ConnectStandalone to re-use shared logic (#12947)
  • PR-12735 - KAFKA-14132: Replace EasyMock and PowerMock with Mockito in connect/runtime/ErrorHandlingTaskTest (#12735)
  • PR-13014 - KAFKA-14461: Move StoreQueryIntegrationTest to junit5 and fixing logic in a couple of tests for finding active streams (#13014)
  • PR-13023 - KAFKA-14532: Correctly handle failed fetch when partitions unassigned (#13023)
  • PR-13026 - KAFKA-14299: Avoid interrupted exceptions during clean shutdown (#13026)
  • PR-13010 - KAFKA-14475: Move TimeIndex/LazyIndex to storage module (#13010)
  • PR-13019 - KAFKA-14531: Fix controller snapshot interval (#13019)
  • PR-13011 - KAFKA-14521: Replace BrokerCompressionCodec with BrokerCompressionType (#13011)
  • PR-13009 - KAFKA-14474: Move OffsetIndex to storage module (#13009)
  • PR-12994 - KAFKA-14457: Controller metrics should only expose committed data (#12994)
  • PR-12801 - KAFKA-14343: Upgrade tests for state updater (#12801)
  • PR-13007 - KAFKA-14473: Move AbstractIndex to storage module (#13007)
  • PR-12996 - KAFKA-14472: Move TransactionIndex and related to storage module (#12996)
  • PR-12862 - KAFKA-14264: New logic to discover group coordinator (#12862)
  • PR-12968 - KAFKA-14417: Address incompatible error code returned by broker from InitProducerId (#12968)
  • PR-13013 - KAFKA-14466: Move ClassloaderAwareRemoteStorageManager to storage module (#13013)
  • PR-12993 - Move IndexEntry and related to storage module (#12993)
  • PR-11390 - KAFKA-13369: Follower fetch protocol changes for tiered storage. (#11390)
  • PR-12961 - KAFKA-14446: API forwarding support from zkBrokers to the Controller (#12961)
  • PR-12965 - KAFKA-14448: Let ZK brokers register with KRaft controller (#12965)
  • PR-12856 - KAFKA-14392: Fix overly long request timeouts in BrokerToControllerChannelManager (#12856)
  • PR-12946 - KAFKA-14427: ZK client support for migrations (#12946)
  • PR-13000 - KAFKA-14496: Wrong Base64 encoder used by OIDC OAuthBearerLoginCallbackHandler (#13000)
  • PR-12977 - Removing Multicasting partitioner for IQ (#12977)
  • PR-12985 - KAFKA-13602: Remove unwanted logging in RecordCollectorImpl.java (#12985)
  • PR-12858 - KAFKA-14367: Add DeleteGroups to the new GroupCoordinator interface (#12858)
  • PR-12944 - KAFKA-14395: Add config to configure client supplier (#12944)
  • PR-12729 - KAFKA-14285: Delete quota node in zookeeper when configs are empty (#12729)
  • PR-12855 - KAFKA-14367: Add DescribeGroups to the new GroupCoordinator interface (#12855)
  • PR-12956 - KAFKA-14379: Consumer should refresh preferred read replica on update metadata (#12956)
  • PR-12971 - KAFKA-14454: Making unique StreamsConfig for tests (#12971)
  • PR-12962 - KAFKA-14318: KIP-878, Introduce partition autoscaling configs (#12962)
  • PR-12932 - KAFKA-14425: The Kafka protocol should support nullable structs (#12932)
  • c6590ee2 - KAFKA-14435: Fix allow.everyone.if.no.acl.found config behavior for StandardAuthorizer
  • PR-12935 - KAFKA-14432: RocksDBStore relies on finalizers to not leak memory (#12935)
  • PR-12955 - KAFKA-14443: Close topic creation Admin clients in MM2 connectors (#12955)
  • PR-12954 - KAFKA-14352: Rack-aware consumer partition assignment protocol changes (KIP-881) (#12954)
  • PR-12893 - KAFKA-14260: Add synchronized to prefixScan method (#12893)

ksqlDB

  • d3f0e149 - fix: fix compile error introduced by merge conflict resolution
  • PR-10000 - fix: implement default method for schema registry client
  • PR-9853 - feat: expose compaction and compression configs for RocksDB
  • PR-9916 - docs: use https for repository
  • PR-9911 - docs: upgrade pymdown-extensions and Pygments version
  • PR-9880 - feat: add MD5 hash UDF
  • e4d0bd7e - Upgrade netty to 4.1.87.Final
  • PR-9810 - Bump minimist and mkdirp
  • 4ce2d5f3 - fix: Replace regex in CommandParser with a split by space
  • da83d1c6 - fix: Replace regex in CommandParser with a split by space
  • PR-9876 - fix: check for tombstone before forwarding to sink
  • PR-9868 - KSE-911: allow proxy protocol listeners in KSQL
  • PR-9865 - bugfix: NPE for BigDecimal in CSV serializer
  • PR-9856 - feat: Add metrics for pull query thread pools
  • a5e1c5b5 - fix: Simplify regex in DdlDmlRequestValidators to avoid catastrophic backtracking
  • PR-9851 - fix: Avoid calling context.fail() twice
  • PR-9823 - fix: Set timeout for pull query forwarded requsts to 20s
  • PR-9818 - fix: default to get authHeader if using basic
  • PR-9812 - fix: catch TopicAuthorizationExceptions when getting topic config
  • PR-9770 - Upgrade netty to 4.1.86 #2
  • PR-9711 - fix: use args map instead of method args in generated java code
  • f1feb1ab - SSEO-3393 - Add metatag for Zendesk search crawler
  • PR-9772 - fix: complete transition to 7.5.x series

REST Proxy

  • 3274c17d - KREST-11122: - Add note about empty response from endpoint
  • a18ee85d - KREST-11122: - Add note about empty response from endpoint
  • PR-1171 - Remove the use of non-public API MockTime
  • PR-1170 - KREST-10646: Build break as a result of MockTime moving in Apache Kafka
  • PR-1169 - KREST-10639: Tidy up batch produce
  • PR-1166 - KREST-10244: Fix produce-request-rate metric
  • PR-1165 - Disable integration test temporarily
  • PR-1162 - KREST-10313: Prototype of batch REST Produce
  • PR-1163 - KREST-10286: Example python code for produce streaming V3 API
  • PR-1161 - Remove verbose log line
  • PR-1158 - KREST-8294: Permit charset for v3 produce
  • PR-1157 - KREST-4467: First part of reworking produce tests
  • PR-1156 - KREST-10318: Topic create without DESCRIBE_CONFIGS
  • PR-1154 - KREST-9968: Aggregated OpenAPI improvements
  • PR-1142 - KREST-9691: Add integration tests for the produce rate-limits for a single tenant.
  • PR-1153 - KREST-9559: Update lifecycle for Produce v3
  • PR-1146 - KREST-5471: Tidy up descriptions of API operations
  • PR-1144 - KREST-8221: Dynamic broker config improvements
  • PR-1140 - KREST-2594: Fix principal format in OpenAPI spec
  • PR-1139 - KREST-9401: Support STRING type in v3 produce API
  • PR-1138 - KREST-6569: - Cope with partitions disappearing
  • PR-1137 - KREST-1701: - Blank message for missing topic
  • PR-1136 - KREST-5711: - Non-negative partition id for produce
  • PR-1134 - KREST-8332: - Better error messages for query parameters
  • PR-1135 - KREST-2863: - Validate topic name in createTopic
  • PR-1132 - OpenAPI specification validation fixes
  • PR-1131 - Error response improvements
  • PR-1130 - Tidy up multi-record produce examples
  • 24efcbe1 - Integration test to send larger message size data in produce
  • PR-1126 - Required query parms and errors for ACL operations
  • PR-1129 - Update readme for v3 API
  • PR-1125 - KREST-7599: - add authorized_operations
  • PR-1124 - KREST-4757: Fix example for replicas_assignments
  • PR-1052 - Update README.md
  • PR-1119 - KREST-1797: - CreateTopic returns partitions and repl factor
  • PR-1114 - KREST-8943: Add an integration test with multiple consumers in parallel.
  • a54dde7e - CNC-366: Update Jetty
  • PR-395 - Don’t use DosFilter.Listener.onRequestOverLimit default to avoid verbosity
  • PR-393 - KREST 8913 Jetty 429 metrics
  • PR-384 - AUTHN-1586 Add optional latency SLO/SLA metrics in annotation
  • PR-380 - Insert RequestLogHandler to the ServletContextHandler instead of putting in Handler collection
  • PR-379 - Remove stacktrace in response when server throws BadMessageException
  • 1ec7602c - KREST 9773 Handle InvalidTopicException correctly
  • 8b251aa1 - Defer loading Conscrypt library
  • PR-376 - KREST-8331: - Remove class names from exceptions
  • PR-374 - Make SNI host check explicit
  • 54cde302 - Add BoringSSL TLS provider with Conscrypt
  • 5ae7042a - Add max buffer header size configs

Schema Registry

  • ca7a941c - Fix merge issue
  • PR-2719 - DGS-7826 DGS-7828 DGS-7830: Add DEK registry for CSFLE
  • 3f0e1198 - DGS-7927: fix for io.grpc_grpc-protobuf
  • a2933052 - throw IOException in BearerAuthCredentialProvider
  • c67de210 - Fix exception handling
  • 8cf3c48f - Update client/src/main/java/io/confluent/kafka/schemaregistry/client/SchemaRegistryClient.java
  • 38bbe23f - Close SerDes
  • 843787b4 - DSG-7861: Make BearerAuthCredentialProvider Closeable
  • 9ef14fcd - Fix exception handling
  • 049ba7bc - Update schema-serializer/src/main/java/io/confluent/kafka/formatter/SchemaMessageSerializer.java
  • a6672805 - Update schema-serializer/src/main/java/io/confluent/kafka/formatter/SchemaMessageDeserializer.java
  • dc8e8914 - Update client/src/main/java/io/confluent/kafka/schemaregistry/client/security/bearerauth/BearerAuthCredentialProvider.java
  • 0388c541 - Update client/src/main/java/io/confluent/kafka/schemaregistry/client/SchemaRegistryClient.java
  • PR-2717 - DGS-7976: Add tagging support for composite json schema
  • PR-2716 - Upgrade wire to 4.8.0
  • 0cf27170 - DGS-7797: Fix checkstyle errors
  • 47296719 - DGS-7797: Introduce a new optional host.port config for inter instance communication
  • PR-2699 - Minor: Fix entity order after converting list to map
  • PR-2696 - DGS-7772: Impl POST /subjects/{subject}/versions/{version}/tags
  • PR-2695 - do not reinstantiate objectmapper as it’s expensive (#2686)
  • PR-2693 - DGS-7746: Fix perf regression due to DGS-6331
  • 48101a91 - Fix merge issue
  • PR-2692 - DGS-7723: Fix for qualifySubjectWithParent method
  • PR-2690 - DGS-7697: Ensure version 0 is not returned in register response
  • PR-2685 - DGS-7565: Add rule name validation
  • 1e57cba0 - Fix merge issue
  • PR-2684 - DGS-7675: Fix NPE when print.schema.ids=true
  • PR-2683 - DGS-7682: Ensure correct tenant is passed when resolving refs
  • PR-2679 - DGS-7668: DGS-7669: Ensure invalid defaults are dropped; also handle slash in aliases
  • PR-2674 - DGS-7564: When registering, return schema if changed on server
  • PR-2673 - Exclude metadata population during import mode
  • PR-2670 - DGS-7488: Add X-Forward=true if forwarding request to leader
  • 4a833e6e - reorder
  • 1bf961b7 - Update json-schema
  • PR-2665 - DGS-7208: DGS-7474: Fix some regressions
  • PR-2664 - DGS-7208: DGS-7474: Add alias/normalize configs
  • PR-2658 - DGS-7457: Cache schemas in client when getting by subject/version
  • PR-2663 - Ensure compat check returns mutable lists
  • 963677cd - Fix conflicts and delete duplicate methods
  • 0f13c16e - Fix checkstyle
  • 20526ee5 - Solve conflicts
  • 119fcae0 - Fix duplicate variable httpConnectTimeoutMs definition
  • e0626f64 - Update the test to make it clear to customer
  • dc6f2096 - Update the doc
  • 33659feb - Update schema-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaSchemaSerDeConfig.java
  • 3ffd8fc7 - Update schema-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaSchemaSerDeConfig.java
  • 1ca2a39d - Update the codes with checking string for http connect timeout
  • ffba37fe - Change the config names
  • PR-2635 - DGS-7289: Adding CustomBearerAuthCredentialProvider
  • 7155f0fb - * Fix checkstyle error
  • 7e2dec9c - * Remove unused import
  • 9ab1b0ec - * Add defaults
  • 89aa28be - * Made SR client http connect and read timeout configurable.
  • PR-2655 - Enable use of service loader for CSFLE
  • PR-2653 - Make DEK algorithm configurable for CSFLE
  • PR-2644 - Add JSONata integration test
  • PR-2654 - DGS-7432: Fix ClassCastException when getting params option
  • PR-2652 - DGS-7430: Add auto.flush config for DlqAction
  • PR-2647 - DGS-7422: Optimization: omit compat check during IMPORT
  • PR-2646 - DGS-7412: Fix for registering references in non-default context
  • PR-2645 - DGS-7407: Fix issues for numeric types in CEL_FIELD exprs
  • 6e014ed0 - Fix merge issue
  • PR-2643 - DGS-7375: DGS-7376: DlqAction enhancements, support ServiceLoader
  • PR-2642 - DGS-7367: Propagate error messages even if not JSON
  • PR-2640 - DGS-7363: Handle JsonNode objects in CEL executors
  • PR-2614 - DGS-7103: Optimize instantiation of lists of schemas
  • PR-2629 - RCCA-12410: Fix exception due to addition to immutable list
  • PR-2639 - DGS-7353: Allow message references in CEL_FIELD exprs
  • 7572f96c - Made classes public
  • PR-2632 - DGS-7243: Add initialized method to determine extension readiness
  • PR-2630 - Add a local SR client for internal use to SR
  • dec6d308 - Made MutableHttpServletRequest case-insensitive
  • 01b5d127 - Use a handler instead of filter for adding request ID
  • 3e4e14f3 - Updated unittest
  • 535615db - Added X-Request-ID header to all request and response headers
  • PR-2625 - Static token provider: adding optional lsrc-id and pool-id
  • PR-2617 - Update RestClientException.java
  • PR-2556 - DGS-6065: Use HOST_NAME config for host even if inter.instance.listener.name is set
  • PR-2554 - Remove kafka-server-common dependency
  • e4f254af - Update README.md
  • PR-2545 - Fix due to KAFKA-14706