Confluent Platform Component Changelogs¶

This topic provides changelogs for the individual Confluent Platform components.

Version 7.6.4¶

Released December 2024

Community Features¶

Common¶

bbde81e9 - Changed bctls-fips to 1.0.13
16ab459f - Changed bouncycastle
PR-687 - update jetty to 9.4.56
PR-684 - define version of commons-io and add it to dependencyManagement
79d5047d - upgrade avro to 1.11.4 to patch AVRO-3985
PR-663 - disable CI gating workflow for master branch
948d59f6 - Upgrade Netty
PR-657 - update protobuf to 3.25.5 (#16) (#654) (#17)
PR-654 - update protobuf to 3.25.5
PR-646 - update bouncycastle to version 2.0 (#11)
PR-637 - adding cp-jar-build ci gating

Kafka¶

PR-1501 - Fix version check in util.py
PR-1487 - Update jetty to 9.4.56.v20240826
PR-1481 - Added commonsIo to libs variable.
PR-1458 - Bump commonsIo to version 2.16.0 in 3.6
bfc515c3 - Ignore failing quota_test
PR-1437 - disable flakey test

ksqlDB¶

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

REST Proxy¶

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

Schema Registry¶

PR-3359 - Add latest caches at the SR client level
PR-3361 - Don’t create a new version if latest is equivalent
PR-3351 - Ensure correct exception is thrown from parseSchema
PR-3354 - Add test to ensure MD5 does not change for schema values
PR-3352 - Minor optimization to reduce schema ID lookups
PR-3348 - Reapply “Fix for decoding of sensitive metadata”
PR-3349 - Reapply “Allow SR to ignore confluent version when matching schemas”
PR-3346 - Include sonarqube
PR-3343 - disable SR to ignore confluent version when matching schemas
PR-3342 - remove fix for decoding of sensitive metadata”
PR-3334 - disable change to default rule actions
PR-3339 - remove fix for decoding of sensitive metadata”
PR-3337 - Fix pint merge 7.4.x to 7.5.x
PR-3333 - Ensure encoders are synced when decoding sensitive metadata
PR-3332 - Fix NPE when listing versions by id
PR-3327 - Add additional tests for draft 2019-09 (#81)
PR-3328 - Add dedupe test for same schema w/different version (#82)
PR-3322 - Allow SR to ignore confluent:version when matching schemas
PR-3316 - Return encrypted value instead of throwing exception
PR-3311 - Fix 7.1.x merge conflicts
PR-3265 - Add performanceMetric to get config metadata API
PR-3264 - Add performanceMetric to list schema refs API
PR-3263 - Add performanceMetric to global delete config API
PR-3307 - Fix pint merge from 7.3.x to 7.4.x
PR-3244 - Handle 401/403 errors appropriately
e39cf350 - Fix typo in scope for JSON schema else clause
PR-72 - Fixed the wait timeout in the KafkaStoreReaderThread. Fixes #54
PR-68 - Updated classpath logic in shell script.
PR-70 - Api update
41e967fc - inor fix
66a9487a - inor fix
PR-3262 - remove azure-identity definition, update azure-keyvault version (#49)
PR-3278 - Use concurrent hash maps in serde members (#61)
PR-3276 - Add format query param to APIs that return a schema (#46)
PR-3275 - Scrub refs in arrays when searching for inline tags (#59)
PR-3273 - Dedupe imported schemas with older versions (#58)
PR-3266 - Ensure register schema request is forwarded correctly (#53)
PR-3252 - Add CSFLE tests with pre-canned data (#42)
PR-3250 - Allow oneofs to be flattened in Protobuf converter (#41)
PR-3249 - Bound recursion when finding tagged entities (#40)
PR-63 - Integration tests
PR-3256 - adding cp jar build CI gating block (#38)

Version 7.6.3¶

Released August 2024

Community Features¶

Common¶

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

Kafka¶

PR-1392 - 3.6 fixed downstream trigger

ksqlDB¶

PR-63 - Checkstyle fixes
PR-62 - Remove unnecessary exclusions
PR-61 - Remove unused imports
PR-60 - Removed the imlicit topic generation from th estatement executor.
PR-59 - Added partition by clause to CSAS statement
PR-52 - Inherit from common POM, clean up dependencies
PR-50 - json processing
PR-49 - Fixed the issue with COUNT(*).
PR-47 - Make tabular output for ‘DESCRIBE …’ statements a little prettier
PR-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.

REST Proxy¶

PR-1250 - Allow to set KafkaAvroSerializerConfig in KafkaRestConfig (#1229)

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