Confluent Platform Component Changelogs¶

This topic provides changelogs for the individual Confluent Platform components.

Version 7.2.13¶

Released December 2024

Community Features¶

Common¶

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

Kafka¶

PR-1505 - [MINOR]: Fix version check in util.py
PR-1491 - [3.2] Update jetty to 9.4.56.v20240826
PR-1477 - Added commonsIo to libs variable.
PR-1462 - Bump commonsIo to version 2.16.0 in 3.2
e146083b - Ignore failing quota_test
PR-1437 - disable flakey test

ksqlDB¶

bb335fa1 - nit
PR-157 - Remove KSQL internal topics from the list topic results. Sort the top
PR-156 - improve test coverage for cli
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-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-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-3244 - Handle 401/403 errors appropriately
PR-3256 - adding cp jar build CI gating block (#38)

Version 7.2.12¶

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-1388 - 3.2 fixed downstream trigger

ksqlDB¶

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

REST Proxy¶

Schema Registry¶

PR-3235 - Fix Pint Merge Error

Version 7.2.11¶

Released June 2024

Community Features¶

Common¶

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

Kafka¶

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

ksqlDB¶

4781375c - Update ref to confluent-packaging-tools
e12817d4 - [skip ci] Copy CODEOWNERS from the default branch
d5a611b2 - [skip ci] Copy CODEOWNERS from the default branch
c0a5ceb7 - [skip ci] Copy CODEOWNERS from the default branch
24fb159d - [skip ci] Copy CODEOWNERS from the default branch
2edfb831 - [skip ci] Copy CODEOWNERS from the default branch
70b4d119 - [skip ci] Copy CODEOWNERS from the default branch
db68a852 - [skip ci] Copy CODEOWNERS from the default branch
22a7f2cc - [skip ci] Copy CODEOWNERS from the default branch
PR-10355 - MINOR: Update snapshot URLs.
PR-10328 - Fix for janino dependency.
PR-10321 - Check if directory exists before cleanup 7.2.x
PR-10312 - Migrate 7.2.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-10316 - Merge Conflict Resolution (from 7.1.x to 7.2.x)
PR-10304 - Update netty version to stable one
PR-10303 - Update netty version to stable one
PR-10294 - Update common version
PR-10365 - add cp-jar-build tasks when running pr workflows

REST Proxy¶

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

Schema Registry¶

b862eb19 - fix merge issue
6a9d6e22 - Fix Protobuf custom option for single-entry map
2d3c4736 - Revert “do not reinstantiate objectmapper as it’s expensive (#2686) (#2695)”
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
2c6c783c - Enhance Avro error with type name
fdc39bff - Fix handleDeleteSubject to pass right oldSchemaValue
PR-3110 - Revert jackson to 2.14.2
57308f0b - upgrade jackson package to fix build
c3520a33 - Removing /tmp/confluent as the DSTDIR check from Makefile
PR-3098 - Fix build due to Jackson upgrade to 2.16.2
af548bf0 - Update Apache commons-compress to 1.26.1
aab7e57f - Scrub Avro namespace when scrub.invalid.names=true
79947071 - Cache checkpoint for cacheInitialized before reader thread starts

Version 7.2.10¶

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 to address
4c8d3021 - update jetty to 9.4.54
PR-581 - fix: no implicit activation of docker-arm profile
PR-563 - added a new docker-arm profile to build docker containers in arm64

Kafka¶

PR-1124 - Update jose4j to 0.9.4 (#15284)
PR-1076 - Update jetty to 9.4.54.v20240208

ksqlDB¶

PR-10243 - Update Commons-Compress and commons-io
PR-10238 - Update apache.io.version
PR-10237 - Update commons-compress
PR-10223 - Change groupID to a more secure name
2f84873b - Change groupID to a more secure name
5612f336 - Increase execution time limit to 6 hours.
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.
PR-10189 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
PR-10175 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
PR-10178 - fix: configure KsqlBoundedMemoryConfigSetter in StandaloneExecutor mode
37e06168 - Fix the parent version in commons.
5467ea20 - set java version to 8
0a1cf171 - Increase the execution time limit.
db81cd09 - Fixed the extra args in service.yml file.

REST Proxy¶

PR-1235 - Deflake KafkaConsumerManagerTest.testBackoffMsControlsPollCalls test
PR-1236 - disable flakey test

Schema Registry¶

PR-3059 - fix: nested schemas were not considered in matching the correct Json Union schema
38e98145 - Handle nulls in enum in JSON Schema converter
PR-3038 - feat: Added ReferenceSchema support to allOf
ae0e3140 - fix: invalid behaviour for stringSchema in allOfToConnectSchema
6df56c8f - Optimization: remove known deps from ProtobufSchema
PR-3012 - Minor: Apply service bot changes to earlier branches
abbab267 - Ensure package change for Protobuf is incompatible
3bd1cdd5 - update common-compress
2ef767e3 - Fix merge issue for wire upgrade
7684230c - Update pom.xml
177af0d0 - Add Protobuf compat check for moving field into existing oneOf
bbe261f4 - exclude okio
PR-2943 - Update Bouncycastle dependencies
d08a0978 - fix NPE when value is nil when print.schema.ids=true is set
13848a40 - Improve the performance of invalid name scrubbing

Version 7.2.9¶

Released December 2023

Community Features¶

Common¶

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

Kafka¶

7c7cb939 - CONFLUENT: Bump ZK version to 3.8.3 for 7.2.x
PR-14497 - HOTIFX: fix Kafka versions for system tests (#14497)

REST Proxy¶

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

Schema Registry¶

98a1a4de - update swagger core
PR-2888 - Apply service bot changes to version branches
bafbad8c - DGS-9343 Allow removing enum in JSON Schema to be backward compatible
PR-2874 - DGS-9048: Semaphore Migration of Version Branches
899b38a2 - migrate to semaphore
7f7a7ab1 - add metrics-core to fix the build
d3b1912d - upgrade com.squareup.okio:okio to 3.4.0
c8ab3fd0 - Add log if encoding fails
d81d5a53 - Encode subject names for Maven download plugin
PR-2820 - Cache ProtobufSchema.toDynamicSchema calls (#2818)
PR-2816 - DGS-8960 Fix handling of diamond structure in Protobuf converter

Version 7.2.8¶

Released October 2023

Community Features¶

Common¶

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

Kafka¶

PR-971 - KSECURITY-2013: Upgraded Jetty to 9.4.53.v20231009 and Netty to 4.1.100.Final
PR-959 - KAFKA-15498: bump snappy-java version to 1.1.10.5 (#14434)

Schema Registry¶

PR-2790 - DGS-8088 Get the mode in scope rather that just for the subject

Version 7.2.7¶

Released September 2023

Community Features¶

Common¶

59440c88 - APPSEC-2855: add generation of SBOMs to maven based Java projects
27a3c1ca - APPSEC-2796: update guava

Kafka¶

PR-940 - KSECURITY-1789: upgrading requests to v2.31.0 (3.2)
PR-933 - KSECURITY-1859: updating netty to 4.1.96 (3.2)
PR-14082 - KAFKA-15102: Add replication.policy.internal.topic.separator.enabled property to MirrorMaker 2 (KIP-949) (#14082)

ksqlDB¶

PR-10065 - fix: import not picked back in fix
d3f0e149 - fix: fix compile error introduced by merge conflict resolution

REST Proxy¶

Schema Registry¶

PR-2734 - DGS-8112 Allow properties to be omitted during serialization
3f0e1198 - DGS-7927: update io.grpc_grpc-protobuf
PR-2695 - do not reinstantiate objectmapper as it’s expensive (#2686)

Version 7.2.6¶

Released June 2023

Community Features¶

Common¶

PR-530 - Backport log redactor to CP patches.
bd393b16 - AUDIT-1600: Updating logredactor version to 1.0.12
22a9da57 - APPSEC-2551: Update Prometheus JMX Exporter
5ad03d12 - APPSEC-2551: Update Jackson
PR-514 - Update snakeyaml
b4334b94 - pin jose4j version to match ce-kafka
95ed5124 - include snappy and jetty in the dependency management to match versions with ce-kafka, cleanup jackson imports

Kafka¶

PR-13602 - KAFKA-14869: Bump coordinator value records to flexible versions (KIP-915, Part-2) (#13526) (#13602)
PR-13598 - KAFKA-14869: Ignore unknown record types for coordinators (KIP-915, Part-1) (#13598)
d6285927 - KAFKA-14887: FinalizedFeatureChangeListener should not shut down when ZK session expires
PR-13499 - KAFKA-14880; TransactionMetadata with producer epoch -1 should be expirable (#13499)
PR-13445 - KAFKA-14843: Include Connect framework properties when retrieving connector config definitions (#13445)
PR-13148 - KAFKA-14645: Use plugin classloader when retrieving connector plugin config definitions (#13148)
PR-13386 - KAFKA-14809 Fix logging conditional on WorkerSourceTask (#13386)
PR-13273 - KAFKA-14731: Upgrade ZooKeeper to 3.6.4 (#13273)
PR-913 - KSECURITY-1627 KSECURITY-1556 KSECURITY-1568: update snappy, jetty, jose

ksqlDB¶

PR-9810 - Bump minimist and mkdirp
4ce2d5f3 - fix: Replace regex in CommandParser with a split by space
cc0501d8 - fix: Simplify regex in DdlDmlRequestValidators to avoid catastrophic backtracking
aefe6338 - Fix log4j-extensions
08853cd3 - Fix log4j-extensions

REST Proxy¶

ab17aa29 - Fix the overzealous conflict resolution
5be3406e - KREST-9942: Remove SnakeYaml from dependency management
a54dde7e - CNC-366: Update Jetty
PR-389 - Cherry pick KREST-1553 for duplicate log fix
PR-385 - Backport KREST-8335 to branch 7.2.x

Schema Registry¶

0f13c16e - fix checkstyle
20526ee5 - solve conflicts
e0626f64 - Update the test to make it clear to customer
dc6f2096 - update the doc
33659feb - Update schema-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaSchemaSerDeConfig.java
3ffd8fc7 - Update schema-serializer/src/main/java/io/confluent/kafka/serializers/AbstractKafkaSchemaSerDeConfig.java
1ca2a39d - Update the codes with checking string for http connect timeout
ffba37fe - * changed the config names
4c383ee4 - Apply suggestions from code review
7155f0fb - * checkstyle error
7e2dec9c - * removing unused import
9ab1b0ec - * adding defaults
01c6d7a7 - * Made SR client http connect and read timeout configurable.
89aa28be - * Made SR client http connect and read timeout configurable.
PR-2654 - DGS-7432 Fix ClassCastException when getting params option
18d69e07 - Fix merge issue
PR-2647 - DGS-7422 Optimization: omit compat check during IMPORT
PR-2642 - DGS-7367 Propagate error messages even if not JSON
PR-2616 - DGS-7005 Convert socket timeouts to RetriableException for converters
f45fe28e - DGS-6698: Remove SnakeYaml from the dependencyManagement
PR-2602 - DGS-6929 Ignore invalid Avro defaults for source connectors
PR-2590 - DGS-6701 Fix getSchemaById to match subject if passed
ed4ec914 - DGS-6698: Remove SnakeYaml from the dependencyManagement
PR-2589 - DGS-6613 Ignore invalid Avro defaults in Avro Converter
PR-2588 - DGS-6603 Fix default conversions in JsonSchemaConverter
PR-2693 - DGS-7746 Fix perf regression due to DGS-6331
PR-2684 - DGS-7675 Fix NPE when print.schema.ids=true
1bf961b7 - Update json-schema

Commercial Features¶

Confluent Server¶

KSECURITY-1568: Upgrading jose4j
KGLOBAL-2035: Unblock local follower fetch requests when records are appended to mirror leader logs
KDATA-737: Fix incorrectly exposed ccloud only configs on documentation
KSECURITY-1556: updated jetty version
KAFKA-14887: FinalizedFeatureChangeListener should not shut down when
KDATA-853: Upgrading dependencies
KSECURITY-1460, KSECURITY-1466: Updated snakeyaml, json-smart and nim
KSECURITY-1459: updated golang.org/x/net mod.
KSECURITY-1455: updated golang.org/x/text mod.
KSECURITY-1453: Updated version of golang.org/x/sys
KSECURITY-1462: Disabled colocated KRaft mode test.
KSTORAGE-2447: Disable ULE on tier topic, if tier topic already exists
KGLOBAL-3350 Add more logging for persistent connection creation in Outbound connection manager
KSECURITY-1627: Updated snappy-java
KSECURITY-1618: update guava version to 32.0.1-jre.
KAFKA-14887: FinalizedFeatureChangeListener should not shut down when ZK session expires

Security¶

CIAM-2998 - Log redactor backport for confluent-security-plugins
KREST-10128 Create LicenseManager instance in iteration run instead o

Secret Registry¶

unpin netty, as rest-utils brings updated version

Control Center¶

[MMA-13078] revisit session caching in basic auth
[MMA-13013] Add property to specify alias cert per component for Schema Registry, KSQL & Connect
[MMA-13089] Handle large message JSON on topic inspection
[MMA-13042] Fixing log statement for websocket time out
[MMA-13216] update jose4j
[MMA-13201] Csrf Enabled Flag not working

MQTT Proxy¶

CC-19108 | Rename isChannelClosed to isAuthenticated.
CC-19108 | Use an atomic reference to avoid publishing message when the channel is closed or marked for closure.

Metadata Service¶

CIAM-2936: update jose4j
Update pom.xml
CIAM-2986 - Older MDS builds are not running all the tests they should be
another attempt with mina-core
pin mina core in cli, scope mina-core as test in main pom
pin mina-core in testingLdap only
SEC-xyz: Update mina-core

Replicator¶

disable builds of connect-replicator version 5.5.x
used spotbugs version variable instead
use spotbugs annotations instead of findbugs
resolving compile issue
KGLOBAL-3224 removed find bugs usage
remove aws-maven plugin to unblock the downstream validation for common: RCCA-10412, APPSEC-2551

Version 7.2.5¶

Released March 2023

Community Features¶

Common¶

PR-512 - add snakeyaml to dependency management
7bcaab9e - Fix typo in with method calls
3868e27b - Fix typo
783c5721 - Return the original “version_range” if it isn’t an actual Maven version range
e71293e4 - Update logredactor depdendency to 1.0.11
PR-502 - fix: override maven version plugin’s default versionrange
9350d231 - Update resolver-maven-plugin to 0.6.0
PR-497 - Upgrade Netty to 4.1.86.Final
PR-496 - Bump to 7.4.4

Kafka¶

PR-13245 - KAFKA-14704; Follower should truncate before incrementing high watermark (#13245)
PR-872 - KC-2332: Upgrade netty to 4.1.86
PR-857 - CONFLUENT: Fix filter for not publishing streams upgrade test artifacts
PR-853 - CONFLUENT: Skip publishing for kafka-streams-upgrade-system-tests
PR-13000 - KAFKA-14496: Wrong Base64 encoder used by OIDC OAuthBearerLoginCallbackHandler (#13000)
PR-12935 - KAFKA-14432: RocksDBStore relies on finalizers to not leak memory (#12935)
PR-12909 - KAFKA-14422; Consumer rebalance stuck after new static member joins a group with members not supporting static members (#12909)
PR-12869 - KAFKA-14382: wait for current rebalance to complete before triggering followup (#12869)
PR-12809 - [KAFKA-14324] Upgrade RocksDB to 7.1.2 (#12809)
PR-12794 - Revert “KAFKA-13891: reset generation when syncgroup failed with REBALANCE_IN_PROGRESS (#12140)” (#12794)
PR-12140 - KAFKA-13891: reset generation when syncgroup failed with REBALANCE_IN_PROGRESS (#12140)
50029d3e - Bump version to 3.2.3

ksqlDB¶

PR-9821 - fix: migrations tool without basic auth works again
PR-9818 - fix: default to get authHeader if using basic
PR-9770 - Upgrade netty to 4.1.86 #2
PR-9717 - fix: change password-based configs to Type.PASSWORD

REST Proxy¶

69ed0cd9 - Remove incorrect synchronization
PR-1108 - Set kafka-schema-registry version in dependency mamanagement
7a7f5dcd - Remove unnecessary ${project.version} tag
PR-1102 - Fix transitive dependency of kafka-schema-registry
PR-1101 - Fix dependency org.yaml_snakeyaml, upgrade to fixed

Schema Registry¶

PR-2577 - DGS-6373 Ignore leading dot when merging Protobuf custom options
PR-2575 - DGS-6331 Handle javaType for oneOfs during JSON deserialization
PR-2568 - DGS-6306 Allow multiple oneofs in Protobuf converter
PR-2550 - DGS-6192 Include default ctx when using subjectPrefix w/wildcard ctx
PR-2540 - DGS-6075 : Add explicit definition of snakeyaml.
PR-2519 - DGS-6014 cherry pick Maven plugin enhancement to 5.5.x
PR-2514 - DGS-5950: Allow optional map key in Avro
PR-2474 - Fix handling of Protobuf repeated options
PR-2471 - Preserve metadata associated with primitive types during normalization
PR-2468 - DGS-5567 Handle Protobuf map options in toCanonicalString()

Commercial Features¶

Confluent Server¶

Backport “Minor: add logging to inLock / inWriteLock to catch leaked locks (#8594)” to 7.2.x
KMETA-478 Enable zk audit logs by default
fix version comparison in kafkatests (#8922)
KAFKA-14731: Upgrade ZooKeeper to 3.6.4 (#13273)
KSECURITY-1005: [7.2.x] Enforce kafka-client-plugins consumers to use the same snakeyaml version
cherrypick KAFKA-14417: Address incompatible error code returned by broker from`InitProducerId`
KSECURITY-897: Make expiration timeout for ZK ACL change notification path configurable
KENGINE-287: RPCProducerIdManager should not wait on new block
KC-2328: Update yaml.v2 to 2.2.4
KSECURITY-953: Update azure-identity to 1.7.3
KSECURITY-965: Update git version 1.13.0
KSECURITY-981: Add FeatureZNode zk node path to secure root paths
KC-2333: Update io.netty libraries to 4.1.86.Final
CPKAFKA-3875: Support reading I/O metrics from /proc/self/io
KSTORAGE-82: Tiered storage topic deletion support
MINOR: disable use of ConfluentLeaderAndIsrRequest in 5.4.x
[KENGINE-314]: Fix a NPE when FetchSession close.
KAFKA-9038: [WIP] Allow creating partitions for topics partitions not in reassignment
CONFLUENT: Use single audit log provider for MDS and its hosting broker
CPKAFKA-3830: Include observer information in MetadataResponse
Bump version to 3.2.3

Security¶

Removed From Supported Operations to follow RBAC Rules
Added fix for unit test
Fixed import
Changed the design of RBAC for Exporters
Removed extra line changes
Added RBAC for Schema linking Phase 1
Remove logging statement
SEC-5350: Update netty-codec-http to 4.1.86.Final

Secret Registry¶

Remove unused variables
Update RestService.java

Control Center¶

Update docker image tag for integration-test
Use docker image tag 7.1.6
Increase wait start time for control center in test
Make sure control center stop properly
Change PORT to avoid conflict with TelemetryReporterIntegrationTest
Change to make this compatible with 6.2.x
KC-2261 timeout websocket connection via jwt token
Update CODEOWNERS to match latest definition from master
MMA-13013: Override SSL Stores priority
Refactoring- made code more functional and improved readability.
Updated NotFoundException message in scenario where topicName provided returns 0 no consumergroupdata.
Updated code based on PR feedback.
Updated consumerGroupId API to also support topicName queryParam.
Improving test cases with scenarios of single consumergroup covering multiple topics. 2. updated consumerGroupId to not support topicName queryParam, it is not required.
Adding unit test for CachedConsumerOffsetsResource
Adding support for topicName in query param to return only consumer groups for that topic
Pin bc-fips version correctly
[MMA-12439] Update Websocket configuration for Control-Center if BasePath supplied
reading password using getPassword instead of getString, this fixes the casting exception
Adding a config to force armeria health check to use HTTP1
Fixing failing test case, due to merge issue
Fixing check style error, removing unused import
renaming Health_check to health check
MMA-12911: Propagate numPartitions and replication factor from CreateTopicsResult
MMA-12912: Disable offset commits, don’t supply group ID
adding config based functionality to force http1 for armeria health checks
MINOR: Update repo to use mvn-wrapper to speed up builds
[MMA-12804] Re-enable failing tests in SslUtilsTest
Fix codeowners to make c3 default ownens as well
Cherry pick 7746 codewoner

MQTT Proxy¶

Remove the pin of netty version to use the (current) version defined in common

Metadata Service¶

Clean testng
[Fix build] Drop down to testNG 7.5 - which is the last version to support jdk8
Adapt 7.1.x to testNg 7
Clean up surefire
CIAM-2615 - Bump TestNG to 7.7.0
Fix notnull in 7.1.x
Fix NotNull import
Squashed ‘mk-include/’ content from commit 7df56b0fff
Revert “Merge remote-tracking branch ‘origin/7.1.x’ into 7.2.x”
Squashed ‘mk-include/’ content from commit 7df56b0fff
CIAM-2579: update pgsql
CIAM-2570: Backport CIAM-2183 fix to 7.2.x
CIAM-2577: Turned off test RbacExtractorMetricsTest
Increase buffer size for Proxy Servlet

Replicator¶

Fixed deprecated method usage
Changed to 5 sec to honor TASK_SHUTDOWN_GRACEFUL_TIMEOUT_MS_CONFIG
Changed default to 120 sec to match topic config sync
KGLOBAL-3060 added consumer poll timeout ms property

Version 7.2.4¶

Released February 2023

Commercial Features¶

Security¶

Security Fixes
Removed bcfips from common
Pin bouncycastle fips dependency in confluent-security-plugins
Exclude bcpkix-jdk15on as compile dep and add as test dependency

Secret Registry¶

Exclude Non-FIPS dep and use bc-fips dependency

Version 7.2.3¶

Released December 2022

Community Features¶

Common¶

PR-492 - APIF-3112: Upgrade jmx_prometheus_javaagent to 0.17.2.
f5764727 - Merge conflict resolution.
PR-489 - APIF-3117: Upgrade scala to 2.13.10.
PR-485 - APIF-2957: Upgrade Jackson and Protobuf versions.

Kafka¶

PR-845 - CONFLUENT: Skip publishing for projects with no scala suffix when the scala version is not the default
PR-842 - DP-9030: Use the new withGradleFile closure
PR-831 - KSECURITY-792: Upgrade from Scala 2.13.8 to 2.13.10
PR-817 - KSECURITY-788: Upgrade jackson-databind version to 2.13.4.2
110bc014 - Merged remote trancking branch into 3.2-sync-upstream-4-nov-2022
PR-801 - KAFKA-13778: Fetch from follower should never run the preferred read replica selection (3.2)

ksqlDB¶

PR-9713 - Bump netty tcnative version to 2.0.54.Final
PR-9708 - APIF-3117: Unpin scala version.
PR-9697 - APIF-3122: Unpin Protobuf version.

REST Proxy¶

PR-1072 - KREST-7107 Shouldn’t provide overly detailed info or stack traces in responses -

Schema Registry¶

PR-2460 - DGS-5544 Support nulls when using optional fields in proto2
PR-2459 - DGS-5400 Support subjectPrefix containing wildcard context and subject
PR-2450 - Pin Snakeyaml version
PR-2443 - DGS-5423 Check subject when looking up ID across contexts
PR-2440 - Update the Snakeyaml dependency
8e5ce168 - Unpin Protobuf version.
PR-2414 - DGS-5253 Handle cycles when resolving references
PR-2405 - DGS-4754 Handle empty record default at field level
PR-2399 - DGS-5084 Ignore compat check in IMPORT mode
PR-2395 - DGS-4971 Handle map types with enhanced.protobuf.schema.support

Commercial Features¶

Confluent Server¶

CONFLUENT: Skip publishing for projects with no scala suffix when the scala version is not the default
DP-9030 - Switch to codeartifact repo
Increase vagrant aws timeout for system test
BouncyCastle Issue fix for Connect service [7.2.x]
KSECURITY-792: Upgrade from Scala 2.13.8 to 2.13.10
CPKAFKA-3723: Message changes to add observer tagged field
KSECURITY-788: Upgrade jackson-databind version to 2.13.4.2
Merged remote trancking branch into 3.2-sync-upstream-4-nov-2022
KSECURITY-789: Upgrade to snakeyaml version 1.32
CIAM-2424 - Name RestClient threads for stackdump identification (#7887)
KSECURITY-794: Upgrade to protobuf version 3.19.6
KSTORAGE-2249: update MergedLog.read to throw NotLeaderOrFollowerExce
KGLOBAL-1812: Fix thread leak in cluster linking test. (#7188)
MINOR. Remove call to java static interface method in scala
CIAM-2304: Add SecurityMetadata:Describe to SecurityAdmin
RCCA-8564: log a warning if LDAP login fails becuase of network issues
CIAM-2290: Upgrade bc fips drivers

Security¶

Exclude bcpkix-jdk15on as compile dep and add as test dependency
Pin bc-nonfips dep as a test dependency
Pin bouncycastle fips dependency in confluent-security-plugins
Removed bcfips from common
excluded bcfips jars
AUTHN-1087: Explicit define netty versions in kafka-rest plugin
AUTHN-1087: [7.0.x only] Enforce Netty versions in kafka-rest plugin
AUTHN-1087: Upgrade vertx to 3.9.14
AUTHN-1087: Upgrade vertx to 3.9.14
AUTHN-1087: Upgrade vertx to 3.9.14
AUTHN-1087: Upgrade vertx to 3.9.14
AUTHN-1087: Upgrade vertx to 3.9.14
AUTHN-1087: Upgrade vertx to 3.9.14
AUTHN-1325: Update bc-fips version to 1.0.2.3
fixed checkstyle error
Requesting permission only for Subject Read operation instead of any of the subject operation in case of GET /schemas

Secret Registry¶

Exclude Non-FIPS dep and use bc-fips dependency

Control Center¶

RCCA-7746: CCloud RBAC user unable to view messages from UI
MMA-9023: memory bounding for streams applications [5.4.x, master]
Revert “MMA-12206 upgrade io.netty:netty-codec-http”

MQTT Proxy¶

Fixing the tests and config validator, to incorporate new changes in validation of MqttDecoder brought in by netty upgrade
Upgrading netty

Metadata Service¶

APIF-3122: Unpin protobuf version.
MMA-12624 Fix testng dependencies
CIAM-2392 Bump PSQL Version
Remove spaces
Add back newline
Implement writeTransactionMarkers in DelegateConfluentAdmin
CIAM-2304: Add unit tests for SecurityAdmin

Replicator¶

KGLOBAL-2436: Don’t seek to beginning on pause for schema translator
REPL-2055-: Log WakeupException at debug level
RCCA-7678: Reverse proxy header check added

Version 7.2.2¶

Released August 2022

Community Features¶

Common¶

aeca780b - Update Jolokia version in pom.xml
PR-472 - Upgrade Netty to 4.1.79.Final
PR-468 - Fix dependency in disk-usage-agent [6.2 and 7.0]
PR-464 - :Migrate from confluent-log4j to reload4j [5.4.x – 7.0.x]
PR-465 - Confluent log4j to reload4j [7.1.x Only]
PR-467 - Upgrade JUNIT in 5.4.x only

Kafka¶

a9b49f40 - Remove unused import
PR-12626 - KAFKA-14208; Do not raise wakeup in consumer during asynchronous offset commits (#12626)
PR-12603 - KAFKA-14196; Do not continue fetching partitions awaiting auto-commit prior to revocation (#12603)
d695a90f - Bump version to 3.2.2
PR-12376 - Upgrade Netty and Jackson versions[KAFKA-14044] (#12376)
PR-12584 - KAFKA-14194: Fix NPE in Cluster.nodeIfOnline (#12584)
PR-12063 - KAFKA-13835: Fix two bugs related to dynamic broker configs in KRaft (#12063)
PR-12440 - KAFKA-14107: Upgrade Jetty version (#12440)
PR-12483 - KAFKA-14136 Generate ConfigRecord for brokers even if the value is unchanged (#12483)
PR-12455 - KAFKA-14111 Fix sensitive dynamic broker configs in KRaft (#12455)
b172a0a9 - Bump version to 3.2.1
PR-12417 - KAFKA-13917: Avoid calling lookupCoordinator() in tight loop (#12417)
PR-12349 - KAFKA-14024: Consumer keeps Commit offset in onJoinPrepare in Cooperative rebalance (#12349)
PR-12421 - Revert “KAFKA-12887 Skip some RuntimeExceptions from exception handler (#11228)” (#12421)
PR-12412 - KAFKA-14079 - Ack failed records in WorkerSourceTask when error tolerance is ALL (#12412)
PR-12405 - KAFKA-13572 Fix negative preferred replica imbalanced count metric (#12405)
PR-12398 - KAFKA-14062: OAuth client token refresh fails with SASL extensions (#12398)
PR-12388 - KAFKA-14013: Limit the length of the reason field sent on the wire (#12388)
PR-12390 - KAFKA-14055; Txn markers should not be removed by matching records in the offset map (#12390)
PR-12381 - KAFKA-13474: Allow reconfiguration of SSL certs for broker to controller connection (#12381)
PR-12371 - KAFKA-14035; Fix NPE in SnapshottableHashTable::mergeFrom() (#12371)
PR-12362 - KAFKA-14010: AlterPartition request won’t retry when receiving retriable error (#12362)
PR-12298 - KAFKA-13998: JoinGroupRequestData ‘reason’ can be too large (#12298)
PR-12136 - KAFKA-13773: catch kafkaStorageException to avoid broker shutdown directly (#12136)
PR-12106 - KAFKA-13861; Fix the validateOnly behavior for CreatePartitions requests in KRaft mode (#12106)
38103ffa - Bump version to 3.2.0
PR-794 - Upgrade Jetty to 9.4.48.v20220622
PR-774 - migrating log4j12 to reload4j, slf4j-log4j12 to slf4j-reload4j.jar (3.2)
3bf3480d - upgrading netty to v4.1.79.Final (3.2) #755

ksqlDB¶

PR-9337 - bugfix: remove log4j from the classpath (#9334)
PR-9334 - bugfix: remove log4j from the classpath

REST Proxy¶

PR-1049 - APIF-2714: Migrate from confluent-log4j to slf4j-reload4j.
PR-1047 - Migrate from confluent-log4j to slf4j-reload4j.
PR-1044 - APIF-2768: Workaround for “Failed to bind to 0.0.0.0/0.0.0.0:9998” error.
PR-350 - Cherry-pick https://github.com/confluentinc/rest-utils/pull/349 to 5.4.x
3d1250af - APIF-2739: Upgrade Jetty to 9.4.48.v20220622.
d93674fb - Do not create a new sensor for error count
88556559 - Set sensors to be expired in 1 hr
ff3595a0 - DGS-4220: fix request tag based metrics
PR-320 - APIF-2714: Switch from confluent-log4j to reload4j (5.4.x)
PR-329 - APIF-2705: Update jersey version to 2.36.

Schema Registry¶

PR-2381 - Adding timer in onJoinPrepare
PR-2376 - DGS-4768 Fix reserved ranges for Protobuf enums
2fd5e6e9 - Remove deprecated methods in SchemaRegistryMetric
PR-2359 - DGS-4395 Fix message indexes of normalized Protobuf with map
PR-2351 - DGS-4358 Fix NPE in Protobuf converter for null map value
0577dffb - Add comments
042d3e3c - DGS-4303: Support different stat types in SchemaRegistryMetric
PR-2346 - Optimize sync call
PR-2345 - Add leader change listeners
PR-2342 - APIF-2714: Migrate from confluent-log4j to slf4j-reload4j.
PR-2339 - APIF-2714: Migrate from confluent-log4j to slf4j-reload4j.
PR-2336 - DGS-4249 Fix name resolution during Protobuf normalization

Commercial Features¶

Confluent Server¶

KAFKA-13861; Fix the validateOnly behavior for CreatePartitions requests in KRaft mode (#12106)
KAFKA-13778: Fetch from follower should never run the preferred read replica selection (7.2.x)
cherry-pick KGLOBAL-2127:72723ca0606d24a3894b58d4fad3eace9b0a07a0 to 7.2.x
Remove unused import
KENGINE-212: batch transaction requests.
KENGINE-211: Add a metric to record the avg latency for a transaction to transit from PreCommit to Commit.
Bump version to 3.2.2
Don’t include Server info as an HTTP response header in the Connect REST API (#7264)
KGLOBAL-1803 reset lastCaughtupTime when mirror leader appends to its log
Update log level in RestClient
MINOR: Follower delayed fetch request should not be recorded for consumer fetch lag
Add Telemetry MetricsReporter Http Exporter stats
upgrading netty to v4.1.79.Final (3.2) #755
Bump version to 3.2.1
MINOR. Remove keyword args and use positional argument
Bump version to 3.2.0
Add direct dependency on com.squareup.okhttp3.okhttp 4.9.3
KAFKA-14107: Upgrade Jetty version.
Migrating log4j12 to reload4j, slf4j-log4j12 to slf4j-reload4j.jar (7.2.x) #7066
Avoid sending partial updates during LDAP group manager startup
Fix exception handling in RBAC writer coordinator (#6576)
Upgrading google-cloud-storage to v2.6.1 (7.2.x)
Upgrading netty version to 4.1.79.Final (backport 7.2.x)
Upgrading aws-java-sdk-s3 to v1.12.268 (7.2.x)
Cherry pick KAFKA-13474 on master to 7.2.x
KGLOBAL-1724: Wrong source topic name in DescribeMirrorsResponse. (#6

Security¶

add auth token provider to ksql security extensions
revert pom
add auth token provider to ksql security extensions
AUTHN-1085: Fix NPE in debug log
APIF-2714: Migrate from confluent-log4j to slf4j-reload4j.

Secret Registry¶

Migrate from log4j to reload4j for connect-plugin
CC-17641,CC-17644 Bump jetty version
APIF-2714: Migrate from confluent-log4j to slf4j-reload4j.

Control Center¶

MMA-12388: Upgrade okhttp
MMA-12201 Fix the mistake in resolving merge conflict
MMA-12201 remove slf4j from transitive deps
MMA-12206 upgrade transitive dependency of netty
MMA-11617: allow for trailing slash in path
MMA-12206 upgrade io.netty:netty-codec-http
MMA-12201 Exclude slf4j in transitive dependency
MMA-8781: Respect SR Config and handle nulls in CachingSchemaRegistryClientSupplier
MMA-12201: Use reload4j version properties from common
MMA-12201 Add logredactor [7.1.x]
MMA-8781: Respect SR Config and handle nulls in CachingSchemaRegistryClientSupplier
MMA-12201 Replace log4j with reload-4j
MMA-12127: Change type from String to Password for CONTROL_CENTER_EMAIL_PASSWORD

MQTT Proxy¶

CC-17620: remove dependency on slf4j-log4j12 and confluent-log4j

Metadata Service¶

Remove unnecessary dep on noop logger
fix pass
CIAM-2097 DB Password config should be password type
CIAM-2164 - Migrate from confluent-log4j to reload4j for MDS

Replicator¶

KGLOBAL-2126 seek to begining only for non empty partitions list
Add log redactor.
Migrate confluent-log4j to reload4j.

Version 7.2.1¶

Released July 2022

Community Features¶

ksqlDB¶

PR-9260 - fix: Excludes Guava from Guava-retrying in order to manage Guava depe
617df451 - merge conflicts
4ef7a1df - merge conflicts

Schema Registry¶

PR-2331 - DGS-4172 Bound size of Avro datumReader/Writer caches
PR-2329 - DGS-4163 Pass topic to schema formatters
PR-2328 - DGS-4162 Handle refs at different levels in Protobuf converter
c4c0b7f7 - Fix merge issue
PR-2327 - DGS-1648 Allow Protobuf msg fullname to be passed for console producer

Commercial Features¶

Confluent Server¶

AUTHN-739: Oauth token refresh causes kafka client authentication to fail

Version 7.2.0¶

Released May 2022

Community Features¶

Common¶

Upgrading gson
PR-456 - DGS-3674 Upgrade gson to 2.8.6
PR-451 - Remove confluent-log4j
PR-450 - Add reload4j definition
PR-446 - Upgrade jackson related packages
6170c767 - Upgrade maven-surefire-plugin version to 3.0.0-M6
5a8b2e2c - Change back powermock 2.0.9 due to manual merge
PR-445 - Unify protocol buffer version.
PR-436 - deprecate common-metrics
PR-393 - chore: update mockito to last available 3.x version
PR-425 - chore: update spotbugs to 4.5.3
PR-429 - import junit-bom to align junit dependencies, update to 3.8.2
PR-400 - Bump confluent-log4j to 1.2.17-cp6
PR-396 - Bump confluent-log4j version 1.2.17-cp5
PR-394 - Add Support to Split Up Integration Tests for Junit5
PR-385 - Bump junit 4 version to latest version (4.13.2)

Kafka¶

PR-710 - KSECURITY-220: Update jackson packages to 2.13.2
PR-12096 - KAFKA-13794: Fix comparator of inflightBatchesBySequence in TransactionsManager (round 3) (#12096)
PR-12064 - KAFKA-12841: Remove an additional call of onAcknowledgement (#12064)
PR-12055 - [MINOR] Update upgrade documentation for 3.2 (#12055)
PR-12018 - KAFKA-13542: Add rebalance reason in Kafka Streams (#12018)
PR-12043 - KAFKA-13828; Ensure reasons sent by the consumer are small (#12043)
PR-11948 - KAFKA-10405: Set purge interval explicitly in PurgeRepartitionTopicIntegrationTest (#11948)
PR-11939 - KAFKA-13761: KafkaLog4jAppender deadlocks when idempotence is enabled (#11939)
PR-12006 - KAFKA-13794: Follow up to fix producer batch comparator (#12006)
PR-11995 - KAFKA-13782; Ensure correct partition added to txn after abort on full batch (#11995)
PR-11991 - KAFKA-13794; Fix comparator of inflightBatchesBySequence in TransactionManager (#11991)
baf8976f - Add muckrake mapping for 7.2 release
PR-11928 - fix: make sliding window works without grace period (#kafka-13739) (#11928)
PR-11953 - KAFKA-13772: Partitions are not correctly re-partitioned when the fetcher thread pool is resized (#11953)
PR-11971 - KAFKA-13783; Remove reason prefixing in JoinGroupRequest and LeaveGroupRequest (#11971)
f96b0211 - Revert “KAFKA-13598: enable idempotence producer by default and validate the configs (#11691)”
63b76b81 - Revert “:KAFKA-13673: disable idempotence when config conflicts (#11788)”
PR-11908 - KAFKA-13748: Do not include file stream connectors in Connect’s CLASSPATH and plugin.path by default (#11908)
PR-11743 - KAFKA-13660: Switch log4j12 to reload4j (#11743)
PR-11962 - KAFKA-13775: Upgrade jackson-databind to 2.12.6.1 (#11962)
PR-11967 - Upgrade RocksDB from 6.27.3 to 6.29.4.1 (#11967)
PR-11869 - KAFKA-13719: Fix connector restart cause duplicate tasks (#11869)
PR-11966 - KAFKA-13418: Support key updates with TLS 1.3 (#11966)
PR-11923 - KAFKA-6718: Add documentation for KIP-708 (#11923)
PR-11942 - KAFKA-13767; Fetch from consumers should return immediately when preferred read replica is defined by the leader (#11942)
PR-11760 - KAFKA-13600: Kafka Streams - Fall back to most caught up client if no caught up clients exist (#11760)
PR-11946 - KAFKA-13770: Restore compatibility with KafkaBasedLog using older Kafka brokers (#11946)
PR-11920 - KAFKA-13672: Race condition in DynamicBrokerConfig (#11920)
PR-11926 - KAFKA-13714: Fix cache flush position (#11926)
PR-11933 - KAFKA-13759: Disable idempotence by default in producers instantiated by Connect (#11933)
PR-11932 - Revert “KAFKA-7077: Use default producer settings in Connect Worker (#11475)” (#11932)
PR-11912 - KAFKA-13752: Uuid compare using equals in java (#11912)
PR-686 - KAFKA-6502: Update consumed offsets on corrupted records. (#11683)
PR-11898 - KAFKA-7540: commit offset sync before close (#11898)
PR-11879 - KAFKA-13728: fix PushHttpMetricsReporter no longer pushes metrics when network failure is recovered. (#11879)
PR-11893 - KAFKA-13682; KRaft Controller auto preferred leader election (#11893)
PR-11733 - KAFKA-13587; Implement leader recovery for KIP-704 (#11733)
PR-11903 - KAFKA-13497: Add trace logging to RegexRouter (#11903)
PR-11909 - KAFKA-13750; Client Compatability KafkaTest uses invalid idempotency configs (#11909)
PR-11173 - KAFKA-13509; Support max timestamp in GetOffsetShell (KIP-815) (#11173)
PR-11705 - KAFKA-9847: add config to set default store type (KIP-591) (#11705)
PR-11837 - KAFKA-6718 / Add rack awareness configurations to StreamsConfig (#11837)
PR-11901 - Don’t generate Uuid with a leading “-” (#11901)
PR-11897 - Polish Javadoc for EpochState (#11897)
PR-11610 - KAFKA-13549: Add repartition.purge.interval.ms (#11610)
PR-11891 - KAFKA-13727; Preserve txn markers after partial segment cleaning (#11891)
PR-11875 - KAFKA-13721: asymetric join-winodws should not emit spurious left/outer join results (#11875)
PR-11475 - KAFKA-7077: Use default producer settings in Connect Worker (#11475)
PR-11877 - KAKFA-13699: new ProcessorContext is missing methods (#11877)
PR-11817 - KAFKA-13438: Replace EasyMock and PowerMock with Mockito in WorkerTest (#11817)
PR-11802 - KIP-825: Part 1, add new RocksDBTimeOrderedWindowStore (#11802)
PR-10802 - KAFKA-6718: Update SubscriptionInfoData with clientTags (#10802)
PR-11873 - Revert “KAFKA-13542: add rebalance reason in Kafka Streams (#11804)” (#11873)
PR-11863 - KAFKA-13689: Revert AbstractConfig code changes (#11863)
PR-11864 - KAFKA-13717: skip coordinator lookup in commitOffsetsAsync if offsets is empty (#11864)
PR-11867 - KAFKA-12648: fix #getMinThreadVersion and include IOException + topologyName in StreamsException when topology dir cleanup fails (#11867)
PR-11872 - KAFKA-12879: Remove extra sleep (#11872)
PR-11871 - KAFKA-12879: Addendum to reduce flakiness of tests (#11871)
PR-11797 - KAFKA-12879: Revert changes from KAFKA-12339 and instead add retry capability to KafkaBasedLog (#11797)
PR-11722 - KAFKA-13630: Reduce amount of time that producer network thread holds batch queue lock (#11722)
PR-674 - KAFKA-12648: fix bug where thread is re-added to TopologyMetadata whe
PR-11857 - KAFKA-12648: fix bug where thread is re-added to TopologyMetadata when shutting down (#11857)
PR-11853 - KAFKA-13710: bring the InvalidTimestampException back for record error (#11853)
PR-11847 - KAFKA-12648: fix NPE due to race condtion between resetting offsets and removing a topology (#11847)
PR-11833 - KAFKA-13671: Add ppc64le build stage (#11833)
PR-11493 - KAFKA-12959: Distribute standby and active tasks across threads to better balance load between threads (#11493)
PR-11800 - KAFKA-13689: printing unused and unknown logs separately (#11800)
PR-11830 - KAFKA-13694: Log more specific information when the verification record fails on brokers. (#11830)
PR-11813 - KAFKA-12648: fix #add/removeNamedTopology blocking behavior when app is in CREATED (#11813)
PR-11839 - KAFKA-13706: Remove closed connections from MockSelector.ready (#11839)
PR-11517 - KAFKA-13466: delete unused config batch.size in kafka-console-producer.sh (#11517)
PR-11788 - :KAFKA-13673: disable idempotence when config conflicts (#11788)
PR-11691 - KAFKA-13598: enable idempotence producer by default and validate the configs (#11691)
PR-11572 - KAFKA-13510: Connect APIs to list all connector plugins and retrieve their configs (#11572)
PR-11777 - KAFKA-10000: Add producer fencing API to admin client (KIP-618) (#11777)
PR-10851 - KAFKA-6718 / Rack aware standby task assignor (#10851)
PR-11812 - KAFKA-12738: address minor followup and consolidate integration tests of PR #11787 (#11812)
PR-7082 - KAFKA-8659: fix SetSchemaMetadata failing on null value and schema (#7082)
PR-11804 - KAFKA-13542: add rebalance reason in Kafka Streams (#11804)
PR-11807 - KAFKA-13698; KRaft authorizer should use host address instead of name (#11807)
PR-11810 - KAFKA-13281: allow #removeNamedTopology while in the CREATED state (#11810)
PR-11808 - KAFKA-13281: add API to expose current NamedTopology set (#11808)
8b12f346 - add getBrokerListStrFromServers() as a deprecated method to fix downstream validation
PR-11806 - KAFKA-13697; KRaft authorizer should support AclOperation.ALL (#11806)
PR-11801 - KAFKA-12738: send LeaveGroup request when thread dies to optimize replacement time (#11801)
PR-11787 - KAFKA-12738: track processing errors and implement constant-time task backoff (#11787)
PR-11499 - KAFKA-10199: Add interface for state updater (#11499)
PR-11774 - KAFKA-10000: Utils methods for overriding user-supplied properties and dealing with Enum types (#11774)
PR-11772 - KAFKA-10000: Add new metrics for source task transactions (#11772)
PR-11791 - KAFKA-13676: Commit successfully processed tasks on error (#11791)
PR-11575 - KAFKA-13511: Add support for different unix precisions in TimestampConverter SMT (#11575)
PR-11752 - KAFKA-13666 Don’t Only ignore test exceptions for windows OS for certain tests. (#11752)
PR-11753 - Add license header in suppressions.xml (#11753)
PR-11770 - KAFKA-13669; Demote empty offset commit messages for source tasks to DEBUG level (#11770)
PR-11750 - KAFKA-12648: avoid modifying state until NamedTopology has passed validation (#11750)
PR-11688 - KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814) (#11688)
PR-11534 - KAFKA-12939: After migrating processors, search the codebase for missed migrations (#11534)
PR-11745 - KAFKA-13661; Consistent permissions in KRaft for CreatePartitions API (#11745)
PR-11674 - KAFKA-13577: Replace easymock with mockito in kafka:core - part 3 (#11674)
PR-11333 - KAFKA-13306: Null connector config value passes validation, but fails creation (#11333)
PR-11558 - KAFKA-13323; Fixed variable name in KafkaConsumer (#11558)
PR-11655 - KAFKA-13316; Enable KRaft mode in CreateTopics tests (#11655)
PR-11742 - KAFKA-13636: Fix for the group coordinator issue where the offsets are deleted for unstable groups (#11742)
PR-11673 - KAFKA-13577: Replace easymock with mockito in kafka:core - part 2 (#11673)
PR-11649 - KAFKA-13646; Implement KIP-801: KRaft authorizer (#11649)
PR-11672 - KAFKA-13577: Replace easymock with mockito in kafka:core - part 1 (#11672)
7c7282f0 - KC-1802: Workaround for init script issue affecting Gradle 7.1 and newer
PR-11340 - KAFKA-13310 : KafkaConsumer cannot jump out of the poll method, and the… (#11340)
PR-10525 - KAFKA-7572: Producer should not send requests with negative partition id (#10525)
PR-11631 - KAFKA-13563: clear FindCoordinatorFuture for non consumer group mode (#11631)
PR-11721 - KAFKA-13629: Use faster algorithm for ByteUtils sizeOfXxx algorithm (#11721)
PR-11726 - KAFKA-13637: Use default.api.timeout.ms as default timeout value for KafkaConsumer.endOffsets (#11726)
PR-11689 - KAFKA-12841: Fix producer callback handling when partition is missing (#11689)
PR-11656 - KAFKA-13579: Patch upgrade of netty/jetty/jackson (#11656)
PR-11725 - KAFKA-13221; Implement PartitionsWithLateTransactionsCount metric (#11725)
PR-11618 - KAFKA-13558: NioEchoServer fails to close resources (#11618)
PR-11717 - KAFKA-13619: Remove zookeeper.sync.time.ms (#11717)
PR-11690 - KAFKA-13599: Upgrade RocksDB to 6.27.3 (#11690)
67cf1876 - Revert “KAFKA-13152: Replace “buffered.records.per.partition” with “input.buffer.max.bytes” (#11424)”
PR-11695 - KAFKA-13595: Allow producing records with null fields in ConsoleProducer (#11695)
PR-11599 - KAFKA-13527: Add top-level error code field to DescribeLogDirsResponse (#11599)
PR-11424 - KAFKA-13152: Replace “buffered.records.per.partition” with “input.buffer.max.bytes” (#11424)
PR-11455 - KAFKA-13423: GlobalThread should not log ERROR on clean shutdown (#11455)
PR-11345 - KAFKA-13603: Allow the empty active segment to have missing offset index during recovery (#11345)
PR-11382 - KAFKA-13348: Allow Source Tasks to Handle Producer Exceptions (KIP-779) (#11382)
PR-11676 - KAFKA-13605: checkpoint position in state stores (#11676)
PR-11714 - KAFKA-13614: Don’t apply leader replication quota to consumer fetches (#11714)
PR-11715 - KAFKA-13618: Fix typo in BatchAccumulator (#11715)
PR-652 - KC-1933; Upgrade confluent-log4j to 1.2.17-cp8
PR-651 - KC-1933; Upgrade confluent-log4j to 1.2.17-cp8
PR-11682 - KAFKA-13524: Add IQv2 query handling to the caching layer (#11682)
PR-11508 - KAFKA-9279: Fail producer transactions for asynchronously-reported, synchronously-encountered ApiExceptions (#11508)
PR-11686 - KAFKA-12648: invoke exception handler for MissingSourceTopicException with named topologies (#11686)
PR-11609 - KAFKA-12648: fixes for query APIs with named topologies (#11609)
PR-11704 - KAFKA-13590:rename InternalTopologyBuilder#topicGroups (#11704)
PR-11657 - KAFKA-13552: Fix BROKER and BROKER_LOGGER in KRaft (#11657)
PR-11671 - KAFKA-13388; Kafka Producer nodes stuck in CHECKING_API_VERSIONS (#11671)
PR-11683 - KAFKA-6502: Update consumed offsets on corrupted records. (#11683)
PR-11452 - KAFKA-13412; Ensure initTransactions() safe for retry after timeout (#11452)
PR-11456 - KAFKA-13351: Add possibility to write kafka headers in Kafka Console Producer (KIP-798) (#11456)
PR-11600 - KAFKA-12648: handle MissingSourceTopicException for named topologies (#11600)
PR-11571 - KAFKA-13496: Add reason to LeaveGroupRequest (KIP-800) (#11571)
PR-11566 - KAFKA-13495: Add reason to JoinGroupRequest (KIP-800) (#11566)
PR-11560 - KAFKA-7589: Allow configuring network threads per listener (#11560)
PR-11664 - KAFKA-13582: TestVerifiableProducer.test_multiple_kraft_security_protocols fails (#11664)
PR-11593 - KAFKA-13528: KRaft RegisterBroker should validate that the cluster ID matches (#11593)
PR-11535 - KAFKA-13476: Increase resilience timestamp decoding Kafka Streams (#11535)
PR-11650 - KAFKA-13553: Add PAPI Window and Session store tests for IQv2 (#11650)
PR-11624 - KAFKA-13553: add PAPI KV store tests for IQv2 (#11624)
PR-11460 - KAFKA-13425: Optimization of KafkaConsumer#pause semantics (#11460)
PR-11567 - KAFKA-13494: WindowKeyQuery and WindowRangeQuery (#11567)
PR-11607 - KAFKA-13544: fix FinalizedFeatureChangeListener deadlock (#11607)
PR-11617 - KAFKA-13557: Remove swapResult from the public API (#11617)
PR-11582 - KAFKA-13525: Implement KeyQuery in Streams IQv2 (#11582)
PR-11408 - KAFKA-13374: Update doc to mention read from leader/followers (#11408)
PR-11605 - replace lastOption with exists (#11605)
PR-11451 - KAFKA-13419: Only reset generation ID when ILLEGAL_GENERATION error (#11451)
PR-11598 - KAFKA-13479: Implement range and scan queries (#11598)
PR-11552 - KAFKA-13488: Producer fails to recover if topic gets deleted midway (#11552)
PR-11597 - KAFKA-13539: Improve propagation and processing of SSL handshake failures (#11597)
PR-11581 - KAFKA-13522: add position tracking and bounding to IQv2 (#11581)
PR-11591 - KAFKA-12648: fix IllegalStateException in ClientState after removing topologies (#11591)
PR-11503 - KAFKA-13456; Tighten KRaft listener config checks/constraints (#11503)
PR-11577 - KAFKA-13515: Fix KRaft config validation issues (#11577)
f05a1797 - KAFKA-13512: Avoid duplicating maps in ZkMetadataCache topic accessors
PR-11573 - KAFKA-13507: GlobalProcessor ignores user specified names (#11573)
PR-11450 - KAFKA-13414: Replace Powermock/EasyMock by Mockito in connect.storage (#11450)
PR-11562 - KAFKA-12648: extend IQ APIs to work with named topologies (#11562)
PR-11046 - KAFKA-12980; Return empty record batch from Consumer::poll when position advances due to aborted transactions (#11046)
e1449994 - KAFKA-13512: Avoid duplicating maps in ZkMetadataCache topic accessors
PR-11513 - KAFKA-13506: Write and restore position to/from changelog (#11513)
PR-11496 - KAFKA-13454: Avoid duplicate config logging at startup (#11496)
f068a791 - KAFKA-13490: Fix createTopics and incrementalAlterConfigs for KRaft mode #11416
a957748d - KAFKA-13490: Fix createTopics and incrementalAlterConfigs for KRaft mode #11416
PR-11479 - KAFKA-12648: Make changing the named topologies have a blocking option (#11479)
PR-11557 - KAFKA-13491: IQv2 framework (#11557)
PR-11563 - KAFKA-13461: Don’t re-initialize ZK client session after auth failure if connection still alive (#11563)
PR-11541 - KAFKA-13498: track position in remaining state stores (#11541)
PR-11529 - KAFKA-12932: Interfaces for SnapshotReader and SnapshotWriter (#11529)
PR-11524 - KAFKA-13469: Block for in-flight record delivery before end-of-life source task offset commit (#11524)
PR-11526 - KAFKA-13472: Correct last-committed offsets tracking for sink tasks after partial revocation (#11526)
PR-11212 - KAFKA-13200: Fix MirrorMaker2 connector version (#11212)
PR-11538 - KAFKA-10712; Update release scripts to Python3 (#11538)
PR-11514 - KAFKA-13480: Track Position in KeyValue stores (#11514)
e8b53caa - KAFKA-13357; Store producer IDs in broker snapshots
PR-11431 - KAFKA-13397: MirrorMaker should not mirror topics ending with .internal (#11431)
PR-11504 - KAFKA-13457: SocketChannel in Acceptor#accept is not closed upon IOException (#11504)
PR-11481 - KAFKA-13117: migrate TupleForwarder and CacheFlushListener to new Record API (#11481)
PR-11500 - KAFKA-13455: Add steps to run Kafka Connect to quickstart (#11500)
PR-11422 - KAFKA-9648: Add configuration to adjust listen backlog size for Acceptor (KIP-764) (#11422)
PR-11459 - KAFKA-13394: Topic IDs should be removed from PartitionFetchState if they are no longer sent by the controller (#11459)
237dede9 - test
6d0e0828 - test
PR-11490 - KAFKA-13439: Deprecate eager rebalance protocol in kafka stream (#11490)
PR-11004 - KAFKA-12257; Consumer mishandles topics deleted and recreated with the same name (#11004)
PR-11484 - KAFKA-13443: Kafka broker exits when OAuth enabled and certain configuration not specified (#11484)
PR-11486 - KAFKA-13444: Fix OAuthCompatibilityTool help and add SSL options (#11486)
PR-11502 - KAFKA-13071; Deprecate support for changing acls through the authorizer (#11502)
PR-11498 - Add recordMetadata() to StateStoreContext (#11498)
3c2dab10 - Revert “MINOR: Remove redundant argument from TaskMetricsGroup#recordCommit (#9642)”
9ea9f0f8 - Revert “MINOR: Remove redundant argument from TaskMetricsGroup#recordCommit (#9642)”
PR-11505 - KAFKA-13449: Comment optimization for parameter log.cleaner.delete.retention.ms (#11505)
PR-11439 - KAFKA-13406: skip assignment validation for built-in cooperativeStickyAssignor (#11439)
PR-11487 - KAFKA-13445: Add ECDSA test for JWT validation (#11487)
PR-11448 - KAFKA-13417; Ensure dynamic reconfigurations set old config properly (#11448)
PR-11323 - KAFKA-12226: Commit source task offsets without blocking on batch delivery (#11323)
PR-11483 - KAFKA-13441: Fix typo in upgrade.html (#11483)
PR-11401 - KAFKA-13255: Use config.properties.exclude when mirroring topics (#11401)
PR-11489 - KAFKA-13446: Remove JWT access token from logs (#11489)
PR-11331 - KAFKA-13111: Re-evaluate Fetch Sessions when using topic IDs (#11331)
PR-11485 - KAFKA-13421; Reenable testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup (#11485)
PR-11415 - KAFKA-13429: ignore bin on new modules (#11415)
PR-11272 - KAFKA-12648: introduce TopologyConfig and TaskConfig for topology-level overrides (#11272)
PR-10563 - KAFKA-12487: Add support for cooperative consumer protocol with sink connectors (#10563)
PR-11412 - KAFKA-10543: Convert KTable joins to new PAPI (#11412)
PR-11429 - KAFKA-13396: Allow create topic without partition/replicaFactor (#11429)
PR-11463 - KAFKA-13430: Remove broker-wide quota properties from the documentation (#11463)
PR-11368 - KAFKA-13261: Add support for custom partitioners in foreign key joins (#11368)
PR-10678 - TRIVIAL: Fix type inconsistencies, unthrown exceptions, etc (#10678)
PR-11441 - KAFKA-8941: Add RocksDB Metrics that Could not be Added due to RocksD… (#11441)

ksqlDB¶

PR-9065 - Switch from confluent-log4j to reload4j
PR-9047 - fix: INSERT/VALUES on a stream with SCHEMA_ID/SCHEMA_FULL_NAME fails
PR-9038 - fix: INSERT fails when serializing Proto/Avro nested Structs
PR-9041 - build: exclude reload4j
PR-8933 - fix: Create stream fails when multiple Protobuf schema definitions exist
PR-8984 - fix: INSERT VALUES fail when SR schema has a non-default name
PR-9028 - fix: remove double quotes from json_records function
PR-8918 - fix: Guard null struct dereferencing inside function calls
PR-8947 - revert: consistency APIs
PR-8967 - fix: preserve old schema behavior for protobuf wrapped primitives (7.1.x)
PR-8968 - fix: preserve old schema behavior for protobuf wrapped primitives (7.0.x)
PR-8934 - fix: preserve old schema behavior for protobuf wrapped primitives
PR-8924 - feat: Support MIN/MAX udafs for Time/TS/Date types
PR-8935 - feat: clean up extra runtimes so the assignment is more focused
PR-8785 - feat: add java client support for push query v2 ALOS through continue method
PR-8845 - feat: Add support for Stream-Stream and Table-Table right join
PR-8936 - fix: clean up state when restarting runtimes to avoid errors
PR-8932 - fix: only make shared runtime that is chosen
PR-8920 - feat: add physical plan stubs for new query planner
PR-8776 - fix: Apply the ExtensionSecurityManager to UDAFs
PR-8901 - Support JDKs 11 & 17
PR-8876 - fix: resolve schema registry issue for pull query
PR-8909 - fix: re-oder cache usage error
PR-8868 - feat: add support for simple column name projection to new query planner
PR-8728 - fix: Fix bugs in sample standard deviation UDAF
PR-8902 - fix: empty to add future list
PR-8898 - fix: make sure topologies are done added before removing
PR-8892 - fix: CLI should return non-zero error code on failure
PR-8877 - feat: Generalize the UDAFs collect_list and collect_set
PR-8889 - fix: decrease default number of shared runtimes
PR-8862 - feat: add stubs for new query planner
PR-8871 - feat: Extend Udaf interface to allow for polymorphic UDAFs.
PR-8869 - fix: do not include schema id in session config
PR-8866 - build: pull from docker internal for onprem image
PR-8819 - fix: use blocking call and throw exception on failure
PR-8849 - fix: Ensures response end handler is invoked just once
PR-8857 - fix: clean up mistaken topic names
PR-8855 - fix(ksql): allow migrations tool to run connector commands with IF [NOT] EXISTS clauses
PR-8851 - fix(ksql): add ifExists/ifNotExist parameters to java client connector functions
PR-8850 - fix: Adds error handling for nested functions
PR-8844 - feat: allow users to specify custom migrations dir location
PR-8813 - Enable consistency mode by default
PR-8809 - feat: add rate-limiting to ksql command topic
PR-8779 - feat: add cleanup service metrics
PR-8765 - coerce property values to correct type
PR-8815 - feat: add consistency levels to clients
PR-8811 - fix: add copious amounts of logging to improve visibility into Gen 2 query’s runtimes
PR-8803 - fix: restore process fails due to DROP constraints
PR-8802 - fix: update restore command topic tool to work with command topic configs
PR-8742 - feat: create command topic with command topic configs
PR-8673 - feat: Use bounds in pull query
PR-8787 - feat: support custom request headers from java client and migrations tool
PR-8789 - fix: check for the queryId in the Task ID for registering saturation metric
PR-8782 - build: add staging s3 url for dependency jars
PR-8777 - fix: spotbugs warnings with Java 11
PR-8775 - fix: pass DCN_NULLPOINTER_EXCEPTION spotbugs error
PR-8769 - fix: always close validation runtimes even on an exception
PR-8761 - fix: reinstate the old KsqlRestClient.create overload
PR-8694 - feat: cleanup transient query resources
PR-8764 - fix: change conflicting metrics name that leads to infinite loop
PR-8755 - fix: various fixes for tracking shared runtime queries in validation
PR-8566 - fix: make writes to the backup file atomic
PR-8740 - fix: prevent hanging stream pull queries on truncated topics
PR-8739 - build: remove release related files from ksql
PR-8726 - fix: Add null handling to functions
PR-8612 - fix: Gives a query completed message for stream pull queries
PR-8734 - DOC fix: replaced old schema registry config with bootstrap servers
PR-8720 - fix: bug preventing decimals in (-1, 1) from being inserted / queried
PR-8722 - fix: only check configs on validation
PR-8713 - fix: when a isolated query is restarted then it should stay isolated
PR-8718 - feat: include checking the the config during validation of SET
PR-8711 - feat: allow for only Gen 1 create or replace queries with server level configs via rest api, bars all gen 2 queries
PR-8716 - fix: reorder imports
PR-8717 - fix: skip docker build for packaging
PR-8715 - fix: logging improvement
PR-8685 - fix: fix create connector config handling for name config
PR-8684 - feat: new CLI params to provide credentials for cloud connector management
PR-8614 - fix: register schema within sandbox
PR-8617 - feat: Return position from streams to client as consistency vector
PR-8710 - build: add docker plugin for release stabilization
PR-8704 - fix: recreating old queries in the old runtime will still use the old runtimes
PR-8671 - feat: remove old runtimes
PR-8692 - build: use pinned cp-base-new image
PR-8675 - fix: use topology-specific IQ APIs
PR-8670 - fix: error message for named topologies is different
PR-8668 - fix: keep shared runtime dirs even if no query has state
PR-8636 - docs: add missing environment variable in event-driven-microservice tutorial
PR-8667 - fix: don’t throw on drop
PR-8640 - fix: clean up custom prefixed internal topics
PR-8632 - feat: Add json_records, to_json_string, and json_concat UDFs
PR-8660 - fix: remove usages of internal Streams API/variable that was removed upstream
PR-8625 - fix: make tutorial work
PR-8644 - build: Update Git Commit Id plugin
PR-8603 - feat: add json_keys UDF
PR-8602 - feat: Add json_array_length UDF
PR-8635 - feat: allow custom connect auth header configuration
PR-8600 - feat: Add is_json_string UDF
PR-8597 - fix: pull queries are supported on source streams now.
PR-8607 - feat: uses internal topics prefix for shared runtimes
6c3320c6 - Revert “fix: back out post-3.1 changes to fix 7.1.x build (#8599)”
PR-8514 - fix: Streams overrides bugfix
PR-8590 - feat: Change API to return Position from Streams
PR-8593 - fix: Fixes an NPE which was causing terminate to fail
PR-8539 - fix: typo in TimestampExtractionPolicyFactory
PR-8565 - feat: [UIF-1113] Add weighting to search results based on domain
PR-8555 - Using IQv2 API for pull queries on window stores
PR-8570 - refactor: small IQv2 cleanup
PR-8553 - feat: add support for connect specific https configs
PR-8556 - feat: Use IQv2 when executing range and table scan pull queries
PR-8563 - feat: un-synchronize PullQueryQueue row queuing when limit absent
PR-8567 - fix: Make JaasPrincipal public
PR-8551 - fix: SandboxKafkaTopicClient should use default replication factor if applicable
PR-8559 - fix: Fix DROP STREAM IF EXISTS DELETE TOPIC
PR-8549 - feat: add max task usage and num stateful tasks metrics
PR-8547 - fix: variable substitution with CREATE CONNECTOR in migrations tool
PR-8544 - fix: make adding to pull query queue threadsafe
PR-8542 - fix: Allow disabling Scalable Push Query ALOS to be set via config

REST Proxy¶

PR-1021 - KREST-6139 Deflake produce rate limiter test
b22efb66 - Patch gson to be 2.9.0
PR-1016 - KREST-5096 Fix NPE in Topics Resource when no key, or no value specified
938cbdd6 - Fix log4j
PR-942 - Fix(#341): Remove deadlock when rebalancing by multiple consumer instances
PR-997 - KREST-4979 reverse order of produce global rate limiters
PR-994 - KEXP-280 new manager method to submit multiple ACLs for creation
PR-974 - Move ProducerMetrics to resources/v3.
PR-993 - KREST-3323 add global rate limiter for produce
PR-981 - KREST-4608 unflake consumergroup tests
PR-979 - KREST-4605 Deflake all the tests that extend AbstractConsumerTest
PR-977 - KREST-4577 Fix Metadata API Test
PR-972 - KREST-4466 Run tests individually and repeatedly
PR-973 - KREST-4356 Optimize CompletionExceptions when rate-limiting
PR-941 - Make ProduceRequest.getOriginalSize() non-optional.
PR-961 - KREST-3322 Remove grace period and swap out custom rate limiter
PR-964 - KREST-3660 Move to Junit5
PR-960 - KREST-3537: Fix HTTP 500 errors in Produce V3.
PR-955 - KREST-3636 all repos need a codeowners file - kafka-rest-eng set
PR-311 - APIF-2427: Switch from confluent-log4j to reload4j
PR-308 - KREST-3446 ensure there is always a minimum value for the thread pool queue
PR-309 - KREST-4958 Update codeowners to also include kafka-rest
PR-299 - KREST-3636 all repos need a codeowners file
PR-306 - KREST-3660 Remove junit 4 dependencies that come in via jersey test
05fbf52e - MMA-11468: Add option to enable nosniff protection
PR-303 - KREST-3660-Junit5-ify rest-utils
PR-300 - TRIVIAL: Change the Maven repository protocol: http → https
PR-293 - KREST-3148 enable ip based rate limiting

Schema Registry¶

PR-2307 - Change everit-json-schema coordinates to reflect artifact published o
PR-2306 - DGS-3783 Allow same schema w/diff ids during IMPORT
PR-2299 - DGS-3141 - adding new v1/metadata/version endpoint
PR-2294 - APPSEC-1156: Patch Gson to be 2.9.0
PR-2292 - DGS-3679 Allow unencrypted private keys when using PEM files
PR-2290 - DGS-3674 Upgrade to Protobuf 3.19.4
PR-2288 - DGS-3672 Allow CachedSchemaRegistryClient to register same schema
PR-2283 - DGS-3659 Handle null default in JSON Schema converter
PR-2282 - DGS-3654 Ensure isKey is passed in deserializers
PR-2275 - Migrate from confluent-log4j to reload4j
96471721 - Upgrade kotlin to 1.6.0
PR-2259 - Fix upgrade to Jackson 2.13
PR-2257 - DGS-3548 Optimize cache for JSON Schema converter
PR-2253 - DGS-3535: Remove enforcement of building with JDK8
PR-2241 - DGS-3484 Allow NaN when parsing JSON
PR-2223 - DGS-3342 Add reserved fields for Protobuf enums
PR-2227 - DGS-3417 Fix default value conversions in JsonSchemaConverter
PR-2221 - DGS-3329 Expose ObjectMapper to allow customizations
PR-2206 - Introduce Pull Request Reviewers
PR-2194 - Incorporated endpoint verification disable for schema registry client
PR-2196 - DGS-3087: Accommodate upstream change in AbstractCoordinator
PR-2176 - Added goal set-compatibility
PR-2177 - Adding new goal test-local-compatibility for schema registry maven plugin
PR-2178 - Downloading specific version of schemas capability added
PR-2188 - DGS-3087: Accommodate upstream change in AbstractCoordinator
PR-2170 - DGS-2975 Make register API 422 error code verbose
PR-2172 - DGS-2989 Update function return type due to changes in parent class
PR-2166 - DGS-2951 Make Register Api’s incompatibility error message verbose
PR-2153 - DGS-2871 Add API to delete Global-level compatibility setting
PR-2163 - DGS-2929 Optimising getLatestVersion implementation [skip secret scan]
PR-2149 - DGS-2672 Add generalized sum type support
PR-2136 - DGS-2750 Add API to SchemaRegistryClient interface to get deleted subjects and schemas
PR-2138 - DGS-2770 Allow Protobuf enums to be be converted to int32
PR-2132 - Upgrade json-schema to 1.14.0
PR-2062 - Configure Schema Registry Client [m]TLS using PEM
55dd7d94 - Added restriction for __GLOBAL subject
PR-2116 - Fix compile error from KAFKA-13456 fix: effectiveAdvertisedListeners
PR-2101 - feat: Update wire-schema version to 4.0.0
PR-2088 - Allow passing a specific class when creating a KafkaJsonSchemaSerde with a client (in tests)

Commercial Features¶

Confluent Server¶

Revert “CIAM-1419: Restructure DefaultAuthCache to lookup access rules for principal (#4758)”
Revert “CONFLUENT: Rename DataPlaneAuthCache class name to CloudAuthCache (#4885)”
KC-2144: Revert “AUTHN-280: Java client: implement async auth (#4659)”
KC-2202 Disable kraft cluster linking system tests 7 2
KGLOBAL-1394: Broker fails to start due to deleted cluster link (#6509)
KC-2202 Disable CL in KRaft mode for CP 7.2
KC-2223: Disallow enabling SBC with KRaft in CP 7.2 release
KC-2202; Disallow TS and KRaft in 7.2.x
build: kafka system tests should support larger EBS volumes for newer instances (#6371)
Upgrade Gson
CPKAFKA-7262: fully support 7.0 and 7.1 in upgrade, downgrade tests
Disable idempotent producer by default in Connect centralized licenses (#6193)
back port fix for scalabe restore test to 7.2.x
KAFKALESS-1047: Always acess SBC related Enums by name
KSECURITY-221: Update jackson packages to 2.13.2 version
Fix backward incompatibility issue in license store (#6152)
CONFLUENT: Record total usage for cluster link quota even if user quota not set
KGLOBAL-1297: Revert cluster link sync filter config validation changes
KSTORAGE-2163: regression in confluent.tier.local.hotset.ms dynamism (#6235)
AUDIT-1041: Add resource id to schema of audit log
KCFUN-411: Fix NaN error for Quota Calculation
KMETA-112; Retry ISR expansion after partition epoch updates
KSECURITY-195: Update org.jetbrains.kotlin packages to 1.6.0
KAFKA-13682; KRaft Controller auto preferred leader election (#11893)
CONFLUENT: Fix path to jolokia
[skip secret scan] KSTORAGE-2003: Lock contention causing producer latency during disk outage
Fix semaphore builds issue introduced by #5614
KPLATFORM-97: Update the jdk version to 17 [skip secret scan]
KAFKALESS-1021: Enable back BrokerFailureDetector#testPartialClusterFailure for KRaft
KAFKALESS-716: Add brokers in KRaft mode only if they’re empty (contain no replicas) [skip-secret-scan]
KSTORAGE-2039: disable durability audits for upgrade tests from versions < 7.1
KCFUN-379: remove principal quotas on empty message
KSTORAGE-2141: fix ExtendedOffsetMap.tombstoneCount
KGLOBAL-1389: Enable kraft mode in eligible tests in MultiTenantClusterLinkTest
KAFKALESS-1066: Log plans that are not improving cluster imbalance
KSTORAGE-2057: use default file deletion delay for compacted segments
KENGINE-164; Use estimated timestamp from broker in late transaction metric
KAFKALESS-811: Add implemention for triggerEvenClusterLoad Api in Kraft
MINOR: Enable rebalance_topic and remove_broker_command system tests
KAFKALESS-937: Update integration tests for KDBM methods onElection(), onResignation()
KGLOBAL-1393: Reduce the workload for CL soaked clusters
KSTORAGE-2055: improve logging in tier tasks
CIAM-1916 Operator should be Readonly
Add Trogdor Helm values for KCFUN soak
METRICS-4256 Factor out MetricCollectors naming conventions + improve collector memory usage
KGLOBAL-1211: Incorrect failed link count
KSTORAGE-2097: local vs. tier data validation in dual compaction mode
KSTORAGE-1821: Tiered transaction violation for exactly aborted batch where baseOffset and lastOffset = 0
KAFKA-13651; Add audit logging to StandardAuthorizer
[skip secret scan] KGLOBAL-1160: CreatePartitions API support for mirror topics in KRaft
KGLOBAL-1081: Fail mirroring if source leader epoch goes backwards
KGLOBAL-1364: Fix link coordinator integration test for KRaft
KGLOBAL-1291: Track public credential for reverse connections to handle API key delete
[skip secret scan] Expire quota consumptions if there is no report from a broker
KAFKALESS-1018: Don’t change RF when draining broker
Add low fluctuating bandwidth KCFUN workload
change brokerList to bootstrapServers() and refactor some create/delete code
KGLOBAL-1350: Enable ClusterLinkSyncIntegrationTest for KRaft and ZK mode
Fix a CL test that is failing on Scala 2.12
KAFKALESS-874: Port a set of broker removal integration tests to run in KRaft
KDATA-245 Improve exception handling for CLM object store calls
CONFLUENT: Make pid work with Java 17
Fix possible race in TopicBasedPhysicalClusterMetadataTest
KSECURITY-194: DataplaneAuthReader should complete startup after parsing ignored/errored Records
KAFKA-13743: Prevent topics with conflicting metrics names from being created in KRaft mode #11910
CIAM-1731: Added metric for missing organization Metadata in Auth Request [skip secret scan]
Add formatter for quotas topic
Add alternating KCFUN soak workload
KMETA-78; Return UNKNOWN_LEADER_EPOCH when follower is not recognized among the replica set
Update Docker Build Instructions [skip secret scan]
CONFLUENT: Add missing log argument in DataplaneAuthReader log
KCFUN-128: Adds a KafkaRequestHandlerBenchmark to benchmark KafkaRequestHandler.poll.
KCFUN-247: Create integration test for Dynamic quota pipeline
KSECURITY-36: Support ResourceIds in Describe ACL Requests
Add Linux CPU usage metric for the Kafka process [skip secret scan]
KCFUN-241: Read service account quotas from CDC internal topic
KCFUN-330: Update deactivated tenant status in the background
Mockito timeout() doesn’t work when mock is called from another thread
KGLOBAL-1365: Enable ClusterLinkIsrTest.testRestartPausedLink
KAFKALESS-1032: Use wall clock to prune task history
KCFUN-169: Fix incorrect metric
KGLOBAL-1369: Handle KafkaBroker shutdown and startup correctly in the cluster link tests.
KGLOBAL-1368: Use input param in verifyMarkReplicaThrottle when calling verify
[KSECURITY-71] Add support for AuditLog V2 schema. [skip secret scan]
KSECURITY-164: Support ResourceIds in Create ACL Requests
KSECURITY-138: Support for special principalType””UserV2:” in Kafka ACLs
Exclude iowait time from cpu busy time.
[skip secret scan] Enable KRaft mode for cluster link integration tests
KAFKALESS-969 Fix NPE in SystemTopicEvenDistributionGoal [skip secret scan]
KAFKALESS-928: KafkaServer should specify SBC bootstrap server under ZooKeeper [skip secret scan]
CPKAFKA-8405: fix leader fields parsing from describe_topic output in
Fix Scala 2.12 compatibility by using type parameter
KAFKALESS-1001: Propagate errors conditionally from BatchedConfigFetcher::getConfigs
KDATA-395 Make CLM minimum sleep time configurable
KAFKA-13577: Replace easymock with mockito in kafka:core - part 1 (#1
KSTORAGE-2107: add more transactions tests to TierCompactLogTest
KAFKA-13801: Kafka server does not respect MetricsReporter contract for dynamically configured reporters (#11998)
KSTORAGE-1946: Consume record timestamp in tier metadata
KDATA-242 KDATA-272 Address CLM scalability for large number of topics
KAFKA-13749: CreateTopics in KRaft must return configs (#11941).
KDATA-244 Handle exceptions for GCS list call response
KMETA-45; KRaft support for Confluent authorizer framework (including multi-tenant ACLs and RBAC) [skip secret scan]
Disabled testAutoMirroringNoOverlappingTopicFilters for kraft
KDATA-113: Add system test for scalable restore
KMETA-75; Do not reset replica state unless there is an epoch bump
KCFUN-355 Make enabling user quota dynamically configurable
KSTORAGE-1949: backfill stateChangeTimestamp when migrating state file
KCFUN-290: Publish Dynamic Quota to brokers [skip secret scan]
Use the non .sh script to start Kafka in Ducker and add missing CP versions
KSECURITY-7: Add request log filter for detailed audit log events
decouple KafkaMetricsCollector from MetricsReporter
KAFKALESS-1007: Wait for new topic metadata to be propagated to all brokes
KDATA-333: Add restore metrics tag
KSECURITY-141: Fix flakiness in metrics checks in ClusterLinkAclSyncIntegrationTest
KAFKALESS-832: Add preliminary check in CapacityGoal for ignored brokers over capacity
KC-1945: Allow SBC operations in the presence of exclusions [skip secret scan]
KSTORAGE-2030: remove segments that are tier compacted from local hotset
KGLOBAL-1208: Don’t do validation of configs when reading from persistent store
[skip secret scan] KCFUN-168: Add expiration thread for computed quotas
KGLOBAL-1022: Use link id in the request for source link creation in quorum controller.
Add muckrake mapping for 7.2 release
KGLOBAL-1235: Add records in the correct order while creating mirror topic
Grant ValidateConfig permission to ConnectorDeveloperRead role
KAFKALESS-872: Port replica replacement self healing test to support KRaft
KAFKALESS-998: Disable idempotence of all SBC used producers
KAFKALESS-872: Disable rebalance topic test for KRaft
KGLOBAL-887: Implementing KRaft integration test framework for some CL tests
KGLOBAL-1188 Ensure ReplicaManager see MirrorTopicChangeRecords
KAFKALESS-872: Port remove broker test to support KRaft
EVENTS-843: Disable idempotence in all KafkaExporters by default (#5987)
EVENTS-843: Disable idempotence in all KafkaExporters by default
KAFKA-13418: Support key updates with TLS 1.3 (#11966)
KAFKALESS-970 Fix computeBalanceUpperThresholdPercentage() to return values no greater than 1.0
KC-2136: Don’t include file-based login configs in broker’s dynamic config list
KGLOBAL-889: Support CL system tests with KRaft + ZK
Revert “AUTHN-280: Java client: implement async auth (#4659)”
KSTORAGE-2071: add dual compaction to log_compaction_test
Revert “KAFKA-13598: enable idempotence producer by default and validate the configs (#11691)”
Revert “:KAFKA-13673: disable idempotence when config conflicts (#11788)”
KENGINE-152: do not use idempotent producer for license log (#5971)
KSTORAGE-2056: Change suffix of tier compaction temporary files from .cleaned to .tiercleaned
KENGINE-152: do not use idempotent producer for license log
KGLOBAL-1191: Fix initialize code in ClusterLinkSyncAcls so we only set initialized to true if we successfully create and delete ACLs
KENGINE-14: enable consumer lag emitter for kraft
KSTORAGE-2068: Fix integration.kafka.tier.TierTopicManagerIntegrationTest.testTierTopicManager to run in KRaft mode
KAFKALESS-872: Port rebalance_topic_test to support KRaft
KAFKALESS-971 Fix computation of resources in ResourceDistributionGoal
KAFKALESS-915: Correct evaluation of expectedFinalClusterSize to fix testRemoveMultipleIncludingController
KGLOBAL-1187: Switch KafkaServerTestHarness (back) to non-concurrent start
KAFKALESS-865: Mechanism to clear SbcResourceManager resources.
KENGINE-57: Added auth latency and error metrics.
CONFLUENT: Fix AclCount metric for MultiTenantAuthorizer
KAFKALESS-982: Retry describeTopics in case of unknown partition exception due to race condition in metadata propagation in exclusion integration tests
KC-2102: Propagate exclusion information to SBC
KCFUN-291: Filter incoming LKC, ignore non-Kafka
CONFLUENT: Downgrade netty-tcnative to 2.0.46
KC-2059: Enable integration and system tests for broker replica exclusion in a KRaft Cluster
AUTHN-695: Add more debuggability for OAuth key resolver
KSTORAGE-1934: concurrent local and tier compaction
KGLOBAL-1197: Fixing IncrementalAlterConfigs to check for overlapping topic filters for cluster links
KGLOBAL-1204: Fix cluster linking metric names for consistency
KAFKALESS-814: Implement RemoveBroker/DescribeBrokerRemovals in KRaft
KAFKALESS-872: Port add_broker_test to support KRaft
KGLOBAL-1172: Add CL configs to ConfigSchema to be encrypted by MetadataControlManager
CC-16870: Set idempotence to false for Producers instantiated in Connect worker
CC-16870: Set idempotence to false for Producers instantiated in Connect worker
METRICS-4017 fix histogram/timer snapshot sum, add min
KAFKA-13761: KafkaLog4jAppender deadlocks when idempotence is enabled
KAFKA-13761: KafkaLog4jAppender deadlocks when idempotence is enabled
KGLOBAL-1198: Fix misleading message about recreating cluster link for dynamic configs
[KPLATFORM-89] creates ce-kafka-resources project
KAFKA-13750; Client Compatability KafkaTest uses invalid idempotency
KCFUN-331: Adding support for Client Quota to UpateDynamicQuotas.
Retry test failures for master branch
KGLOBAL-1182: Add metrics for each remote RPC call for cluster link periodic tasks
Broker Health State Changes
KSECURITY-35: Support ResourceIds in CreateACL/DeleteACL Request Handlers
KGLOBAL-973: Mirror topics API changes for KRaft
CCLOG-1485 Cleanup connect permissions, move ResourceOwner and DeveloperManage roles to connectv2 namespace
KGLOBAL-1187: Disable the testMirrorFailoverWhileSourceIsUnavailable
KAFKALESS-942: De-flake testOngoingBrokerAdditionRejectsTriggerEvenClusterLoadRequest
[skip secret scan] KCFUN-168: Recompute quotas when quota usages are reported
CPKAFKA-8201 Fix for regression in CLM system test due to addition of stateChangeTs to FTPS
KAFKA-13750; Client Compatability KafkaTest uses invalid idempotency
bugfix: return startZooKeeper ` as a deprecated proxy to `startQuorum
KGLOBAL-1184: Fix the ReverseConnectionRequestTest
KAFKALESS-921: Re-enable Thread Leak checking for all but SBC tests.
KC-2109: Introduce and use killBrokerById
KAFKALESS-764: Fallback to populating SBC internal listener from metadata log
KAFKALESS-852 – SbcEventQueue
KAFKALESS-920: Fix BalancerStatusTest in KRaft by matching returned Error instead of ApiError
KAFKALESS-900: Fix replication factor in BrokerFailureDetectorTest and use monotonic time
KC-1929: Convert SBC Integration tests to use KafkaServerTestHarness
bugfix: return startZookeeper as a deprecated proxy to startQuorum
KDATA-229: Add support for list and restore operations in Azure
KENGINE-139: do not synchronize when reporting fetch session cache metrics
KSTORAGE-2019: set enable.idempotence=false for TierTopic producer (#5833)
KMETA-27: Add KRaft support to the multitenant integration tests
CPKAFKA-8319: Update okio version to 3.0.0
KAFKA-13727; Preserve txn markers after partial segment cleaning (#11
CPKAFKA-8319: Update okio version to 3.0.0
KC-2088: Ensure MZ cluster availability when health check cannot reach brokers through load balancers due to a network issue.
MINOR: Revert “MINOR: temporary disable downstream validation”
KGLOBAL-1162: Disallow cluster link prefixing and acl syncing to be e
KAFKALESS-896 Enable ClusterModelPBTUtils to generate clusters with NEW brokers
[skip secret scan][Metrics-4078]add environment and cloud-cluster scoped MetricsViewer role
KAFKALESS-847 Exclusion-aware TopicReplicaDistributionGoal [skip secret scan]
KGLOBAL-1140: Filter out mirror topics from source cluster in ClusterLinkAutoMirroring when applicable
KENGINE-65: Add Metric for the total number of ACLs for a PKC
KDATA-346: Add flag to enable/disable deepOffsetScan
CIAM-1792 - Stream Lineage is available to new DataplaneRoles
[skip secret scan] KAFKALESS-846 Support exclusion in ResourceDistributionGoal
Handle KRaft cluster ID with leading minus sign
KAFKALESS-895 Part 1: ClusterModelPBTUtils able to create special states (IGNORED, DEAD) [skip secret scan]
KGLOBAL-997: Use AdminClient for mirror topic config sync
KAFKA-13435; Static membership protocol should let the leader skip assignment (KIP-814)
fix test that wasn’t testing anything
KAFKALESS-819: Log exact resource usage by hot partition #5847
KSTORAGE-1499: fix segment deletion before creation
KGLOBAL-974: Delete mirror topics support for cluster link in KRaft.
KDATA-340: Set Durability topic producer idempotence to false
KSTORAGE-1975 Remove unnecessary WrapIO
KDATA-273 CLM Maintain reference to latest instance of LifecycleManagerState
KSTORAGE-2019: set enable.idempotence=false for TierTopic producer
[skip secret scan] KSTORAGE-1422: TierArchiver Metric for Max Time Lag
KENGINE-73: Use more threads to load and unload groups
KAFKALESS-841: Add support for CapacityGoal with exclusions [skip secret scan]
Upgrading snakeyaml
KDATA-307: kafka reversion check when run restore
KDATA-308: restore fromTimestamp input format
KSECURITY-59: Add additional authoriser metrics
AUDIT-986: Update confluent-log4j version
AUDIT-986: Update confluent-log4j version
CPKAFKA-3449: Add simple Trogdor worker for calling Cruise Control rebalances
[skip secret scan] KGLOBAL-887 Cluster Linking requests tests in KRaft
KC-2094: Add KRaft quorum test cases to TS system tests
KGLOBAL-1139: Update cluster link tests to always check migrated ACLs
KGLOBAL-1070: Fix unnecessary metadata requests and logs.
KC-2058: Validate against replica exclusions in KRaft mode for the CreatePartitions,CreateTopic and AlterPartitionReassignments APIs
KGLOBAL-1129: Change consumer.group.prefix.enable default value to false
KGLOBAL-1134: Validate sasl.jaas.config for cluster links to avoid UnknownServerException
KMETA-53: Implement Metadata Encryption for sensitive records in kraft
KAFKALESS-928: Remove possible port collision when starting multiple brokers in Embe
KDATA-329 Added retries for consumer calls that can time outs
remove obsolete duplicateResourceLabelsOnTimeseries flag
CONFLUENT: Convert more modules to JUnit 5 and fix related build issues
KC-2095: Enable dynamic updates of secrets stored in sym linked directories
KGLOBAL-1125: Fix lag reported by MirrorCommand when source hwm not known
update telemetry-client + telemetry-api to 3.x
Address Akhilesh’s review comments
Bug fixes for CRUD operations and updating config operations to be KRaft compatible
KCFUN-312: Add wait for socket close in testDisconnectThrottledConnec
KGLOBAL-1128: Remove cluster link prefix from ACL resource transformation in LinkContext
KAFKALESS-853: Implement SbcEvents [skip secret scan]
KC-2045: Add KRaft quorum options to four system tests with TS
KDATA-299 Remove metrics reporter class property from CLM’s tier topic consumer configuration
CONFLUENT: Use non-parameterized tests for EndToEndAuthorizationTest since it is extended for Confluent authorizer tests
CONFLUENT: Use non-parameterized tests for EndToEndAuthorizationTest since it is extended for Confluent authorizer tests
KGLOBAL-863: Fix formatting to handle multiple filtered out topics (#
KGLOBAL-1096: Remove cluster link prefix from user principal
KGLOBAL-1043: Implement cluster link metadata topic in Zk mode.
KC-2057: Add BrokerReplicaExclusion{Image, Delta} and notify SBC on altered exclusions as part of the metadata image update
KGLOBAL-1093: Fix handling of CLUSTER_ID in LinkContext
KGLOBAL-1108: Fix OffsetsForLeaderEpoch version for cluster link source version < 2.8
Throw IOException for Confluent internal ip and port
CPKAFKA-8142: document merge requirements in pull request template
[skip secret scan] KSTORAGE-1976: Add DeletionTask exceptions per second metric
KGLOBAL-863: Fix formatting to handle multiple filtered out topics
Disallow loopback addresses for CL connections.
MINOR: temporary disable downstream validation
KDATA-311: Add support for Azure backend for recovery
KSTORAGE-1958: Avoid producer state snapshot sync flush during log roll
KGLOBAL-908: Change kafka-cluster-links cmd utility to ignore sync property and filter validations for source link creation
KSTORAGE-1959: Avoid checking for existence of stale index files during roll
CONFLUENT: Add missing arguments to log statements
KGLOBAL-1094: Change config name for enabling cluster link prefixing
fix merge and test failure
Fix DynamicBrokerReconfigurationTest.testThreadPoolResize
Fix test failure MultiTenantAuthorizerTest.testAclUpdateInZooKeeper.
KGLOBAL-1032: Add config option for whether to add cluster link prefix to consumer group metadata
Revert “CONFLUENT: Delete duplicate script files”
KAFKALESS-878: Add array field brokerId in describeBalancerStatus API
KAFKALESS-838: Add support for excluded broker utilization
CONFLUENT: Delete duplicate script files
KSTORAGE-1933: Make tier cleaner configs dynamically configurable
KAFKA-13603: Allow the empty active segment to have missing offset index during recovery [skip secret scan]
KGLOBAL-1049: Make sure cluster link config changes are processed on controller failover
Revert “KSTORAGE-1958: Avoid producer state snapshot sync flush during log roll (#5592)
add getBrokerListStrFromServers() as a deprecated method to fix downstream validation
AuthN-546, 547 Fix extractor compatibility issue
KAFKALESS-142: Send DataBalancer logs to dedicated file.
KSTORAGE-1958: Avoid producer state snapshot sync flush during log roll
KGLOBAL-983: Limit Number of Lagging Partitions
Add Kafka 3.0/1 and CP 7.0.1 to vagrant base.sh script so they’re pulled in
KSTORAGE-1947: add state change timestamp to TierPartitionStateEntry [FTPS cleanup]
KC-1927: BrokerReplicaExclusion API wiring & record persistence 1/2
KGLOBAL-927: Delete cluster links for deleted tenants.
[timestampConverter] add validator and recommender
KCFUN-279: Setup KCFUN Soak cluster workloads
CPKAFKA-8136: Remove named arg from method call when creating KafkaSe
KGLOBAL-319: Reduce log level of repetitive metadata refresh errors
KGLOBAL-1071: Don’t auto-mirror _confluent topics even if they match filters
[skip secret scan] KAFKA-13310: KafkaConsumer cannot jump out of the poll method, and t
KGLOBAL-1045: Add unit test for ClusterLinkSyncOffsets that tests handling two writers
AUDIT-971: Update confluent-log4j version for 7.1.x
DGS-2782: Added New Metadata resource in dataplane rbac roles for DG
Ignore failing quota_test (#5651)
AUDIT-971: Bump confluent-log4j version
KGLOBAL-938 leader epoch bump
KDATA-269 CLM to use customer supplied key for AWS BYOK clusters
KAFKALESS-850: Push callbacks to SBC [skip secret scan]
Revert “[CCLOG-1141] TimestampConverter : add validator and recommender”
KAFKA-13646; Implement KIP-801: KRaft authorizer (#11649)
KAFKALESS-848: Make LeaderBytesInDistributionGoal exclusion-aware. [skip secret scan]
KGLOBAL-1048: Check mirror topic state during ClusterLinkStopMirrorTopic
KAFKALESS-838: Add capacity for excluded brokers
KGLOBAL-988: Remove cache in cluster link offset sync task to stale offsets during controller failover, overwrites, expiry etc.
KDATA-246 CLM Making backup period configurable
KGLOBAL-112: Integration test for cluster link fetch with topic ids to detect topic recreate
[CCLOG-1141] TimestampConverter : add validator and recommender
KDATA-298 Add a tool to inspect (list / get) tiered objects
config restore parallelism from cli
KENGINE-124: Fit and finish for KC-1786
Ignore failing quota_test
Upgrade TCNative version
KENGINE-127; Add dynamic config for transaction logging verbosity
KPERF-247 single scan replicas for deleted topics in KafkaController updateMetrics
SEC-2906: Don’t generate audit events for un-routed method categories
KCFUN-272: Allow muting connections before TLS handshake completion
Allow to set list of aud in jwtConsumerBuilder
KDATA-280: Add metrics for Automated restore
KGLOBAL-1056: Support listing ACLs filtered by link ids for AclCommand
KMETA-12 Optimize CreateTopicsRequest
Fix javadoc in clients module to prepare ce-kafka for jdk17
Cherry-pick “Address comments from PR #5558 (#5612)” to master
Cherry-pick “Disbaled bubbling errors from JsonSerializer and Deserializers for connect that print the message in stack trace (#5558)” onto 7.1.x
Cherrypick to 7.1.x “KSTORAGE-1915: Check if usage of S3’s GetBucketLocation API can be eliminated”
KAFKALESS-838: Set Broker state at construction
KCFUN-268: Re-add missing call to deleteTenants()
CPKAFKA-8140: disable tier compaction system test in 7.1.x
KGLOBAL-881: Integrating CRUD operations for links with KRaft
KAFKALESS-845 Support exclusion in LeaderReplicaDistributionGoal [skip secret scan]
FIX: Remove record logging in connector tracing exception
CONFLUENT: Inline preAuthorize into authorize
FIX: Remove logging entire record in connector tracing exception.
[CLI-1430] Add GCM functionality to DecryptionEngine (#5563)
[CLI-1430] Add GCM functionality to DecryptionEngine
Revert “[KPLATFORM-89] Publishes ccDockerKafkaTarGz artifact (#5383)”
CONFLUENT: Call each authorization request sensor once per batched authorize call [skip secret scan]
KSTORAGE-1915: Check if usage of S3’s GetBucketLocation API can be eliminated
CONFLUENT: Check version to select ZK CLI class name
[KPLATFORM-89] Publishes ccDockerKafkaTarGz artifact
Revert “KPERF-205: Accumulate follower fetch purgatory checks in acti
KDATA-69 Add more metrics for Backup Object Lifecycle Manager
revert change to build.gradle
Incorporate LogCleanerDeleteRentenionMsDoc from AK to ce-kafka according to suggestion from Jason
KGLOBAL-972: AlterMirrors support in KRaft mode brokers.
Temporary commit(will be squashed into merge commit after review)
KGLOBAL-1046: Test ClusterLinkAutoMirroring handles multiple controllers/writers
KGLOBAL-1047: Add unit tests for dest cluster ACLs getting mutated out of band by ClusterLinkSyncAcls task
CONFLUENT: Initialise DynamicConfigs in BrokerServer, ControllerServer
move opencensus related code from telemetry-api to ce-metrics
KAFKALESS-867: Don’t create SampleStore during startup check
KSTORAGE-1953: Back off CompactionTask if Log.lockFirstNotDeletableOffset call fails
KSTORAGE-1901: Add TierArchiverExceptions per second metric
Cherry-pick “Disbaled bubbling errors from JsonSerializer and Deserializers for connect that print the message in stack trace #5558” onto master
KAFKALESS-843: Add excluded broker support to SystemTopicEvenDistributionGoal.
KAFKA-13636: Fix for the group coordinator issue where the offsets ar
CONFLUENT: Fix ReverseConnectionTest failure when executed with Java 17
KSTORAGE-1898: add internal retry for retriable exception in CompactionTask
KAFKALESS-844 Support exclusion in ReplicaDistributionGoal [skip secret scan]
KAFKALESS-842: Update ReplicaCapacity goal to support broker replica exclusions [skip secret scan]
KAFKALESS-851: Create an SbcResource class
KGLOBAL-770: StopMirrorsTask for ClusterLink in KRaft mode.
Build image build using developer credentials
CONFLUENT: Reinstate MultiTenantClusterLinkTest that was deleted by mistake
remove two empty lines in KafkaClusterTestKit to pass checkstyleTest (MethodLength)
AuthN-546, 547 Only Authenticate Oauth users to lkc bound to the same
CONFLUENT: Fix compiler warnings when building with Java 17
Revert “[KPLATFORM-7] Enables local Docker image build using developer creden… (#5456)”
KC-1802: Workaround for init script issue affecting Gradle 7.1 and newer
[KPLATFORM-7] Enables local Docker image build using developer creden
KC-1802: Workaround for init script issue affecting Gradle 7.1 and newer
CONFLUENT: Update netty-tcnative to 2.0.48.Final
Revert “Revert “KAFKALESS-820, KAFKALESS-685: Fix NPE in CDBE::shutdown (#5436)” (#5514)”
KSTORAGE-1932: add confluent.tier.cleaner.enable config
Revert “KAFKALESS-820, KAFKALESS-685: Fix NPE in CDBE::shutdown (#5436)”
KAFKA-13614: Don’t apply leader replication quota to consumer fetches
KAFKALESS-820, KAFKALESS-685: Fix NPE in CDBE::shutdown
KGLOBAL-1034: Support source initiated links with link coordinators based on controller or partition leader
SBC: Cleanup Mockito usage
KGLOBAL-1034: Support source initiated links with link coordinators based on controller or partition leader
KMETA-31: datagen connector with KRaft
KC-1973, KDATA-300: Add support for KRaft in DA integration tests
Add new resourceTypes and role mapping for notification-service RBAC
CCLOG-1356 Move connect permissions to cloud_rbac_roles.json
KDATA-286: Remove interrupt to AuditJob
[skip secret scan] Cell PBTs for replicaMoves in OnPremClusterModel
CONFLUENT; Avoid duplicate topic id in replica manager update
KC-2043: Add KRaft quorum options to tier_deletion_test
EVENTS-710: remove restriction on event extension length
Revert “CONFLUENT; Avoid duplicate topic id in replica manager update (#4995)”
CONFLUENT; Avoid duplicate topic id in replica manager update
[skip secret scan] KSTORAGE-1854: Implement min compaction lag ms
CDX-174 Add consumer shared resources for OrgAdmin role
KDATA-271: restore byok support for gcs
KPERF-290: Maintain principal scope as part of MultiTenantPrincipal
KC-1967: KRaft: No JVM Exit upon K8s Operator HTTP BeginShutdown
KMETA-17: update TierConfigurationTest.testDisableTieredStorageAtBrokerLevelAfterEnablingStatically to run against kraft
Pick KAFKA-13221 which adds PartitionsWithLateTransactionsCount metric
KMETA-25: Fix controller NPE due multitenant metrics
[skip secret scan] KAFKALESS-837: Introduce IGNORED (alive & excluded) broker state/strategy in ClusterModel and modify RackAwareGoal to work with exclusion [skip-secret-scan]
KGLOBAL-1038: Fix cluster link prefix issues
CIAM-1700: Add role definitions for ksqlDB data plane roles
KGLOBAL-1025: Auto mirror create should exclude all linked topics. (#
Revert “KAFKA-13152: Replace “buffered.records.per.partition” with “input.buffer.max.bytes” (#11424)”
KCFUN-240: Allow configuration of service account quotas
KCFUN-267: Only update LKC metadata store once on initial load
KDATA-43 System test for CLM
KC-1504: fix license topic consumer endOffsets TimeoutException
CPKAFKA-7648: retry fetching license topic metadata in LicenseStore
KGLOBAL-558: Pass kwargs correctly to KafkaService
KGLOBAL-1036: Add most recent Kafka versions to test_cluster_link_com
KGLOBAL-783: Add upgrade system test for cluster linking
KGLOBAL-1025: Auto mirror create should exclude all linked topics.
KSTORAGE-1462: Ensure tasks for deleted partitions are removed from partitionsInError
KSTORAGE-1930: allow setting log.retention.ms to -1 (infinite) at cluster level in ccloud
[KPERF-249] [skip secret scan] Use exponential backoff on fetch failure
KPERF-205: Accumulate follower fetch purgatory checks in action queue
[CNC-9] Configure log redactor for Connect (#5440)
KC-2004 - Disable populating map if the BrokerHealthManager thread isn’t running
KDATA-287: restore checksum enabled
KC-2039; Fix infinite recursion when AlterIsr inflight
KCFUN-237: Update quota auto-tuning logic to work with hierarchical quotas
[CNC-9] Configure log redactor for Connect
KGLOBAL-1028: Update ACL failed metric when ACL sync fails due to tenant ACL limit
KGLOBAL-785: Handle partition leadership updates for mirror partitions in replica manager in KRaft mode.
KGLOBAL-1021: Fix deadlock in ClusterLinkFetcherManager during excessive epoch updates
KC-1659: Add metrics for monitoring API keys that are currently in use
make cc-trogdor role binding sorta namespaced
[DO NOT MERGE] Cache+upgrade+update assignment metadata
KAFKALESS-812: Optimize proposal rejections in SystemTopicEvenDistrib
KENGINE-115: Leader replication quota should not be applied to consumers
KCFUN-274: ClientQuotaCallback.updateDynamicQuotas needs a default implementation (#5403)
KCFUN-274: ClientQuotaCallback.updateDynamicQuotas needs a default implementation
[skip secret scan] KSTORAGE-1920: Compaction: add metric and improve log message when offset map is filled
removed default cc-trogdor role binding since it broke a test. Will c
CCDB-4528: Prevent ClassCastException during preflight connector config validation
KGLOBAL-995: Change mirrorTopic in NewMirrorTopic to sourceTopic in t
KGLOBAL-881: Refactor away zk in cl components
KGLOBAL-1006: Use Kafka Uuid instead of Java UUID for cluster link APIs and metrics
KSE-848: remove ksql connector management RBAC roles
Update confluent-log4j version to cp8
[SEC-2896] Update confluent-log4j version to cp8
KGLOBAL-1009: Fix testDeleteAutoMirroredTopics intermittent failures
KGLOBAL-882 KRaft support for mirror topics
KGLOBAL-1009: Fix testDeleteAutoMirroredTopics intermittent failures
KGLOBAL-894: Return error message detailing all overlapping topic fil
KGLOBAL-995: Change mirrorTopic in NewMirrorTopic to sourceTopic in the admin API
CONFLUENT: fix PartitionTest.testIsrShrinkDeferralIfUnhealthy
KGLOBAL-1014: Disable cluster link prefix in 7.1.x.
KENGINE-47: metric for tracking controlled shutdown requests due to unhealthy brokers
CIAM-1618 Add internal flag for role that requires “Bind” authz
KAFKALESS-726: Basic implementation of SystemTopicEvenDistributionGoal [skip secret scan]
Updates to cc-trogdor and CloudNetworkFaultSpec
KGLOBAL-1013: Add metrics to track prefixed auto mirror topics
KGLOBAL-854: Fix function name style. (#5353)
KAFKALESS-798: Ensure ApiPersistenceStore does not leak an admin client instance by closing it appropriately
KENGINE-29: Shrunk ISR before leader crash makes the partition offline
KGLOBAL-854: Fix function name style.
KSTORAGE-1928: update TierTopicDeletionIntegrationTest to run in kraft mode
KGLOBAL-1012: Move clusterLinkPrefix to AbstractClusterLinkIntegrationTest
KGLOBAL-991: Allow link ids to be specified in ACL filters to prevent circular sync
KENGINE-108: clear KafkaYammerMetrics and ThreadCountersManager memory after all brokers are shutdown
KSTORAGE-1931: update TierTopicManagerIntegrationTest to run against both zk and kraft modes
KGLOBAL-1003: Add metrics to track information regarding cluster link prefix
KSTORAGE-1929: make TierCompactionCommitAndSwap idempotent
CIAM-1659 Give Cluster and Topic DescribeConfigs to all Operator roles
KAFKA-13582: TestVerifiableProducer.test_multiple_kraft_security_prot
KAFKA-13582: TestVerifiableProducer.test_multiple_kraft_security_protocols fails
CONFLUENT: Fix QuorumTestHarness.controllerListenerSecurityProtocol
KC-2002: Disallow TS with KRaft for CP 7.1
Backport: AuthN-256 Fix Oauth system test with new configuration
Temporarily disable integrations tests for backup object lifecycle manager
KGLOBAL-1000 Address any test gaps involving cluster link prefix
AuthN-256 - Fix Oauth system test with new configuration
KGLOBAL-989: Enhance system tests to include cluster link prefix
Fix merge for Connect source task logic
KCFUN-239: Add interface and implementation for hierarchical client quota callback
CONFLUENT: Fix IntegrationTestHarness and QuorumTestHarness
CONFLUENT: Ensure dynamic reconfigurations are setup correctly in KRaft mode
Fix NPE
Clm kraft compatibility
Revert “KDATA-248”
CCLOG-1189 Add connect roles to CCloud RBAC policies
KSTORAGE-1894: fix test testMetricsNotAcquireLogLock
KGLOBAL-854: Introduce DescribeClusterLinks (#5014)
KPERF-281 Lazily evaluate log parameters in EmbeddedAuthorizer
KGLOBAL-854: Introduce DescribeClusterLinks
KGLOBAL-904: Add support for ListClusterLinks with KRaft
Cluster Link periodic tasks and metrics support for KRaft.
KGLOBAL-880 Create and delete cluster links
KAFKA-13512: Avoid duplicating maps in ZkMetadataCache topic accessors
KAFKA-13512: Avoid duplicating maps in ZkMetadataCache topic accessors
KAFKA-13490: Fix createTopics and incrementalAlterConfigs for KRaft mode #11416
KAFKA-13490: Fix createTopics and incrementalAlterConfigs for KRaft mode #11416
KAFKA-13357; Store producer IDs in broker snapshots
Revert “MINOR: Remove redundant argument from TaskMetricsGroup#recordCommit (#9642)”

Security¶

SEC-3245: Migrate from confluent-log4j to reload4j
Fix confluent-log4j version.
Minor: Fix KafkaYammerMetrics import
Add spotbugs
Added exclusion since MDC class is failing because of reload4j
bugfix: repair failing build due to renamed method in ce-kafka
Introduce GitHub CODEOWNERS (Pull Request Reviewers)
KREST-3660 Move to Junit 5 where needed
Add authorizations for DELETE of Global Config
BUGFIX: KC-1948 changed TestSslUtils to return String not Password
KSQL-7811: support JwtPrincipal wrapped in DefaultKsqlPrincipal
FF-6454 MINOR Debug Logging for subjectPatternOperationFound

Secret Registry¶

Migrate log4j
bugfix: Make SecretRegistryCoordinator implement AbstractCoordinator
Update onJoinPrepare method to return boolean
remove usage of deprecated mockito-all
Rename advertisedListeners to effectiveAdvertisedListeners

Control Center¶

MMA-11829: add reload4j dependency
Bump maven-shade-plugin to 3.3.0
Revert “MMA-11712: Support different Schema Registry clusters with the same URL endpoints”
Override transitive dependency for analytics library of kotlin-stdlib-common
Add exclusion to override dependency kotlin-stdlib-jdk8
MMA-11829: Migrate from confluent-log4j to reload4j for blueway
MMA-11712: Support different Schema Registry clusters with the same URL endpoints
MMA-11827: Add findbugs-exclude.xml file to fix build failures
LOG_DIR to match rest of confluent components
(MINOR): Revert change that commented testArmeriaServiceHealthCheck
MMA-11694: Add retry logic for ControlCenterIntegrationTest
APIF-2311: Remove graphql module
TRAFFIC-1398 Add bootstrap templatization for ApiKeyAdminSupplier
MMA-11725: Remove usages of deprecated RocksDBStore:init(ProcessorContext, StateStore)
MMA-11404: fix powermockito incompatibility with Mockito 4.0+ and other build failures
MMA-11121: Fix compatibility issues for partition size metric
KEXP-213 add flags for ACL and Consumer group management from REST Proxy
fix build break
MMA-11491: Basic Authentication for KSQL
MMA-7291: Basic Authentication for Connect
[MMA-10400] fix: comment out config property to match project style
[MMA-10400] feat: custom analytics endpoint for segment

MQTT Proxy¶

CC-17228 | Migrate from confluent-log4j to reload4j.
Introduce GitHub CODEOWNERS (Pull Request Reviewers)

Metadata Service¶

Revert “MINOR: Use CloudAuthCache in DBAuthCache (#758)”
CIAM-2020 - Fix null string in MDSLoggingFilter
CIAM-2019 - Fix 6.x MDS builds from Jackson update
Upgrade events version
Fix dependencies
MDS-38 MDS-39 - Make MDSLoggingFilter case-insensitive
MDS-37 MDS-39 - Improve redaction rule for auth header
MINOR SEC-3087 SEC-3028 Avoid NPE in integration test
Use custom mds version format in mk-include targets
Removed OrgAdmin from user User:u-4x25kx User:u-12qko3
Update cc-mk-include to fix semaphore PR builds
[AUTHN-566] Fix policy parse exception error messages
[AUTHN-703] add migration to provider_org_mapping
Update one-off db readme to use gimme-aws-creds
PR Template to encourage writing motivation and testing strategies
Build Break Fix for KSQL - only resolve confluent-sec-plugins version once
CIAM-1814: Create new cc-rbac maven module
[AUTHN-565] Fix error message when deleting non-existent identity pools
[AUTHN-562] Fix internal errors on policy parsing
CIAM-1488: Extractor will toggle role bindings for health check.
Add consumes annotation to identity pool api
CIAM-1789 CIAM-1696: Only emit for new kafka cluster, also only look at BOUND_TO_PHYSICAL event
CIAM-1806: Update EmbeddedKafkaCluster method usages
CIAM-1752: Enable remote JMX for icc-rbac
CIAM-1792 - Stream Lineage is available to new DataplaneRoles
CIAM-1488: Update id to format rb-hc-xx for precreated 60 role bindings
CIAM-1524: Configure icc-rbac load-balancer and weighted DNS routing
Introduce GitHub CODEOWNERS (Pull Request Reviewers)
Authn-545: Publish organization id with IdentityPool
CIAM-1488: Insert 60 rbac role bindings for org 0 health checking.
CCLOG-1190 : Updated validation to allow Connector resource Type for clusterType NOT_SPECIFIED(“”)
[AUTHN-557] Add orgId check for trust service extractor
CIAM-1431: Update regex for semaphore auto deploy make target
CIAM-1754: Added toggle soft delete function.
CIAM-1431: Update icc-rbac & rbac-extractor to use newer semaphore mk targets
CIAM-1431: Integrate icc-rbac with helm, halyard, and semaphore
CIAM-1771 dbmigration to delete role bindings with newlines
Revert authn-545 and resolve conflict
CIAM-1760 - Do CDX stag and prod dbMigrates
SEC-2906: Update rbac-api-server for upstream AuditLog refactor
CIAM-1482: Use EventsMetadata instead of single entry sequence_id for sequence id.
Authn-287: Add Metrics for Trust Services RBAC Extractor
CIAM-1733: Rbac Extractor emit 0 (healthy) HTTP status while closing or closed
AUTHN-515: TrustService Performance metrics
MDS-25 Prevent Credentials from be logged when Jetty prints debug auth headers
Authn-545: Update Extractor to publish organization id with IdentityPool record
CIAM-1671: Upgrade icc-rbac to be configurable via env var
CIAM-1733: Don’t emit Rbac Extractor HTTP status while closing
CIAM-1521: Build fat shaded jar for icc-rbac
CIAM-1695: Added BOUND_TO_PHYSICAL event for lifecycle.
Authn-523: Simplify code in JwksKeyRefreshSchedulerService
CIAM-1721: Temporary fix bug that Extractor cannot be automatically deploied to devel
CIAM-1700: Add unit tests for new KSQL namespace and roles definitions
Authn-511: Add LD FF for KeyRefreshSchedulerService
AUTHN-509: Enable Extractor for Trust Service in Devel
Authn-509: Temp grant access to cc_rbac_extractor_api_0 in devel
AUTHN-510: Minor fix in JWKS refresh scheduler
CIAM-1429: Upgrade icc-rbac to be configurable via file
[MDS-27] Protobuf version bump
AUTHN-506: Add trust service schema for rbac-extractor
CIAM-1669: Logging new created LKC events in INFO level.
CIAM-1648: Resource Pattern validation for v2 API
[MINOR] Fix assertion check on error string
[AUTHN-490] Fix exception handling in RefreshTask
BUGFIX: Clear PGOPTIONS so search_path doesn’t break dbmate
KSE-848: remove scheduler service role binding in stag and prod
test: update test for removed RBAC roles (CCloudConnectorManager + CCloudClusterRoleBindingAdmin)
CIAM-1618 - Updated devel schema.sql PR
KSE-848: remove scheduler service role binding in devel
AUTHN-490: handle deserialization exception in IdentityProviderManagerImpl
CIAM-1618 add functionality for internal rbac roles
Improved meters for capturing both db query duration and producer to events Kafka duration
CIAM-1631: Implement and test wildcard and prefix resource role bindings for V2 API
Change Trust-Service update routes to patch
Authn-120: JWKS scheduler Implementation
CIAM-1493: Reverted changes for RBAC Extractor load testing.
CIAM-1493: Updated events topics for RBAC Extractor load testing in DEVEL.
Update development process for ccloud
[AUTHN-460] Add OpenAPI spec for Assume Principal endpoint
BUGFIX: resourcePattern should be null for non-resource roles
CIAM-1490: Update Public API path from /v2 to /iam/v2
CIAM-1616: Run cloud.coop tests with the rest of MDS tests
KGLOBAL-969 : Adapt MDS tests to lookup brokerId
AUTHN-263: Fix interface API compatibility
KSE-715 Migrate scheduler admin in stag, prod
CIAM-1570 Add notificationserviceadmin rolebinding
Give RBAC user temp access to cts schema
CIAM-1436 Add input validation on ResourceName in rolebinding APIs
CIAM-1610 - Remove explicit usage of log4j2 from extractor class
CIAM-1138: Minor renaming of function parameter from jwt to credential for authorizer client
Dbmigration: Add Trust Service user Schema
TrustService devel migration scripts
CIAM-1594 - Add index to prod for knownScopes call
CIAM-540 - Enable pg_stat_statements in prod
CIAM-1594: Stag Create and apply rb_scope_idx_with_cluster_type dbmigration
CIAM-540: Stag Create extension pg_stat_statements dbmigration
CIAM-1450: Update one-off db creation & connection readme
CIAM-1594: Devel Create and apply rb_scope_idx_with_cluster_type dbmigration
CIAM-540: Devel Create extension pg_stat_statements dbmigration
test: update tests for new RBAC roles (CCloudConnectorManager + CCloudClusterRoleBindingAdmin)
Add CCloudClusterRoleBindingAdmin role binding for scheduler service
Authn-373 Support manual refresh for Trust Service data given Orgs
CIAM-1428: Adapt ParitySuite to run against icc-rbac
CIAM-1424: Upgrading OTEL from 1.4.1-alpha to 1.9.0-alpha
Add Configurable Authn to TrustService
Trust Service API Crud
Authn-340 Add RolePolicy table
Fix Content-Type for public API create request
CIAM-1451 Fix tests for new CCRoleBindingViewer role
CIAM-1494-1548: Added metrics for lifecycle dead letter queue and Kafka produce time.
CIAM-2018 This release version includes a fix to prevent stack trace exposure from getting surfaced in HTTP responses for malformed requests.

Replicator¶

KSECURITY-325: Migrate confluent-log4j to reload4j
fix upstream build
MINOR: Add CLUSTER level acls to fix build failures