Confluent Platform Component Changelogs¶
This topic provides changelogs for the individual Confluent Platform components.
Version 7.6.3¶
Released August 2024
Community Features¶
Common¶
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-10403 - Add a null check in the response object to avoid NPE while accessing the connection status.
- 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
- PR-10380 - Use range version instead of pinned nano-versions
- 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-25 - Issue 5
- PR-11 - Moves hard-coded configs
- 51f62d2f - Dedupe schemas during IMPORT mode
- 0f4860f3 - Revert “Upgrade JSONata dependency to 2.5.0”
- bd9d64f8 - Fix alias search when using context wildcard
- 64e420b4 - Clean up LocalKmsClient
- 2e6d4af6 - Upgrade json-skema dependency to 0.15.0
- 8c5aaa96 - Upgrade JSONata dependency
Version 7.6.2¶
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 to address CVEs
- 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-1317 - Update refs to confluent-packaging-tools 3.6
- PR-15971 - InvalidRequestException: ADD_PARTITIONS_TO_TXN with version 4 which is not enabled when upgrading from kafka (#15971)
- PR-1236 - Updated netty version to 4.1.108.Final
- PR-15748 - Increment the local-log-start-offset before deleting segments in memory table (#15748)
- PR-1171 - update tags and added seamphore tags as part of semaphore migration 3.6
- PR-14995 - Allow restricting File and Directory ConfigProviders to specific paths (#14995)
- c4deed51 - Bump version to 3.6.2
- PR-1366 - 3.6 removed mk-include and make init-ci from semaphore
ksqlDB¶
- 4781375c - Update ref to confluent-packaging-tools
- PR-10353 - Add support for AnyOf Json type while encoding Ksql schemas.
- 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-10348 - Merge Conflict Resolution (from 7.5.x to 7.6.x)
- PR-10346 - Merge Conflict Resolution (from 7.2.x to 7.3.x)
- f8184c49 - Disable ITs only for failing modules
- 7902e36e - Disable ITs only for single module
- aa0c5327 - Disable ITs only for single module
- PR-10340 - fix for vertx dependency.
- PR-10338 - fix for vertx dependency.
- f68591f6 - Remove disable ITs flag
- b0225629 - Update plugin version
- PR-10333 - Fix for janino 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-10325 - Merge Conflict Resolution (from 7.5.x to 7.6.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-10308 - Migrate to 7.6.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
- c36d53b4 - Fix 7.6.x build
- 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¶
- b1692037 - Revert recent change to in-memory cache
- ab26883a - Ensure aliases are properly qualified
- b862eb19 - fix merge issue
- 6a9d6e22 - Fix Protobuf custom option for single-entry map
- b7aea93c - Incorporate review feedback
- 2d3c4736 - Revert “do not reinstantiate objectmapper as it’s expensive (#2686) (#2695)”
- 99e176a0 - Enhance test
- b3570725 - Fix checkstyle
- 18865846 - Add aliases query param to /schemas endpoint
- PR-3147 - Added config for calling local store on health check
- cdf34e52 - Fix deserialization of Avro unions with logical types
- 9f34f1a4 - Add aliases query param to schemas endpoint
- PR-3142 - Call kafkaStore on healthy checks
- 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
- 026c2b1f - Add API to return KEK names for a subject
- 2c980a77 - More robust usage of ServiceLoader
- 79d50b79 - Add comment
- c9956f29 - ensure KafkaStoreMessageHandler take checkpoints
- 2c6c783c - Enhance Avro error with type name
- f98a7075 - Fix checkstyle
- d81d0f49 - Unwrap IllegalStateException if possible
- ca36c3e3 - Add testSharing query param during kek create and update
- fdc39bff - Fix handleDeleteSubject to pass right oldSchemaValue
- 8052b8a5 - expose sslfactory
- 811adc50 - fix compile error
- a3e3f2f8 - allow exception to be thrown
- 5848374c - fix checkstyle
- 01dbcbb9 - add headerProperties
- de17bc6e - Support passing keystore/truststore to Vault KMS client
- PR-3110 - Revert jackson to 2.14.2
- PR-3109 - Produce register schema message after tombstones
- 33dd09be - add JettyEofExceptionWriterInterceptor to catch and swallow JettyEofException
- cf034df4 - add JettyEofExceptionMapper to catch and convert JettyEofException to 400 error
- 40f80bde - Enhance register API to allow tags to be added/removed
- 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
- a128fcf5 - Add comment
- 8e9c12cb - Fix NPE
- dbd05f8c - Ensure subject is hard deleted before clearing
- fa9545cc - Ensure consistent lookup of rule params
- b36c62ae - Support const in JSONSchemaConverter
- 2c32a50d - Refactor storage value to entity conversions
- c04c8fbd - Revert “Minor renaming”
- 8eeaf335 - Add disabled override
- 93d8d2f8 - Allow rule onFailure/onSuccess to be overriden by rule type
- 439119b5 - Add KEK test endpoint for testing shared KEKs
- 4d377d80 - Allow rule onFailure/onSuccess to be overriden via props
- PR-3072 - Don’t allow subjects named __EMPTY
- 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
- e5f0e83f - enable topic deletion in tests
- 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.6.1¶
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¶
- 64f7a0a3 - fix getOffsetByMaxTimestamp for compressed records (#15542)”
- da1ee97f - fix the LogValidator for non-compressed type (#15570)”
- PR-15608 - Fix bug where config change notification znode may not get created during migration (#15608)
- PR-15584 - Correctly migrate default client quota entities (#15584)
- PR-1128 - Update jose4j to 0.9.4 (#15284)
- PR-15562 - Stop emitting warning log message when parsing source connector offsets with null partitions (#15562)
- PR-15570 - fix the LogValidator for non-compressed type (#15570)
- PR-15481 - desanitize entity name when migrate client quotas (#15481)
- PR-15530 - Broker may not shut down when SocketServer fails to bind as Address already in use (#15530)
- PR-15284 - Update jose4j to 0.9.4 (#15284)
- PR-15464 - upgrade jline from 3.22.0 to 3.25.1 (#15464)
- PR-15542 - fix getOffsetByMaxTimestamp for compressed records (#15542)
- PR-15490 - Fix the dir path to be considered offline (#15490)
- PR-15498 - Reduce synchronization between producer threads (#15323) (#15498)
- PR-1072 - Update jetty to 9.4.54.v20240208
- PR-15293 - Fix UMR and LAIR handling during ZK migration (#15293)
- 5d3e691e - Fix ZK migration controller race #15238
- f734f32b - Reduce batch size for initial metadata load during ZK migration
- PR-15479 - Divide DeleteTopics requests by leader node (#15479)
- PR-15480 - Upgrade zookeeper 3.8.3 -> 3.8.4 (#15480)
- PR-15398 - Missing license for scala related dependencies (#15398)
- PR-1014 - update bcprov-jdk15on
ksqlDB¶
- 173a4f8e - Address review comments.
- 85b238bf - Add a no-arg constructor for ProtobufNoSRConverter.
- PR-10243 - Update Commons-Compress and commons-io
- PR-10238 - Update apache.io.version
- PR-10237 - Update commons-compress
- PR-10234 - MINOR: Pinned the common nanoversion to 7.6.1-3
- 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.
- 30544a65 - Cherry pick the replacement of easymock to mockito from newer branches.
- 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.
- 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.
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
- PR-3038 - feat: Added ReferenceSchema support to allOf
- ae0e3140 - fix: invalid behaviour for stringSchema in allOfToConnectSchema
- ff5b2158 - Add support for CONDITION with CEL_FIELD
- a349821f - add OffsetCheckpointReadOnly
- 22f36f3f - Optimization: cache Tink primitives
- 6df56c8f - Optimization: remove known deps from ProtobufSchema
- 07c9975e - Fix handling of multitype JSON schemas for 2020-12
- e5bfd011 - Add JSON Schema converter config to ignore modern dialects
- 306dd5c5 - Add error message for PACKAGE_CHANGED
- abbab267 - Ensure package change for Protobuf is incompatible
- aed3b7d5 - Ensure correct GenericData is used
- 26569386 - Optimization: remove extraneous KekInfo/DekInfo classes
- be5c571b - Improve parameter handling in FieldEncryptionExecutor
- 5d5fda18 - Fix use of non-absolute refs for JSON Schema
- 3bd1cdd5 - update common-compress
- 77f4ed97 - Ensure Vault namespace is being passed
- 98ffc914 - update azure-identity
- 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
Version 7.6.0¶
Released February 2024
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
- 8e71caf2 - Update bouncycastle
- 9862a1ce - Disable retirejs
- 91d80f1d - Update pom.xml
- 970d8055 - Upgrade Avro
- 35a1415d - Update Jetty and Netty
- 81295738 - Update snappy to 1.10.5
- 90952027 - Update reload4j, fix typo
- aea31af8 - Add guava to dependencyManagement
Kafka¶
- PR-15291 - Update jetty to 9.4.53.v20231009
- PR-15199 - KAFKA-16139: Fix StreamsUpgradeTest (#15199)
- b743f6fd - KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup
- 7486223d - KAFKA-16120: Fix partition reassignment during ZK migration
- PR-15177 - KAFKA-16017: Checkpoint restored offsets instead of written offsets (#15177)
- PR-15149 - KAFKA-16093: Fix spurious REST-related warnings on Connect startup (#15149)
- PR-14980 - KAFKA-15817: Avoid reconnecting to the same IP address (#14813) (#14980)
- PR-15090 - KAFKA-16065: close DelayedFuturePurgatory in DelayedOperationTest (#15090)
- PR-15079 - KAFKA-16053: Fix memory leaks due to KDC server in tests (#15079)
- PR-15007 - KAFKA-16007: Merge batch records during ZK migration (#15007)
- PR-14293 - KAFKA-15372: Reconfigure dedicated MM2 connectors after leadership change (#14293)
- PR-14567 - KAFKA-13988: Enable replicating from latest offset with MirrorMaker 2 (#14567)
- PR-14646 - KAFKA-15689: Logging skipped event when expected migration state is wrong (#14646)
- PR-14651 - Using INFO level for migration transition state logging (#14651)
- PR-987 - KSECURITY-2090: Updated bcpkix version to 1.77
- PR-14719 - KAFKA-15799 Handle full metadata updates on ZK brokers (#14719)
- PR-14483 - KAFKA-15481: Fix concurrency bug in RemoteIndexCache (#14483)
- PR-14482 - KAFKA-15169: Added TestCase in RemoteIndexCache (#14482)
- PR-981 - Update muckrake version mapping for 3.6
- PR-14635 - KAFKA-15755: LeaveGroupResponse v0 - v2 loses its member under certain error conditions (#14635)
- PR-14727 - KAFKA-15802: Validate remote segment state before fetching index (#14727)
- PR-14545 - KAFKA-15605: Fix topic deletion handling during ZK migration (#14545)
- PR-14713 - KAFKA-15780: Wait for consistent KRaft metadata when creating or deleting topics (#14695) (#14713)
- PR-14718 - KAFKA-15800: Prevent DataExceptions from corrupting KafkaOffsetBackingStore (#14718)
- PR-14712 - cherrypick KAFKA-15653: Pass requestLocal as argument to callback so we use the correct one for the thread (#14712)
- PR-14647 - KAFKA-15693: Immediately reassign lost connectors and tasks when scheduled rebalance delay is disabled (#14647)
- PR-14506 - KAFKA-15552 Fix Producer ID ZK migration (#14506)
- PR-14674 - KAFKA-15771: fix concurrency bug in ProduceRequest#partitionSizes() (#14674)
- PR-14630 - KAFKA-15680: Fix sink task partition-count metric when cooperative consumer protocol is used (#14630)
- 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)
- 33b8ee3a - remove unused import
- PR-14407 - KAFKA-15479: Remote log segments should be considered once for retention breach (#14407)
- PR-14317 - KAFKA-13973: Fix inflated block cache metrics (#14317)
- PR-14535 - KAFKA-15596: Upgrade ZooKeeper to 3.8.3 (#14535)
- PR-14519 - KAFKA-15571: StateRestoreListener#onRestoreSuspended is never called because DelegatingStateRestoreListener doesn’t implement onRestoreSuspended (#14519)
- PR-14458 - KAFKA-15498: upgrade to snappy 1.1.10.5 (#14458)
- PR-14522 - KAFKA-15415: On producer-batch retry, skip-backoff on a new leader (#14384) (#14522)
- PR-14445 - KAFKA-15502: Update SslEngineValidator to handle large stores (#14445)
- PR-14480 - KAFKA-15330: Add missing documentation of metrics introduced as part of KAFKA-15028 (#14480)
- PR-14459 - KAFKA-15511: Handle CorruptIndexException in RemoteIndexCache (#14459)
- PR-14434 - KAFKA-15498: bump snappy-java version to 1.1.10.4 (#14434)
- PR-14398 - KAFKA-15473: Hide duplicate plugins in /connector-plugins (#14398)
- PR-14393 - Added missing licenses for libraries (#14393)
- PR-14382 - KAFKA-15442: add a section in doc for tiered storage (#14382)
- PR-14347 - KAFKA-15439: Transactions test with tiered storage (#14347)
- PR-14378 - KAFKA-15459: Convert coordinator retriable errors to a known producer response error (#14378)
- PR-14367 - KAFKA-15450 Don’t allow ZK migration with JBOD (#14367)
- PR-14363 - KAFKA-14993: Improve TransactionIndex instance handling while copying to and fetching from RSM (#14363)
- PR-14349 - KAFKA-15352: Update log-start-offset before initiating deletion of remote segments (#14349)
- PR-14351 - KAFKA-15441 Allow broker heartbeats to complete in metadata transaction (#14351)
- PR-14342 - KAFKA-15435 Fix counts in MigrationManifest (#14342)
- PR-14221 - KAFKA-15338: The metric group documentation for metrics added in KAFKA-13945 is incorrect (#14221)
- PR-14330 - KAFKA-15410: Delete records with tiered storage integration test (4/4) (#14330)
- PR-14354 - KAFKA-14273; Close file before atomic move (#14354)
- PR-14314 - KAFKA-15425: Fail fast in Admin::listOffsets when topic (but not partition) metadata is not found (#14314)
- PR-14341 - KAFKA-15307: Removes non-existent configs (#14341)
- PR-14340 - KAFKA-15351: Update log-start-offset after leader election for topics enabled with remote storage (#14340)
- PR-14339 - KAFKA-15422: Update documenttion for delegation tokens when working with Kafka with KRaft (#14339)
- PR-14329 - KAFKA-15410: Delete topic integration test with LocalTieredStorage and TBRLMM (3/4) (#14329)
- PR-14331 - KAFKA-15293 Added documentation for tiered storage metrics (#14331)
- PR-14328 - KAFKA-15410: Reassign replica expand, move and shrink integration tests (2/4) (#14328)
- PR-14307 - KAFKA-15410: Expand partitions, segment deletion by retention and enable remote log on topic integration tests (1/4) (#14307)
- PR-14324 - KAFKA-15424: Make the transaction verification a dynamic configuration (#14324)
- PR-14113 - KAFKA-15260: RLM Task should handle uninitialized RLMM for the associated topic-parititon (#14113)
- PR-14320 - KAFKA-15421: fix network thread leak in testThreadPoolResize (#14320)
- PR-14326 - KAFKA-15429: reset transactionInFlight on StreamsProducer close (#14326)
- PR-14325 - KAFKA-15429: catch+log errors from unsubscribe in streamthread shutdown (#14325)
- PR-14319 - KAFKA-15427: Fix resource leak in integration tests for tiered storage (#14319)
- PR-14301 - KAFKA-15351: Ensure log-start-offset not updated to local-log-start-offset when remote storage enabled (#14301)
- daea0fdf - KAFKA-15375: fix broken clean shutdown detection logic in LogManager
- PR-14161 - KAFKA-15267: Do not allow Tiered Storage to be disabled while topics have remote.storage.enable property (#14161)
- PR-14285 - KAFKA-15399: Enable OffloadAndConsumeFromLeader test (#14285)
- PR-14236 - KAFKA-15353: make sure AlterPartitionRequest.build() is idempotent (#14236)
- PR-14288 - KAFKA-15256: Adding reviewer as part of release announcement email template (#14288)
- PR-14266 - KAFKA-15294: Publish remote storage configs (#14266)
- PR-14127 - KAFKA-15181: Wait for RemoteLogMetadataCache to initialize after assigning partitions (#14127)
- PR-14282 - KAFKA-15389: Don’t publish until we have replayed at least one record (#14282)
- PR-13561 - KAFKA-14888: Added remote log segments retention mechanism based on time and size. (#13561)
- 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-14238 - KAFKA-15290: Handle topic-level dynamic remote storage enable configuration (#14238)
- PR-14283 - KAFKA-15400: Use readLock when removing an item from the RemoteIndexCache (#14283)
- PR-14135 - KAFKA-14991: KIP-937-Improve message timestamp validation (#14135)
- PR-14280 - KAFKA-15391: Handle concurrent dir rename which makes log-dir to be offline unexpectedly (#14280)
- PR-14208 - KAFKA-14538 Metadata transactions in MetadataLoader (#14208)
- PR-14269 - KAFKA-14936: fix grace period partition issue (#14269)
- PR-14197 - KAFKA-15380: Execute action queue after callback request (#14197)
- PR-14116 - KAFKA-15167: Tiered Storage Test Harness Framework (#14116)
- PR-14083 - KAFKA-15219: KRaft support for DelegationTokens (#14083)
- PR-14249 - KAFKA-10199: Change to RUNNING if no pending task to init exist (#14249)
- PR-938 - KSECURITY-1789: upgrading requests to v2.31.0
- PR-14027 - KAFKA-14936: Add restore logic (3/N) (#14027)
- PR-14230 - KAFKA-15226: Add connect-plugin-path and plugin.discovery system test (#14230)
- PR-14103 - HOTIFX: fix Kafka Streams upgrade path from 3.4 to 3.5 (#14103)
- PR-14237 - Handle case of default broker in config migration (#14237)
- PR-14216 - KAFKA-15319: Upgrade rocksdb
- PR-13947 - KAFKA-15130: Delete remote segments when deleting a topic (#13947)
- PR-936 - KSECURITY-1859: upgrading netty to 4.1.96.Final
- PR-14213 - KAFKA-15345; KRaft leader notifies leadership when listener reaches epoch start (#14213)
- PR-14220 - KAFKA-15102: Add release notes about the replication.policy.internal.topic.separator.enabled property for MirrorMaker 2 (#14220)
- PR-14005 - KAFKA-15177: Implement KIP-875 SourceConnector::alterOffset API in MirrorMaker 2 connectors (#14005)
- PR-14195 - KAFKA-15228: Add sync-manifests command to connect-plugin-path (KIP-898) (#14195)
- PR-13302 - KAFKA-14759: Move Mock, Schema, and Verifiable connectors to new test-plugins module (#13302)
- PR-14183 - KAFKA-15210: Mention vote should be open for at atleast 72 hours in the release script (#14183)
- PR-14209 - KAFKA-14133: Migrate ActiveTaskCreatorTest, ChangelogTopicsTest and GlobalProcessorContextImplTest to Mockito (#14209)
- PR-14142 - KAFKA-7438: Replace EasyMock with Mockito in SessionStoreBuilderTest (#14142)
- PR-14205 - KAFKA-14133: Migrato SessionCacheFlushListenerTest, TimestampedCacheFlushListenerTest and TimestampedTupleForwarderTest to Mockito (#14205)
- PR-14202 - KAFKA-15329: Make default remote.log.metadata.manager.class.name as topic based RLMM (#14202)
- PR-14082 - KAFKA-15102: Add replication.policy.internal.topic.separator.enabled property to MirrorMaker 2 (KIP-949) (#14082)
- PR-14176 - KAFKA-15295: Add config validation when remote storage is enabled on a topic (#14176)
- PR-14190 - KAFKA-7438: Replace Easymock & Powermock with Mockito in RocksDBMetricsRecorderGaugesTest (#14190)
- adc16d0f - KAFKA-14538: Implement KRaft metadata transactions in QuorumController
- PR-13990 - KAFKA-14937: Refactoring for client code to reduce boilerplate (#13990)
- PR-14001 - KAFKA-15326: [5/N] Processing thread punctuation (#14001)
- PR-14201 - KAFKA-15289: Support KRaft mode in RequestQuotaTest (#14201)
- PR-14189 - KAFKA-7438: Replace Easymock & Powermock with Mockito in TableSourceNodeTest (#14189)
- PR-14064 - KAFKA-15030: Add connect-plugin-path command-line tool (#14064)
- PR-14187 - KAFKA-13197: fix GlobalKTable join/left-join semantics documentation. (#14187)
- PR-14172 - KAFKA-14595: Move classes from ReassignPartitionsCommand to tools (#14172)
- PR-14153 - KAFKA-14132: Replace Easymock & Powermock with Mockito in KafkaBasedLogTest (#14153)
- PR-14151 - KAFKA-15083: add config with “remote.log.metadata” prefix (#14151)
- PR-14185 - KAFKA-15287: Change NodeApiVersions.create() to support both zk and kraft (#14185)
- PR-14188 - KAFKA-15239: Fix ThroughputThrottler import-control (#14188)
- PR-14068 - KAFKA-15233: Add documentation for plugin.discovery and connect-plugin-path (KIP-898) (#14068)
- PR-14092 - KAFKA-15239: Fix system tests using producer performance service (#14092)
- PR-14102 - KAFKA-13187: Replace EasyMock / PowerMock with Mockito in DistributedHerderTest (#14102)
- PR-14156 - KAFKA-15202: Fix MM2 offset translation when syncs are variably spaced (#14156)
- PR-14050 - KAFKA-15220: Do not returned fenced brokers from getAliveBrokerNode (#14050)
- PR-14159 - KAFKA-15291: Connect plugins should declare a version (#14159)
- PR-14169 - KAFKA-15318: Update the Authorizer via AclPublisher (#14169)
- PR-14175 - KAFKA-15288: Change BrokerApiVersionsCommandTest to support kraft mode (#14175)
- PR-14178 - KAFKA-15022: [9/N] use RackAwareTaskAssignor in StickyTaskAssignor (#14178)
- PR-14164 - KAFKA-15022: [8/N] more tests for HAAssignor (#14164)
- PR-14141 - KAFKA-15100; KRaft data race with the expiration service (#14141)
- PR-14096 - KAFKA-14595: Move AdminUtils to server-common (#14096)
- 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-14055 - KAFKA-15031: Add plugin.discovery to Connect worker configuration (KIP-898) (#14055)
- PR-14139 - KAFKA-15022: [7/N] use RackAwareTaskAssignor in HAAssignor (#14139)
- PR-14150 - KAFKA-15022: [6/N] add rack aware assignor configs and update standby optimizer (#14150)
- PR-14133 - KAFKA-15189: only init remote topic metrics when enabled (#14133)
- PR-13984 - KAFKA-15107: Support custom metadata for remote log segment (#13984)
- PR-14145 - KAFKA-10199: Change to RUNNING if no pending task to recycle exist (#14145)
- PR-13920 - KAFKA-15106: Fix AbstractStickyAssignor isBalanced predict (#13920)
- PR-14143 - KAFKA-7438: Replace PowerMockRunner with MockitoJUnitRunner in RetryUtilTest (#14143)
- PR-14114 - KAFKA-12969: Add broker level config synonyms for topic level tiered storage configs (#14114)
- PR-14108 - KAFKA-15022: [5/N] compute rack aware assignment for standby tasks (#14108)
- PR-14074 - KAFKA-15236: Rename tiered storage metrics (#14074)
- PR-14128 - KAFKA-15272: Fix the logic which finds candidate log segments to upload it to tiered storage (#14128)
- PR-14097 - KAFKA-15022: [4/N] use client tag assignor for rack aware standby task assignment (#14097)
- PR-14089 - KAFKA-15244: Remove PluginType.from(Class) (#14089)
- PR-13260 - KAFKA-14661: Upgrade Zookeeper to 3.8.1 (#13260)
- PR-14126 - Fix a Scala 2.12 compile issue (#14126)
- PR-14099 - KAFKA-14702: Extend server side assignor to support rack aware replica placement (#14099)
- PR-14115 - KAFKA-15263 Check KRaftMigrationDriver state in each event (#14115)
- PR-14056 - KAFKA-14501: Implement Heartbeat protocol in new GroupCoordinator (#14056)
- PR-14090 - KAFKA-14048; CoordinatorContext should be protected by a lock (#14090)
- PR-13671 - KAFKA-14967: fix NPE in CreateTopicsResult in MockAdminClient (#13671)
- PR-14049 - KAFKA-14038: Optimise calculation of size for log in remote tier (#14049)
- PR-13643 - KAFKA-15213: provide the exact offset to QuorumController.replay (#13643)
- PR-14084 - [MINOR] Add latest versions to kraft upgrade kafkatest (#14084)
- PR-14067 - KAFKA-14499: [3/N] Implement OffsetCommit API (#14067)
- PR-14069 - KAFKA-15251: Add 3.5.1 to system tests (#14069)
- PR-14017 - KAFKA-14500; [6/6] Implement SyncGroup protocol in new GroupCoordinator (#14017)
- PR-14030 - KAFKA-15022: [3/N] use graph to compute rack aware assignment for active stateful tasks (#14030)
- PR-14075 - KAFKA-15235: Fix broken coverage reports since migration to Gradle 8.x (#14075)
- PR-14028 - KAFKA-15196 Additional ZK migration metrics (#14028)
- PR-14094 - KAFKA-15243: Set decoded user names to DescribeUserScramCredentialsResponse (#14094)
- PR-14100 - [MINOR] Fix Javadoc comment in KafkaFuture#toCompletionStage (#14100)
- PR-14059 - KAFKA-14583: Move ReplicaVerificationTool to tools (#14059)
- PR-14051 - KAFKA-15218: Avoid NPE thrown while deleting topic and fetch from follower concurrently (#14051)
- PR-14079 - KAFKA-15238: Move DLQ reporter setup from the DistributedHerder’s tick thread to the sink task thread (#14079)
- PR-14010 - KAFKA-15183: Add more controller, loader, snapshot emitter metrics (#14010)
- PR-13707 - KAFKA-14990: Dynamic producer ID expiration should be applied on a broker restart (#13707)
- PR-14033 - KAFKA-14920: Address timeouts and out of order sequences (#14033)
- PR-14004 - KAFKA-15168: Handle overlapping remote log segments in RemoteLogMetadata cache (#14004)
- PR-13773 - KAFKA-14712: Produce correct error msg with correct metadataversion (#13773)
- PR-14057 - KAFKA-15194: Prepend offset in the filenames used by LocalTieredStorage (#14057)
- PR-13797 - KAFKA-14950: implement assign() and assignment() (#13797)
- PR-14066 - KAFKA-15232: Move ToolsUtils to tools (#14066)
- PR-14047 - KAFKA-14499: [2/N] Add OffsetCommit record & related (#14047)
- PR-14046 - KAFKA-14499: [1/N] Introduce OffsetCommit API version 9 and add new StaleMemberEpochException error (#14046)
- PR-14024 - KAFKA-13431 (KIP-793): Expose the original pre-transform topic partition and offset in sink records (#14024)
- PR-13278 - KAFKA-14591: Move DeleteRecordsCommand to tools (#13278)
- PR-14060 - KAFKA-15222: upgrade zinc scala plugin to 1.9.2 (#14060)
- PR-13999 - KAFKA-15176: add tests for tiered storage metrics (#13999)
- PR-13996 - KAFKA-15022: [2/N] introduce graph to compute min cost (#13996)
- PR-13313 - KAFKA-14760: Move ThroughputThrottler from tools to clients, remove tools dependency from connect-runtime (#13313)
- PR-13874 - KAFKA-14133: Migrate various mocks in TaskManagerTest to Mockito (#13874)
- PR-14044 - KAFKA-15216: InternalSinkRecord::newRecord should not ignore new headers (#14044)
- PR-13942 - KAFKA-14936: Check the versioned table’s history retention and compare to grace period (4/N) (#13942)
- PR-13983 - KAFKA-14734: Use CommandDefaultOptions in StreamsResetter (#13983)
- PR-13971 - KAFKA-15150: Add ServiceLoaderScanner implementation (#13971)
- PR-14029 - KAFKA-10579: Upgrade reflections from 0.9.12 to 0.10.2 (#14029)
- PR-13977 - KAFKA-15162: Reflectively find plugins in parent ClassLoaders that aren’t on the classpath (#13977)
- PR-13949 - KAFKA-15141: Initialize logger statically on hot codepaths (#13949)
- PR-14039 - KAFKA-15211: Mock InvalidParameterException in DistributedConfigTest (#14039)
- PR-14035 - KAFKA-15199: Remove Leading and Trailing Spaces in release.py (#14035)
- PR-13870 - KAFKA-14500; [5/N] Implement JoinGroup protocol in new GroupCoordinator (#13870)
- PR-13948 - KAFKA-15091: Fix misleading Javadoc for SourceTask::commit (#13948)
- PR-13944 - KAFKA-14953: Add tiered storage related metrics (#13944)
- PR-13945 - KAFKA-15121: Implement the alterOffsets method in the FileStreamSourceConnector and the FileStreamSinkConnector (#13945)
- PR-13585 - KAFKA-14737: Move kafka.utils.json to server-common (#13585)
- PR-13158 - KAFKA-14647: Move TopicFilter to server-common/utils (#13158)
- PR-13837 - KAFKA-9564: Local Tiered Storage implementation for Remote Storage Manager (#13837)
- PR-14023 - fix typo in streams/dsl-api.html (#14023)
- PR-13941 - KAFKA-15123: Add tests for ChunkedBytesStream (#13941)
- PR-13787 - KAFKA-14884: Include check transaction is still ongoing right before append (take 2) (#13787)
- PR-14003 - KAFKA-15182: Normalize source connector offsets before invoking SourceConnector::alterOffsets (#14003)
- PR-13991 - KAFKA-14462; [23/23] Wire GroupCoordinatorService in BrokerServer (#13991)
- PR-13997 - KAFKA-15180: Generalize integration tests to change use of KafkaConsumer to Consumer (#13997)
- PR-14013 - Fix compile test error (#14013)
- PR-10167 - KAFKA-12261: Mention about potential delivery loss on increasing partition when auto.offset.reset = latest (#10167)
- PR-13957 - Kafka Streams Threading: Exception handling (#13957)
- PR-13973 - KAFKA-15148: Mark tests correctly as integration tests where they running as unit tests (#13973)
- PR-13963 - KAFKA-14462; [22/N] Implement session and revocation timeouts (#13963)
- PR-13859 - KAFKA-15093: Add 3.4.0 and 3.5.0 to core upgrade and compatibility system tests (#13859)
- PR-13275 - KAFKA-14522 Rewrite/Move of RemoteIndexCache to storage module. (#13275)
- PR-13453 - KAFKA-12525: Ignoring stale status statuses when reading from Connect status topic (#13453)
- PR-13974 - KAFKA-15155: Follow PEP 8 best practice in Python to check if a container is empty (#13974)
- PR-13988 - [KAFKA-15137] Do not log entire request payload in KRaftControllerChannelManager (#13988)
- PR-13982 - KAFKA-15159: upgrade minor dependencies (#13982)
- PR-13946 - KAFKA-15139: Avoid slow Set.removeAll(List) in MirrorCheckpointConnector (#13946)
- PR-13955 - KAFKA-15145: Don’t re-process records filtered out by SMTs on Kafka client retriable exceptions in AbstractWorkerSourceTask (#13955)
- PR-13383 - KAFKA-14059 Replace PowerMock with Mockito in WorkerSourceTaskTest (#13383)
- PR-13284 - KAFKA-14718: Wait for MirrorMaker to start before executing test (#13284)
- PR-13661 - Doc fixes: Fix format and other small errors in config documentation (#13661)
- PR-13851 - KAFKA-15022: [1/N] initial implementation of rack aware assignor (#13851)
- PR-13961 - KAFKA-14462; [21/N] Add CoordinatorTimer implementation in CoordinatorRuntime (#13961)
- PR-13968 - KAFKA-15149: Fix handling of new partitions in dual-write mode (#13968)
- PR-13962 - KAFKA-15129;[7/N] Remove metrics in TransactionMarkerChannelManager when TransactionCoordinator shutdown (#13962)
- PR-13821 - KAFKA-15069: Refactor plugin scanning logic into ReflectionScanner (#13821)
- PR-13964 - KAFKA-15153: Use Python ‘is’ instead of ‘==’ to compare for None (#13964)
- PR-13898 - KAFKA-14966; [2/N] Extract OffsetFetcher reusable logic (#13898)
- PR-13901 - KAFKA-14462; [20/N] Refresh subscription metadata on new metadata image (#13901)
- PR-13950 - KAFKA-15140: Use TestUtils methods and add logs for assertion failure at TopicCommandIntegrationTest (#13950)
- PR-13925 - KAFKA-10199: Consider tasks in state updater when computing offset sums (#13925)
- PR-13924 - KAFKA-15129: [1/N] Remove metrics in LogCleanerManager when LogCleaner shutdown (#13924)
- PR-13938 - KAFKA-15135: fix(storage): pass endpoint configurations as client common to TBRLMM (#13938)
- PR-13760 - KAFKA-8982: Add retry of fetching metadata to Admin.deleteRecords (#13760)
- PR-13939 - [MINOR] Correcting few WARN log lines in DistributedHerder#handleRebalance (#13939)
- PR-13923 - KAFKA-15131: Improve RemoteStorageManager exception handling documentation (#13923)
- PR-13591 - KAFKA-14831: Illegal state errors should be fatal in transactional producer (#13591)
- PR-13904 - KAFKA-15114: Update StorageTool help for creating SCRAM credentials to specify name instead of user. (#13904)
- PR-13915 - KAFKA-14930: Document the new PATCH and DELETE offsets REST APIs for Connect (#13915)
- PR-13855 - KAFKA-14936: Add Grace period logic to Stream Table Join (2/N) (#13855)
- PR-13831 - KAFKA-15053: Use case insensitive validator for security.protocol config (#13831)
- PR-13880 - KAFKA-14462; [19/N] Add CoordinatorLoader implementation (#13880)
- PR-13845 - KAFKA-15078; KRaft leader replys with snapshot for offset 0 (#13845)
- PR-13798 - KAFKA-15028: AddPartitionsToTxnManager metrics (#13798)
- PR-13910 - KAFKA-15109 Ensure the leader epoch bump occurs for older MetadataVersions (#13910)
- PR-907 - Fix packaging master build
- PR-13818 - KAFKA-14784: Connect offset reset REST API (#13818)
- PR-13267 - KAFKA-14694: RPCProducerIdManager should not wait on new block (#13267)
- PR-13895 - KAFKA-15098 Allow authorizers to be configured in ZK migration (#13895)
- PR-13812 - KAFKA-14462; [18/N] Add GroupCoordinatorService (#13812)
- PR-13890 - KAFKA-15109 Don’t skip leader epoch bump while in migration mode (#13890)
- PR-13850 - KAFKA-15084: Remove lock contention from RemoteIndexCache (#13850)
- PR-13856 - KAFKA-15087 Move/rewrite InterBrokerSendThread to server-commons (#13856)
- PR-12739 - KAFKA-7438: Migrate to Mockito in TimeOrderedCachingPersistentWindowStoreTest (#12739)
- cd3c0ab1 - KAFKA-15060: fix the ApiVersionManager interface
- PR-13872 - KAFKA-15085: Make Timer.java implement AutoCloseable (#13872)
- PR-13865 - KAFKA-15096: Update snappy-java to 1.1.10.1 (#13865)
- PR-13828 - KAFKA-15066: add “remote.log.metadata.manager.listener.name” config to rlmm (#13828)
- PR-13819 - KAFKA-15059: Remove pending rebalance check when fencing zombie source connector tasks (#13819)
- PR-13711 - KAFKA-14133: Migrate StandbyTaskCreator mock in TaskManagerTest to Mockito (#13711)
- PR-13756 - KAFKA-14936: Add On Disk Time Ordered Buffer (1/N) (#13756)
- PR-902 - Update muckrake version mapping for 3.5
- PR-13843 - KAFKA-15080; Fetcher’s lag never set when partition is idle (#13843)
- PR-13712 - KAFKA-14133: Migrate Admin mock in TaskManagerTest to Mockito (#13712)
- PR-13795 - KAFKA-14462; [17/N] Add CoordinatorRuntime (#13795)
- PR-13834 - KAFKA-15076; KRaft should prefer latest snapshot (#13834)
- PR-13832 - KAFKA-15036: Add a test case for controller failover (#13832)
- PR-13829 - KAFKA-10199: Re-add revived tasks to the state updater after handling (#13829)
- PR-13835 - KAFKA-15077: Code to trim token in FileTokenRetriever (#13835)
- PR-13830 - KAFKA-14936: Change Time Ordered Buffer to not require Change<> 0/N (#13830)
- PR-13827 - KAFKA-15073: Add a Github action to mark PRs as stale (#13827)
- PR-13807 - KAFKA-15040: trigger onLeadershipChange under KRaft mode (#13807)
- PR-13815 - KAFKA-14966: Extract OffsetFetcher reusable logic (#13815)
- PR-12307 - KAFKA-14006: Parameterize WorkerConnectorTest suite (#12307)
- PR-13751 - KAFKA-14539: Simplify StreamsMetadataState by replacing the Cluster metadata with partition info map (#13751)
- PR-13811 - KAFKA-14278: Fix InvalidProducerEpochException and InvalidTxnStateException handling in producer clients (#13811)
- PR-13803 - KAFKA-15051: add missing GET plugin/config endpoint (#13803)
- PR-13678 - KAFKA-10337: await async commits in commitSync even if no offsets given (#13678)
- PR-13765 - KAFKA-15021; Skip leader epoch bump on ISR shrink (#13765)
- PR-13788 - KAFKA-14791; Create a builder for PartitionRegistration (#13788)
- PR-13675 - KAFKA-14462; [14/N] Add PartitionWriter (#13675)
- PR-13473 - KAFKA-14866: Remove controller module metrics when broker is shutting down (#13473)
- PR-13135 - KAFKA-14633: Reduce data copy & buffer allocation during decompression (#13135)
- PR-13779 - KAFKA-15037: pass remoteLogEnabled to unifiedLog (#13779)
- PR-13805 - KAFKA-14863: Fix failing tests for invalid plugins that are no longer visible (#13805)
- PR-13799 - KAFKA-15048: Improve handling of unexpected quorum controller errors (#13799)
- PR-13794 - KAFKA-14462; [16/N] Add CoordinatorLoader and CoordinatorPlayback interfaces (#13794)
- PR-13800 - KAFKA-15012: Allow leading zeros in numeric fields while deserializing JSON messages using the JsonConverter (#13800)
- PR-13467 - KAFKA-14863: Hide plugins with invalid constructors during plugin discovery (#13467)
- PR-13793 - KAFKA-14462; [15/N] Make Result generic and rename it (#13793)
- PR-13759 - KAFKA-15019: Improve handling of broker heartbeat timeouts (#13759)
- PR-13735 - KAFKA-15003: Fix ZK sync logic for partition assignments (#13735)
- PR-13666 - KAFKA-14462; [13/N] CoordinatorEvent and CoordinatorEventProcessor (#13666)
- PR-13776 - KAFKA-15034: Improve performance of the ReplaceField SMT; add JMH benchmark (#13776)
- 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-13774 - KAFKA-12562: Fix KafkaStreams#store old references in comments (#13774)
- PR-13681 - KAFKA-14133: Migrate ActiveTaskCreator mock in TaskManagerTest to Mockito (#13681)
- PR-13786 - Upgrade to snappy v1.1.10.0 (#13786)
- PR-13780 - KAFKA-15039: Reduce logging level to trace in PartitionChangeBuilder.… (#13780)
- 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-13639 - KAFKA-14462; [12/N] Add GroupMetadataManager and ConsumerGroup (#13639)
- PR-13738 - KAFKA-14982: Improve the kafka-metadata-quorum output (#13738)
- 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-13356 - KAFKA-14789: Prevent mis-attributing classpath plugins, allow discovery of classpath RestExtension and ConfigProvider (#13356)
- PR-13465 - KAFKA-14368: Connect offset write REST API (#13465)
- PR-13455 - KAFKA-14841 Handle callbacks to ConsumerRebalanceListener in MockConsumer (#13455)
- PR-13664 - KAFKA-14961: harden DefaultBackgroundThreadTest.testStartupAndTearDown test (#13664)
- PR-13165 - KAFKA-14654: Connector classes should statically initialize with plugin classloader (#13165)
- PR-13749 - KAFKA-15016: Update LICENSE-binary file (#13749)
- PR-11565 - KAFKA-13504: Retry connect internal topics’ creation in case of InvalidReplicationFactorException (#11565)
- PR-13745 - KAFKA-15015: Explicit on reload4j version (#13745)
- PR-13708 - KAFKA-14500; [4/N] Add Timer interface (#13708)
- PR-13704 - KAFKA-14500; [3/N] add GroupMetadataKey/Value record helpers (#13704)
- PR-13723 - KAFKA-14980: Fix MirrorSourceConnector source consumer configuration (#13723)
- PR-13535 - KAFKA-9579 Fetch implementation for records in the remote storage through a specific purgatory. (#13535)
- PR-13720 - KAFKA-14997: Fix JmxToolTest failing on CI server (#13720)
- PR-13717 - KAFKA-14994: Update jose4j
- PR-13670 - KAFKA-14962: Trim whitespace from ACL configuration (#13670)
- PR-13663 - KAFKA-14500; [2/N] Rewrite GroupMetadata in Java (#13663)
- PR-13679 - KAFKA-14291: KRaft controller should return right finalized features in ApiVersionResponse (#13679)
- PR-13517 - KAFKA-14752: Kafka examples improvements - demo changes (#13517)
- PR-13060 - KAFKA-14559: Fix JMX tool to handle the object names with wildcard and optional attributes (#13060)
- PR-13690 - KAFKA-14978 ExactlyOnceWorkerSourceTask should remove parent metrics (#13690)
- PR-13516 - KAFKA-14752: Kafka examples improvements - processor changes (#13516)
- PR-13443 - KAFKA-14514; Add Range Assignor on the Server (KIP-848) (#13443)
- PR-13660 - KAFKA-14662: Update the ACL list in the doc (#13660)
- PR-13644 - KAFKA-14500; [1/N] Rewrite MemberMetadata in Java (#13644)
- PR-13688 - KAFKA-14974: Restore backward compatibility in KafkaBasedLog (#13688)
- PR-13638 - KAFKA-14462; [11/N] Add CurrentAssignmentBuilder (#13638)
- PR-13594 - KAFKA-14913: Using ThreadUtils.shutdownExecutorServiceQuietly to close executors in Connect Runtime (#13594)
- PR-13621 - KAFKA-14133: Migrate ChangeLogReader mock in TaskManagerTest to Mockito (#13621)
- PR-13515 - KAFKA-14752: Kafka examples improvements - producer changes (#13515)
- PR-13461 - KAFKA-14840: Support for snapshots during ZK migration (#13461)
- PR-13312 - KAFKA-14766: Improve performance of VarInt encoding and decoding (#13312)
- PR-13623 - KAFKA-14926: Remove metrics on Log Cleaner shutdown (#13623)
- PR-13607 - KAFKA-14916: Fix code that assumes transactional ID implies all records are transactional (#13607)
- PR-12149 - KAFKA-13668: Retry upon missing initProducerId due to authorization error (#12149)
- PR-13122 - KAFKA-14594: Move LogDirsCommand to tools module (#13122)
- 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-13637 - KAFKA-14462; [10/N] Add TargetAssignmentBuilder (#13637)
- PR-13514 - KAFKA-14752: Kafka examples improvements - consumer changes (#13514)
- PR-13529 - KAFKA-14133: Migrate topology builder mock in TaskManagerTest to mockito (#13529)
- 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-13171 - KAFKA-14584: Deprecate StateChangeLogMerger tool (#13171)
- PR-13606 - KAFKA-14918 Only send controller RPCs to migrating ZK brokers (#13606)
- 33962e8b - KAFKA-14943: Fix ClientQuotaControlManager validation
- 70493336 - KAFKA-14943: Fix ClientQuotaControlManager validation
- PR-13544 - KAFKA-14462; [9/N] Add RecordHelpers (#13544)
- PR-12545 - KAFKA-14944: Reduce CompletedFetch#parseRecord() memory copy (#12545)
- PR-13429 - KAFKA-14666: Add MM2 in-memory offset translation index for offsets behind replication (#13429)
- PR-13538 - KAFKA-14462; [8/N] Add ConsumerGroupMember (#13538)
- PR-13636 - KAFKA-14933: Document Connect’s log level REST APIs from KIP-495 (#13636)
- PR-13459 - KAFKA-14592: Move FeatureCommand to tools (#13459)
- 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-13537 - KAFKA-14462; [7/N] Add ClientAssignor, Assignment, TopicMetadata and VersionedMetadata (#13537)
- PR-13437 - KAFKA-14828: Remove R/W locks using persistent data structures (#13437)
- 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-13432 - KAFKA-14821 Implement the listOffsets API with AdminApiDriver (#13432)
- f5de4daa - KAFKA-14887: FinalizedFeatureChangeListener should not shut down when ZK session expires
- PR-13609 - KAFKA-14834: [11/N] Update table joins to identify out-of-order records with isLatest (#13609)
- PR-11478 - KAFKA-13299: Accept duplicate listener on port for IPv4/IPv6 (#11478)
- PR-13471 - KAFKA-14868: Remove all ReplicaManager metrics when it is closed (#13471)
- PR-13572 - KAFKA-14908: Set setReuseAddress on the kafka server socket (#13572)
- 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-13557 - KAFKA-14902: KafkaStatusBackingStore retries on a dedicated background thread to avoid stack overflows (#13557)
- PR-13280 - KAFKA-14735: Improve KRaft metadata image change performance at high … (#13280)
- 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-13502 - KAFKA-14790: Add more AddPartitionsToTxn tests in KafkaApis and Authorizer tests (#13502)
- PR-13536 - KAFKA-14462; [6/N] Update Records (#13536)
ksqlDB¶
- PR-10198 - Set timeout to 6 hours on branches starting on 7.3.x
- PR-10195 - Add pinned nano version for common on 7.3.x
- PR-10196 - Add pinned nano version for common for 7.4.x
- PR-10189 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
- PR-10175 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
- PR-10178 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
- PR-10149 - Merge Conflict Resolution (from 6.2.x to 7.0.x)
- 722b14d9 - MINOR: fix broken build
- PR-10109 - fix: return retryable error during shutdown
- PR-10110 - MINOR: fix broken build
- PR-10092 - fix: fedramp issues
- PR-10098 - fix: vert.x regression bug when doing high volume pull query
- PR-10103 - fix: do not continue processing records on permission errors in schema registry
- 247e0278 - [KSQL-11372] Log pull query bandwidth rate in bytes
- PR-10097 - fix: [KSQL-11345] fix changed TaskAssignor
- PR-10077 - fix: concurrency bug when doing high volume pull query over java client (alternative)
- PR-10059 - feat: FedRAMP Self-managed ksqlDB
- PR-10065 - fix: import not picked back in fix
- PR-10061 - fix: force the number of standby to always be zero for transient queries
- PR-10050 - fix: checkstyle violations in KsqlConfig
- PR-10040 - fix: delete created Kafka if the corresponding command fails
- 193fd55f - small fixes
- c4e7ab07 - remove logger
- 462d924d - remove TR
- cfa4457c - remove streams clients metrics
- 2c849dc4 - eric comments
- 00f2a0bf - don’t addConfluentMetricsContextConfigsKafka for streams clients
- PR-10032 - fix: Fixes corruption in the output of pull queries with large responses
- PR-10010 - fix: remove duplicate definition
- PR-10006 - fix: implement default method for schema registry client
- PR-9970 - fix: do not scan the whole classpath
- PR-9969 - Bump io.confluent.schema-registry.version to 7.6.0-0 after bumping ksql version to 7.6
REST Proxy¶
- PR-1235 - KREST-2300 Deflake KafkaConsumerManagerTest.testBackoffMsControlsPollCalls test
- PR-1236 - KREST-NNN disable flaky test
- 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-1203 - Add 413 response error for produce v3 api
- PR-1200 - KREST-10285 example rest produce v3 streaming in javascript (nodejs)
- PR-1196 - Create custom Properties and Map configs classes with toString method that hides password properties
- PR-1192 - Able to drop connection if produce request is larger than a threshold
- PR-1189 - KREST-11230 Fix tests to expect media-type application/json for errors
- PR-1183 - Make sure that ErrorMessage is intepret as json type in response writer
- PR-1178 - Review logging, some code tidy up
- PR-1176 - KREST-10790 Add test for KafkaRestExceptionMapper.java
- PR-1168 - KREST-10243 Add custom-request-logging to kafka-rest, and log error-codes for when various rate-limiters are triggered
- PR-440 - KREST-11812 Replace EOL javaee/jaxb-api with jarkartaee/jaxb-api
- ee8dd479 - KREST-12364: update bcpix
- PR-420 - CIAM-2673: initialize start time in metrics before onEvent() is called
- PR-411 - KREST-11705 Map RecordTooLargeException to KAFKA_BAD_REQUEST_ERROR_CODE
- PR-408 - KREST-11276 - Tighten SSL auto cert reload
- PR-409 - KREST-11276 - Fixing cert reload with multiple registered listeners
- PR-410 - KREST-7955 421 misdirected request if host does not match SNI
- PR-406 - Implementation of RateLimitNetworkTrafficListener
- PR-405 - Make sure that ErrorMessage is always interpreted as json in Response
- PR-404 - Fix typo in doc and make private property final
- PR-402 - Add JettyRequestMetricsFilter for counting requests on Jetty layer
- a49bb0b0 - KREST-10989: Handle ThrottlingQuotaExceededException exception as 429
- acbc8234 - KREST-10790 Handle TopicDeletionDisabledException as 400
- PR-398 - Introduce request attribute to enable global metrics use runtime request tags
Schema Registry¶
- 0cb664f1 - Fix sharedKeys cache to account for multiple use of kms key ID
- PR-2943 - DGS-9104: 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 - DGS-9825: Added num_keks_shared metric
- 13848a40 - Improve the performance of invalid name scrubbing
- PR-2931 - Handle bug where enable.fips config is true but FIPS resource exten
- d8edcdc7 - Add test
- e07cbfad - DGS-9753 FIx local refs for JSON Schema 2020-12
- 0bdb81e7 - DGS-9732 Omit decrypted DEK when registering DEK in IMPORT mode
- 0eb5a631 - DGS-9719 Allow JSONata exprs to be used for CONDITION rules
- 85a9e53c - DGS-9520 Also support allOf to singleton; add tests
- 26a3423e - DGS-8901 Ensure logicalType flag passed to ReflectData
- 414ce79f - DGS-9520 Better handling of JSON Schema singleton combined types
- 01cc37a6 - Fix NPE for getAllVersionsById in MockSchemaRegistryClient
- de9de139 - Handle all exceptions when rule action cannot be performed
- 78b1947d - DGS-9450 Strip rule param prefix from configs
- 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
- 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
- 0d57454c - Add unit tests and introduce validate fields config
- 089b1fb7 - Upgrade tink to 1.12.0
- 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
- 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
- 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
- PR-2832 - Rename Pre-init resource extension config
- PR-2828 - DGS-9006: Load FIPS extension before KafkaSchemaRegistry is initialized
- 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-2818 - Cache ProtobufSchema.toDynamicSchema calls
- PR-2817 - Sort list of dek subjects before returning to client
- PR-2816 - DGS-8960 Fix handling of diamond structure in Protobuf converter
- PR-2811 - fix packaging of kafka-connect-avro-converter
- PR-2815 - Update DEK Registry spec
- PR-2810 - Upgrade json-skema to 0.10.0
- PR-2807 - Allow create kek/dek to act like undelete
- PR-2808 - For tags API, only modify ruleset on leader node
- 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
- PR-2801 - Add check and test for invalid DEK rotation expiry
- PR-2798 - Add tests for DEK generation
- PR-2792 - Cache missing subjects (and not just missing schemas)
- 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-2781 - DGS-8542 Add support for JSON Schema Draft 2020-12
- PR-2783 - DGS-8708 Add rule config to preserve source fields
- PR-2782 - Add CSFLE tests for non-string fields
- PR-2775 - Upgrade wire to 4.9.0
- PR-2774 - Fix build due to KAFKA-9800
- PR-2773 - DGS-8615 Minor change to DlqAction
- PR-2771 - Checking “isCompatible” for all compatibility test responses
- 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
- PR-2765 - DGS-8334 Don’t include ts in hashCode/equals for schemas
- PR-2764 - DGS-8336 Add ruleType filter to schemas endpoint
- PR-2758 - DGS-8323 Always populate version metadata prop for tags API
- PR-2762 - DGS-8320 Fix handling of primitives for JSON Schema
- PR-2759 - DGS-8334 Add timestamp to returned schemas
- PR-2756 - DGS-8320 Fix handling of primitives for JSON Schema
- PR-2755 - DGS-8320 Enable defaults for JSON Schema
- e8fa7432 - DGS-7866: Disallow properties starting with $ by default in JsonSchema
- 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
- b8d518d1 - DGS-7865: Add protobuf support for reserved fields and incorporate review feedback
- PR-2741 - Improve error handling during DEK creation
- PR-2738 - Ensure kek name is prefixed with context
- 8cd4e320 - DGS-7865: Reserved fields support for Avro schema
- 3018aee8 - DGS-7865: checkstyle fixes
- e5dcee98 - DGS-7865: Reserved fields support for JSON schema
- 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-2682 - Fix stop service script logic
- PR-2686 - Use static ObjectMappers
- 9f7dad51 - Bump junit from 4.12 to 4.13.1 in /benchmark