Repository: knative-sandbox/eventing-kafka-broker
Pull request #1827 (2022-01-28 20:03:29)

[data-plane]: Bump protobuf.version from 3.19.3 to 3.19.4 in /data-plane
Bumps `protobuf.version` from 3.19.3 to 3.19.4.
Updates `protobuf-java` from 3.19.3 to 3.19.4
<details>
<summary>Release notes</summary>
<p><em>Sourced from <a href="https://github.com/protocolbuffers/protobuf/releases">protobuf-java's releases</a>.</em></p>
<blockquote>
<h2>Protocol Buffers v3.19.4</h2>
<h1>Python</h1>
<ul>
<li>Make libprotobuf symbols local on OSX to fix issue <a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9395">#9395</a> (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9435">#9435</a>)</li>
</ul>
<h1>Ruby</h1>
<ul>
<li>Fixed a data loss bug that could occur when the number of <code>optional</code> fields in a message is an exact multiple of 32. (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9440">#9440</a>).</li>
</ul>
<h1>PHP</h1>
<ul>
<li>Fixed a data loss bug that could occur when the number of <code>optional</code> fields in a message is an exact multiple of 32. (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9440">#9440</a>).</li>
</ul>
</blockquote>
</details>
<details>
<summary>Commits</summary>
<ul>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/22d0e265de7d2b3d2e9a00d071313502e7d4cccf"><code>22d0e26</code></a> Update protobuf version for 3.19.4 (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9449">#9449</a>)</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/afeb6d8181db3bba03c81e31a309eb3d3243cae3"><code>afeb6d8</code></a> Merge pull request <a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9451">#9451</a> from haberman/ruby-dataloss-bugfix</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/98b8e055d560062c03aef7fd7f305d0699145252"><code>98b8e05</code></a> Merge branch '3.19.x' into ruby-dataloss-bugfix</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/eb301e1a336276b78ce3ddad6fe7bad45b54c127"><code>eb301e1</code></a> Merge pull request <a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9450">#9450</a> from haberman/php-dataloss-bugfix</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/aceff710f4caef3269308a6c50ab075f3879176d"><code>aceff71</code></a> Fixed data loss bug in Ruby extension.</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/35a21c124971bb062cffe0b6bda6159fbbbb3297"><code>35a21c1</code></a> Added CHANGES.txt entry.</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/67995fb4e9ccd43195993dddc051a018fd888086"><code>67995fb</code></a> Fixed data loss bug with PHP C extension.</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/779b97260d6f75c4701bee27ba5863f3bf246a41"><code>779b972</code></a> Update CHANGES.txt for 3.19.4 release (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9448">#9448</a>)</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/a035bd0882f74d42798cf65fced7ce785b837646"><code>a035bd0</code></a> Make libprotobuf symbols local on OSX (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/8346">#8346</a>) (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9435">#9435</a>)</li>
<li>See full diff in <a href="https://github.com/protocolbuffers/protobuf/compare/v3.19.3...v3.19.4">compare view</a></li>
</ul>
</details>
<br />

Updates `protobuf-java-util` from 3.19.3 to 3.19.4
<details>
<summary>Release notes</summary>
<p><em>Sourced from <a href="https://github.com/protocolbuffers/protobuf/releases">protobuf-java-util's releases</a>.</em></p>
<blockquote>
<h2>Protocol Buffers v3.19.4</h2>
<h1>Python</h1>
<ul>
<li>Make libprotobuf symbols local on OSX to fix issue <a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9395">#9395</a> (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9435">#9435</a>)</li>
</ul>
<h1>Ruby</h1>
<ul>
<li>Fixed a data loss bug that could occur when the number of <code>optional</code> fields in a message is an exact multiple of 32. (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9440">#9440</a>).</li>
</ul>
<h1>PHP</h1>
<ul>
<li>Fixed a data loss bug that could occur when the number of <code>optional</code> fields in a message is an exact multiple of 32. (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9440">#9440</a>).</li>
</ul>
</blockquote>
</details>
<details>
<summary>Commits</summary>
<ul>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/22d0e265de7d2b3d2e9a00d071313502e7d4cccf"><code>22d0e26</code></a> Update protobuf version for 3.19.4 (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9449">#9449</a>)</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/afeb6d8181db3bba03c81e31a309eb3d3243cae3"><code>afeb6d8</code></a> Merge pull request <a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9451">#9451</a> from haberman/ruby-dataloss-bugfix</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/98b8e055d560062c03aef7fd7f305d0699145252"><code>98b8e05</code></a> Merge branch '3.19.x' into ruby-dataloss-bugfix</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/eb301e1a336276b78ce3ddad6fe7bad45b54c127"><code>eb301e1</code></a> Merge pull request <a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9450">#9450</a> from haberman/php-dataloss-bugfix</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/aceff710f4caef3269308a6c50ab075f3879176d"><code>aceff71</code></a> Fixed data loss bug in Ruby extension.</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/35a21c124971bb062cffe0b6bda6159fbbbb3297"><code>35a21c1</code></a> Added CHANGES.txt entry.</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/67995fb4e9ccd43195993dddc051a018fd888086"><code>67995fb</code></a> Fixed data loss bug with PHP C extension.</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/779b97260d6f75c4701bee27ba5863f3bf246a41"><code>779b972</code></a> Update CHANGES.txt for 3.19.4 release (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9448">#9448</a>)</li>
<li><a href="https://github.com/protocolbuffers/protobuf/commit/a035bd0882f74d42798cf65fced7ce785b837646"><code>a035bd0</code></a> Make libprotobuf symbols local on OSX (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/8346">#8346</a>) (<a href="https://github-redirect.dependabot.com/protocolbuffers/protobuf/issues/9435">#9435</a>)</li>
<li>See full diff in <a href="https://github.com/protocolbuffers/protobuf/compare/v3.19.3...v3.19.4">compare view</a></li>
</ul>
</details>
<br />


Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`.

[//]: # (dependabot-automerge-start)
[//]: # (dependabot-automerge-end)

---

<details>
<summary>Dependabot commands and options</summary>
<br />

You can trigger Dependabot actions by commenting on this PR:
- `@dependabot rebase` will rebase this PR
- `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it
- `@dependabot merge` will merge this PR after your CI passes on it
- `@dependabot squash and merge` will squash and merge this PR after your CI passes on it
- `@dependabot cancel merge` will cancel a previously requested merge and block automerging
- `@dependabot reopen` will reopen this PR if it is closed
- `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
- `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)


</details>

knative-prow-robot: [APPROVALNOTIFIER] This PR is **NOT APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/1827#" title="Author self-approved">dependabot[bot]</a>*
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please assign **psschwei** after the PR has been reviewed.
You can assign the PR to them by writing `/assign @psschwei` in a comment when ready.

The full list of commands accepted by this bot can be found [here](https://go.k8s.io/bot-commands?repo=knative-sandbox%2Feventing-kafka-broker).

<details open>
Needs approval from an approver in each of these files:

- **[OWNERS](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/OWNERS)**

Approvers can indicate their approval by writing `/approve` in a comment
Approvers can cancel approval by writing `/approve cancel` in a comment
</details>
<!-- META={"approvers":["psschwei"]} -->
knative-prow-robot: Hi @dependabot[bot]. Thanks for your PR.

I'm waiting for a [knative-sandbox](https://github.com/orgs/knative-sandbox/people) member to verify that this patch is reasonable to test. If it is, they should reply with `/ok-to-test` on its own line. Until that is done, I will not automatically test new commits in this PR, but the usual testing commands by org members will still work. Regular contributors should [join the org](https://github.com/orgs/knative-sandbox/people) to skip this step.

Once the patch is verified, the new status will be reflected by the `ok-to-test` label.

I understand the commands that are listed [here](https://go.k8s.io/bot-commands?repo=knative-sandbox%2Feventing-kafka-broker).

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository.
</details>

knative-prow-robot: [APPROVALNOTIFIER] This PR is **NOT APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/1827#" title="Author self-approved">dependabot[bot]</a>*
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please ask for approval from **pierdipi** after the PR has been reviewed.

The full list of commands accepted by this bot can be found [here](https://go.k8s.io/bot-commands?repo=knative-sandbox%2Feventing-kafka-broker).

<details open>
Needs approval from an approver in each of these files:

- **[OWNERS](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/OWNERS)**

Approvers can indicate their approval by writing `/approve` in a comment
Approvers can cancel approval by writing `/approve cancel` in a comment
</details>
<!-- META={"approvers":["pierdipi"]} -->
codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) Report
> Merging [#1827](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (88eca15) into [main](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/commit/db70212f7e886eb7be629b8b712b857a6be75a58?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (db70212) will **increase** coverage by `13.22%`.
> The diff coverage is `n/a`.

> :exclamation: Current head 88eca15 differs from pull request most recent head 2e9c5c3. Consider uploading reports for the commit 2e9c5c3 to get more accurate results
[![Impacted file tree graph](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/graphs/tree.svg?width=650&height=150&src=pr&token=xyPIgGOiwy&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)

```diff
@@              Coverage Diff              @@
##               main    #1827       +/-   ##
=============================================
+ Coverage     68.79%   82.01%   +13.22%     
  Complexity      614      614               
=============================================
  Files           131       69       -62     
  Lines          5492     2024     -3468     
  Branches        178      178               
=============================================
- Hits           3778     1660     -2118     
+ Misses         1410      270     -1140     
+ Partials        304       94      -210     
```

| Flag | Coverage Δ | |
|---|---|---|
| java-unittests | `82.01% <ø> (ø)` | |

Flags with carried forward coverage won't be shown. [Click here](https://docs.codecov.io/docs/carryforward-flags?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#carryforward-flags-in-the-pull-request-comment) to find out more.

| [Impacted Files](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) | Coverage Δ | |
|---|---|---|
| [control-plane/pkg/reconciler/kafka/broker\_class.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9rYWZrYS9icm9rZXJfY2xhc3MuZ28=) | | |
| [control-plane/pkg/prober/async\_prober.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcHJvYmVyL2FzeW5jX3Byb2Jlci5nbw==) | | |
| [...als/kafka/eventing/v1alpha1/consumer\_validation.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvYXBpcy9pbnRlcm5hbHMva2Fma2EvZXZlbnRpbmcvdjFhbHBoYTEvY29uc3VtZXJfdmFsaWRhdGlvbi5nbw==) | | |
| [control-plane/pkg/security/secret.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvc2VjdXJpdHkvc2VjcmV0Lmdv) | | |
| [control-plane/pkg/config/env\_config.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvY29uZmlnL2Vudl9jb25maWcuZ28=) | | |
| [control-plane/pkg/security/scram.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvc2VjdXJpdHkvc2NyYW0uZ28=) | | |
| [control-plane/pkg/contract/extensions.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvY29udHJhY3QvZXh0ZW5zaW9ucy5nbw==) | | |
| [control-plane/pkg/reconciler/broker/broker.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9icm9rZXIvYnJva2VyLmdv) | | |
| [control-plane/pkg/reconciler/source/controller.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9zb3VyY2UvY29udHJvbGxlci5nbw==) | | |
| [control-plane/pkg/reconciler/channel/controller.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9jaGFubmVsL2NvbnRyb2xsZXIuZ28=) | | |
| ... and [52 more](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827/diff?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) | |

------

[Continue to review full report at Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827?src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Last update [db70212...2e9c5c3](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1827?src=pr&el=lastupdated&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox).

knative-prow-robot: [APPROVALNOTIFIER] This PR is **APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/1827#" title="Author self-approved">dependabot[bot]</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/1827#pullrequestreview-867457937" title="Approved">matzew</a>*

The full list of commands accepted by this bot can be found [here](https://go.k8s.io/bot-commands?repo=knative-sandbox%2Feventing-kafka-broker).

The pull request process is described [here](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process)

<details >
Needs approval from an approver in each of these files:

- ~~[OWNERS](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/OWNERS)~~ [matzew]

Approvers can indicate their approval by writing `/approve` in a comment
Approvers can cancel approval by writing `/approve cancel` in a comment
</details>
<!-- META={"approvers":[]} -->
knative-prow-robot: @dependabot[bot]: The following test **failed**, say `/retest` to rerun all failed tests or `/retest-required` to rerun all mandatory failed tests:

Test name | Commit | Details | Required | Rerun command
--- | --- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-broker-upgrade-tests | 2e9c5c3ffbac079eed5c7448a87e38e9f43c07cd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1827/pull-knative-sandbox-eventing-kafka-broker-upgrade-tests/1488049886640214016) | true | `/test pull-knative-sandbox-eventing-kafka-broker-upgrade-tests`

[Full PR test history](https://gubernator.knative.dev/pr/knative-sandbox_eventing-kafka-broker/1827). [Your PR dashboard](https://gubernator.knative.dev/pr/dependabot[bot]).

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
pierDipi: /test pull-knative-sandbox-eventing-kafka-broker-upgrade-tests
knative-prow-robot: New changes are detected. LGTM label has been removed.

Patch:
diff --git a/control-plane/config/200-controller/100-config-kafka-descheduler.yaml b/control-plane/config/200-controller/100-config-kafka-descheduler.yaml
new file mode 100644
index 000000000..00b90633a
--- /dev/null
+++ b/control-plane/config/200-controller/100-config-kafka-descheduler.yaml
@@ -0,0 +1,61 @@
+# Copyright 2021 The Knative Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: config-kafka-descheduler
+  namespace: knative-eventing
+  labels:
+    kafka.eventing.knative.dev/release: devel
+data:
+  _example: |
+    ################################
+    #                              #
+    #    EXAMPLE CONFIGURATION     #
+    #                              #
+    ################################
+
+    # This block is not actually functional configuration,
+    # but serves to illustrate the available configuration
+    # options and document them in a way that is accessible
+    # to users that `kubectl edit` this config map.
+    #
+    # These sample configuration options may be copied out of
+    # this example block and unindented to be in the data block
+    # to actually change the configuration.
+    #
+    # These predicate plugins are used to filter out pods that
+    # a vreplica cannot be removed from due to not satisfying the
+    # predicate condition. For each pod, the descheduler
+    # will call filter plugins in their configured order.
+    # predicates: |+
+                    []
+    #
+    # These priority plugins are used to score each pod that
+    # has passed the filtering phase. The scheduler will then
+    # select the pod with the highest weighted score sum to
+    # remove vreplica from. If two pods have an equal score,
+    # a pod is chosen randomly.
+    # priorities: |+
+                  [
+                    {"Name": "RemoveWithEvenPodSpreadPriority",
+                    "Weight": 10,
+                    "Args": "{\"MaxSkew\": 2}"},
+                    {"Name": "RemoveWithAvailabilityZonePriority",
+                    "Weight": 10,
+                    "Args":  "{\"MaxSkew\": 2}"},
+                    {"Name": "RemoveWithHighestOrdinalPriority",
+                    "Weight": 2}
+                  ]
diff --git a/control-plane/config/200-controller/100-config-kafka-scheduler.yaml b/control-plane/config/200-controller/100-config-kafka-scheduler.yaml
new file mode 100644
index 000000000..a419b8471
--- /dev/null
+++ b/control-plane/config/200-controller/100-config-kafka-scheduler.yaml
@@ -0,0 +1,63 @@
+# Copyright 2021 The Knative Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  name: config-kafka-scheduler
+  namespace: knative-eventing
+  labels:
+    kafka.eventing.knative.dev/release: devel
+data:
+  _example: |
+    ################################
+    #                              #
+    #    EXAMPLE CONFIGURATION     #
+    #                              #
+    ################################
+
+    # This block is not actually functional configuration,
+    # but serves to illustrate the available configuration
+    # options and document them in a way that is accessible
+    # to users that `kubectl edit` this config map.
+    #
+    # These sample configuration options may be copied out of
+    # this example block and unindented to be in the data block
+    # to actually change the configuration.
+    #
+    # These predicate plugins are used to filter out pods that
+    # a vreplica cannot be placed on due to not satisfying the
+    # predicate condition. For each pod, the scheduler
+    # will call filter plugins in their configured order.
+    # predicates: |+
+                  [
+                    {"Name": "PodFitsResources"},
+                    {"Name": "NoMaxResourceCount",
+                    "Args": "{\"NumPartitions\": 100}"},
+                    {"Name": "EvenPodSpread",
+                    "Args": "{\"MaxSkew\": 2}"}
+                  ]
+    #
+    # These priority plugins are used to score each pod that
+    # has passed the filtering phase. The scheduler will then
+    # select the pod with the highest weighted score sum. If
+    # two pods have an equal score, a pod is chosen randomly.
+    # priorities: |+
+                  [
+                    {"Name": "AvailabilityZonePriority",
+                    "Weight": 10,
+                    "Args":  "{\"MaxSkew\": 2}"},
+                    {"Name": "LowestOrdinalPriority",
+                    "Weight": 2}
+                  ]
diff --git a/control-plane/pkg/reconciler/base/receiver_condition_set.go b/control-plane/pkg/reconciler/base/receiver_condition_set.go
index df9794c36..1eb85a29b 100644
--- a/control-plane/pkg/reconciler/base/receiver_condition_set.go
+++ b/control-plane/pkg/reconciler/base/receiver_condition_set.go
@@ -219,11 +219,6 @@ func (manager *StatusConditionManager) FailedToUpdateReceiverPodsAnnotation(err
 	return fmt.Errorf("failed to update receiver pods annotation: %w", err)
 }
 
-func (manager *StatusConditionManager) FailedToGetConfig(err error) reconciler.Event {
-
-	return fmt.Errorf("failed to get contract configuration: %w", err)
-}
-
 func (manager *StatusConditionManager) FailedToResolveConfig(err error) reconciler.Event {
 
 	manager.Object.GetConditionSet().Manage(manager.Object.GetStatus()).MarkFalse(
diff --git a/control-plane/pkg/reconciler/broker/broker.go b/control-plane/pkg/reconciler/broker/broker.go
index 08ea153b0..c2bdb9fa9 100644
--- a/control-plane/pkg/reconciler/broker/broker.go
+++ b/control-plane/pkg/reconciler/broker/broker.go
@@ -161,7 +161,7 @@ func (r *Reconciler) reconcileKind(ctx context.Context, broker *eventing.Broker)
 	// Get resource configuration.
 	brokerResource, err := r.reconcilerBrokerResource(ctx, topic, broker, secret, topicConfig)
 	if err != nil {
-		return statusConditionManager.FailedToGetConfig(err)
+		return statusConditionManager.FailedToResolveConfig(err)
 	}
 	coreconfig.SetDeadLetterSinkURIFromEgressConfig(&broker.Status.DeliveryStatus, brokerResource.EgressConfig)
 
diff --git a/control-plane/pkg/reconciler/channel/channel.go b/control-plane/pkg/reconciler/channel/channel.go
index e505ac58d..93a874d70 100644
--- a/control-plane/pkg/reconciler/channel/channel.go
+++ b/control-plane/pkg/reconciler/channel/channel.go
@@ -184,7 +184,7 @@ func (r *Reconciler) reconcileKind(ctx context.Context, channel *messagingv1beta
 	// Get data plane config map.
 	contractConfigMap, err := r.GetOrCreateDataPlaneConfigMap(ctx)
 	if err != nil {
-		return statusConditionManager.FailedToGetConfig(err)
+		return statusConditionManager.FailedToResolveConfig(err)
 	}
 	logger.Debug("Got contract config map")
 
@@ -198,7 +198,7 @@ func (r *Reconciler) reconcileKind(ctx context.Context, channel *messagingv1beta
 	// Get resource configuration
 	channelResource, err := r.getChannelContractResource(ctx, topic, channel, secret, topicConfig)
 	if err != nil {
-		return statusConditionManager.FailedToGetConfig(err)
+		return statusConditionManager.FailedToResolveConfig(err)
 	}
 	coreconfig.SetDeadLetterSinkURIFromEgressConfig(&channel.Status.DeliveryStatus, channelResource.EgressConfig)
 
diff --git a/data-plane/THIRD-PARTY.txt b/data-plane/THIRD-PARTY.txt
index e732754de..775825b80 100644
--- a/data-plane/THIRD-PARTY.txt
+++ b/data-plane/THIRD-PARTY.txt
@@ -20,8 +20,8 @@ Lists of 158 third-party dependencies.
      (Apache License, Version 2.0) Guava: Google Core Libraries for Java (com.google.guava:guava:30.1.1-android - https://github.com/google/guava/guava)
      (The Apache Software License, Version 2.0) Guava ListenableFuture only (com.google.guava:listenablefuture:9999.0-empty-to-avoid-conflict-with-guava - https://github.com/google/guava/listenablefuture)
      (The Apache Software License, Version 2.0) J2ObjC Annotations (com.google.j2objc:j2objc-annotations:1.3 - https://github.com/google/j2objc/)
-     (3-Clause BSD License) Protocol Buffers [Core] (com.google.protobuf:protobuf-java:3.19.3 - https://developers.google.com/protocol-buffers/protobuf-java/)
-     (3-Clause BSD License) Protocol Buffers [Util] (com.google.protobuf:protobuf-java-util:3.19.3 - https://developers.google.com/protocol-buffers/protobuf-java-util/)
+     (3-Clause BSD License) Protocol Buffers [Core] (com.google.protobuf:protobuf-java:3.19.4 - https://developers.google.com/protocol-buffers/protobuf-java/)
+     (3-Clause BSD License) Protocol Buffers [Util] (com.google.protobuf:protobuf-java-util:3.19.4 - https://developers.google.com/protocol-buffers/protobuf-java-util/)
      (Apache 2.0) OkHttp Logging Interceptor (com.squareup.okhttp3:logging-interceptor:3.12.12 - https://github.com/square/okhttp/logging-interceptor)
      (Apache 2.0) MockWebServer (com.squareup.okhttp3:mockwebserver:3.12.12 - https://github.com/square/okhttp/mockwebserver)
      (Apache 2.0) OkHttp (com.squareup.okhttp3:okhttp:3.14.9 - https://github.com/square/okhttp/okhttp)
diff --git a/data-plane/pom.xml b/data-plane/pom.xml
index 910aa857a..ee60953fc 100644
--- a/data-plane/pom.xml
+++ b/data-plane/pom.xml
@@ -46,7 +46,7 @@
     <micrometer.version>1.8.2</micrometer.version>
     <opentelemetry.version>1.10.1</opentelemetry.version>
     <jackson.version>2.13.1</jackson.version>
-    <protobuf.version>3.19.3</protobuf.version>
+    <protobuf.version>3.19.4</protobuf.version>
     <slf4j.version>1.7.35</slf4j.version>
     <ch.qos.logback.version>1.2.10</ch.qos.logback.version>
     <net.logstash.logback.encoder.version>7.0.1</net.logstash.logback.encoder.version>
diff --git a/hack/release.sh b/hack/release.sh
index a7a7c295f..e6a82d0ac 100755
--- a/hack/release.sh
+++ b/hack/release.sh
@@ -67,6 +67,11 @@ function build_release() {
     "${EVENTING_KAFKA_CHANNEL_ARTIFACT}"
     "${EVENTING_KAFKA_CHANNEL_PROMETHEUS_OPERATOR_ARTIFACT}"
   )
+
+  # ARTIFACTS_TO_PUBLISH has to be a string, not an array.
+  # shellcheck disable=SC2178
+  # shellcheck disable=SC2124
+  export ARTIFACTS_TO_PUBLISH="${ARTIFACTS_TO_PUBLISH[@]}"
 }
 
 main $@


Test patch:
diff --git a/.github/workflows/kind-e2e.yaml b/.github/workflows/kind-e2e.yaml
index ba6bfc419..86c037c7d 100644
--- a/.github/workflows/kind-e2e.yaml
+++ b/.github/workflows/kind-e2e.yaml
@@ -27,6 +27,8 @@ jobs:
         test-suite:
           - ./test/e2e
           - ./test/e2e_new
+          - ./test/e2e_channel
+          - ./test/e2e_new_channel
 
         # Map between K8s and KinD versions.
         # This is attempting to make it a bit clearer what's being tested.
@@ -38,7 +40,7 @@ jobs:
           - k8s-version: v1.22.2
             kind-version: v0.11.1
             kind-image-sha: sha256:f638a08c1f68fe2a99e724ace6df233a546eaf6713019a0b310130a4f91ebe7f
-          - test-suite: ./test/e2e
+          - test-suite: ./test/e2e_channel
             extra-test-flags: -channels=messaging.knative.dev/v1beta1:KafkaChannel
 
     env:
@@ -123,7 +125,7 @@ jobs:
           export CLUSTER_DOMAIN=${CLUSTER_SUFFIX}
 
           # Run the tests tagged as e2e on the KinD cluster.
-          go test -race -count=1 -timeout=1h -v -short -tags=e2e \
+          go test -race -count=1 -timeout=1h -v -short -tags=e2e,cloudevents \
              ${{ matrix.test-suite }} ${{ matrix.extra-test-flags }}
 
       - name: Collect system diagnostics
diff --git a/control-plane/pkg/reconciler/broker/broker_test.go b/control-plane/pkg/reconciler/broker/broker_test.go
index 93dad84b3..8f9bc3b38 100644
--- a/control-plane/pkg/reconciler/broker/broker_test.go
+++ b/control-plane/pkg/reconciler/broker/broker_test.go
@@ -979,7 +979,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 						},
 						reconcilertesting.WithInitBrokerConditions,
 						StatusBrokerDataPlaneAvailable,
-						StatusBrokerConfigParsed,
+						StatusBrokerConfigNotParsed("failed to resolve Spec.Delivery.DeadLetterSink: destination missing Ref and URI, expected at least one"),
 						StatusBrokerTopicReady,
 					),
 				},
diff --git a/test/e2e-tests.sh b/test/e2e-tests.sh
index d9a36da09..eeedc53ae 100755
--- a/test/e2e-tests.sh
+++ b/test/e2e-tests.sh
@@ -21,9 +21,11 @@ header "Running tests"
 
 export_logs_continuously
 
-go_test_e2e -timeout=1h ./test/e2e/... -channels=messaging.knative.dev/v1beta1:KafkaChannel || fail_test "E2E suite failed"
+go_test_e2e -timeout=1h ./test/e2e/... || fail_test "E2E suite failed"
 
-go_test_e2e -tags=deletecm ./test/e2e/... -channels=messaging.knative.dev/v1beta1:KafkaChannel || fail_test "E2E (deletecm) suite failed"
+go_test_e2e -timeout=1h ./test/e2e_channel/... -channels=messaging.knative.dev/v1beta1:KafkaChannel || fail_test "E2E suite (KafkaChannel) failed"
+
+go_test_e2e -tags=deletecm ./test/e2e/... || fail_test "E2E (deletecm) suite failed"
 
 if ! ${LOCAL_DEVELOPMENT}; then
   go_test_e2e -tags=sacura -timeout=40m ./test/e2e/... || fail_test "E2E (sacura) suite failed"
diff --git a/test/e2e/conformance/main_test.go b/test/e2e/conformance/main_test.go
index 2b7c1ca53..b5daffbf5 100644
--- a/test/e2e/conformance/main_test.go
+++ b/test/e2e/conformance/main_test.go
@@ -24,24 +24,14 @@ import (
 	"os"
 	"testing"
 
-	"knative.dev/eventing-kafka/test"
-	eventingTest "knative.dev/eventing/test"
 	testlib "knative.dev/eventing/test/lib"
 	"knative.dev/pkg/system"
 	"knative.dev/pkg/test/zipkin"
 )
 
-var channelTestRunner testlib.ComponentsTestRunner
-
 func TestMain(m *testing.M) {
 
 	os.Exit(func() int {
-		eventingTest.InitializeEventingFlags()
-		channelTestRunner = testlib.ComponentsTestRunner{
-			ComponentFeatureMap: test.ChannelFeatureMap,
-			ComponentsToTest:    eventingTest.EventingFlags.Channels,
-		}
-
 		// Any tests may SetupZipkinTracing, it will only actually be done once. This should be the ONLY
 		// place that cleans it up. If an individual test calls this instead, then it will break other
 		// tests that need the tracing in place.
diff --git a/test/e2e/main_test.go b/test/e2e/main_test.go
index 76196aceb..d8d336e83 100644
--- a/test/e2e/main_test.go
+++ b/test/e2e/main_test.go
@@ -23,21 +23,11 @@ import (
 	"os"
 	"testing"
 
-	"knative.dev/eventing-kafka/test"
-	eventingTest "knative.dev/eventing/test"
 	testlib "knative.dev/eventing/test/lib"
 	"knative.dev/pkg/system"
 )
 
-var channelTestRunner testlib.ComponentsTestRunner
-
 func TestMain(m *testing.M) {
-
-	eventingTest.InitializeEventingFlags()
-	channelTestRunner = testlib.ComponentsTestRunner{
-		ComponentFeatureMap: test.ChannelFeatureMap,
-		ComponentsToTest:    eventingTest.EventingFlags.Channels,
-	}
 	os.Exit(func() int {
 		defer testlib.ExportLogs(testlib.SystemLogsDir, system.Namespace())
 
diff --git a/test/e2e/channel_event_transformation_test.go b/test/e2e_channel/channel_event_transformation_test.go
similarity index 97%
rename from test/e2e/channel_event_transformation_test.go
rename to test/e2e_channel/channel_event_transformation_test.go
index 07e3d9d8f..be6fb75db 100644
--- a/test/e2e/channel_event_transformation_test.go
+++ b/test/e2e_channel/channel_event_transformation_test.go
@@ -17,7 +17,7 @@
  * limitations under the License.
  */
 
-package e2e
+package e2e_channel
 
 import (
 	"context"
diff --git a/test/e2e/channel_single_event_test.go b/test/e2e_channel/channel_single_event_test.go
similarity index 98%
rename from test/e2e/channel_single_event_test.go
rename to test/e2e_channel/channel_single_event_test.go
index 141752a2a..262c5d2a5 100644
--- a/test/e2e/channel_single_event_test.go
+++ b/test/e2e_channel/channel_single_event_test.go
@@ -17,7 +17,7 @@
  * limitations under the License.
  */
 
-package e2e
+package e2e_channel
 
 import (
 	"context"
diff --git a/test/e2e/conformance/channel_addressable_resolver_cluster_role_test.go b/test/e2e_channel/conformance/channel_addressable_resolver_cluster_role_test.go
similarity index 100%
rename from test/e2e/conformance/channel_addressable_resolver_cluster_role_test.go
rename to test/e2e_channel/conformance/channel_addressable_resolver_cluster_role_test.go
diff --git a/test/e2e/conformance/channel_channelable_manipulator_cluster_role_test.go b/test/e2e_channel/conformance/channel_channelable_manipulator_cluster_role_test.go
similarity index 100%
rename from test/e2e/conformance/channel_channelable_manipulator_cluster_role_test.go
rename to test/e2e_channel/conformance/channel_channelable_manipulator_cluster_role_test.go
diff --git a/test/e2e/conformance/channel_crd_metadata_test.go b/test/e2e_channel/conformance/channel_crd_metadata_test.go
similarity index 100%
rename from test/e2e/conformance/channel_crd_metadata_test.go
rename to test/e2e_channel/conformance/channel_crd_metadata_test.go
diff --git a/test/e2e/conformance/channel_crd_name_test.go b/test/e2e_channel/conformance/channel_crd_name_test.go
similarity index 100%
rename from test/e2e/conformance/channel_crd_name_test.go
rename to test/e2e_channel/conformance/channel_crd_name_test.go
diff --git a/test/e2e/conformance/channel_spec_test.go b/test/e2e_channel/conformance/channel_spec_test.go
similarity index 100%
rename from test/e2e/conformance/channel_spec_test.go
rename to test/e2e_channel/conformance/channel_spec_test.go
diff --git a/test/e2e/conformance/channel_status_subscriber_test.go b/test/e2e_channel/conformance/channel_status_subscriber_test.go
similarity index 100%
rename from test/e2e/conformance/channel_status_subscriber_test.go
rename to test/e2e_channel/conformance/channel_status_subscriber_test.go
diff --git a/test/e2e/conformance/channel_status_test.go b/test/e2e_channel/conformance/channel_status_test.go
similarity index 100%
rename from test/e2e/conformance/channel_status_test.go
rename to test/e2e_channel/conformance/channel_status_test.go
diff --git a/test/e2e/conformance/channel_tracing_test.go b/test/e2e_channel/conformance/channel_tracing_test.go
similarity index 100%
rename from test/e2e/conformance/channel_tracing_test.go
rename to test/e2e_channel/conformance/channel_tracing_test.go
diff --git a/test/e2e_channel/conformance/main_test.go b/test/e2e_channel/conformance/main_test.go
new file mode 100644
index 000000000..2b7c1ca53
--- /dev/null
+++ b/test/e2e_channel/conformance/main_test.go
@@ -0,0 +1,53 @@
+//go:build e2e
+// +build e2e
+
+/*
+ * Copyright 2020 The Knative Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package conformance
+
+import (
+	"log"
+	"os"
+	"testing"
+
+	"knative.dev/eventing-kafka/test"
+	eventingTest "knative.dev/eventing/test"
+	testlib "knative.dev/eventing/test/lib"
+	"knative.dev/pkg/system"
+	"knative.dev/pkg/test/zipkin"
+)
+
+var channelTestRunner testlib.ComponentsTestRunner
+
+func TestMain(m *testing.M) {
+
+	os.Exit(func() int {
+		eventingTest.InitializeEventingFlags()
+		channelTestRunner = testlib.ComponentsTestRunner{
+			ComponentFeatureMap: test.ChannelFeatureMap,
+			ComponentsToTest:    eventingTest.EventingFlags.Channels,
+		}
+
+		// Any tests may SetupZipkinTracing, it will only actually be done once. This should be the ONLY
+		// place that cleans it up. If an individual test calls this instead, then it will break other
+		// tests that need the tracing in place.
+		defer zipkin.CleanupZipkinTracingSetup(log.Printf)
+		defer testlib.ExportLogs(testlib.SystemLogsDir, system.Namespace())
+
+		return m.Run()
+	}())
+}
diff --git a/test/e2e_channel/main_test.go b/test/e2e_channel/main_test.go
new file mode 100644
index 000000000..0c67ac791
--- /dev/null
+++ b/test/e2e_channel/main_test.go
@@ -0,0 +1,46 @@
+//go:build e2e
+// +build e2e
+
+/*
+ * Copyright 2020 The Knative Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package e2e_channel
+
+import (
+	"os"
+	"testing"
+
+	"knative.dev/eventing-kafka/test"
+	eventingTest "knative.dev/eventing/test"
+	testlib "knative.dev/eventing/test/lib"
+	"knative.dev/pkg/system"
+)
+
+var channelTestRunner testlib.ComponentsTestRunner
+
+func TestMain(m *testing.M) {
+
+	eventingTest.InitializeEventingFlags()
+	channelTestRunner = testlib.ComponentsTestRunner{
+		ComponentFeatureMap: test.ChannelFeatureMap,
+		ComponentsToTest:    eventingTest.EventingFlags.Channels,
+	}
+	os.Exit(func() int {
+		defer testlib.ExportLogs(testlib.SystemLogsDir, system.Namespace())
+
+		return m.Run()
+	}())
+}
diff --git a/test/e2e_new/main_test.go b/test/e2e_new/main_test.go
index f8c717918..c31e03102 100644
--- a/test/e2e_new/main_test.go
+++ b/test/e2e_new/main_test.go
@@ -24,8 +24,6 @@ import (
 	"os"
 	"testing"
 
-	"knative.dev/eventing/test/rekt/resources/channel_impl"
-
 	// Uncomment the following line to load the gcp plugin (only required to authenticate against GKE clusters).
 	_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
 
@@ -47,10 +45,6 @@ func init() {
 	// environment.InitFlags registers state and level filter flags.
 	environment.InitFlags(flag.CommandLine)
 
-	// CHANNEL_GROUP_KIND=KafkaChannel.messaging.knative.dev;CHANNEL_VERSION=v1beta1
-	channel_impl.EnvCfg.ChannelGK = "KafkaChannel.messaging.knative.dev"
-	channel_impl.EnvCfg.ChannelV = "v1beta1"
-
 	// Force the broker class to be configured properly
 	broker.EnvCfg.BrokerClass = kafka.BrokerClass
 }
diff --git a/test/e2e_new/kafka_channel_test.go b/test/e2e_new_channel/kafka_channel_test.go
similarity index 99%
rename from test/e2e_new/kafka_channel_test.go
rename to test/e2e_new_channel/kafka_channel_test.go
index 6c9c8f2be..f099c6c73 100644
--- a/test/e2e_new/kafka_channel_test.go
+++ b/test/e2e_new_channel/kafka_channel_test.go
@@ -17,7 +17,7 @@
  * limitations under the License.
  */
 
-package e2e_new
+package e2e_new_channel
 
 import (
 	"fmt"
diff --git a/test/e2e_new/kafka_channel_upstream_test.go b/test/e2e_new_channel/kafka_channel_upstream_test.go
similarity index 99%
rename from test/e2e_new/kafka_channel_upstream_test.go
rename to test/e2e_new_channel/kafka_channel_upstream_test.go
index 132670950..c7b660760 100644
--- a/test/e2e_new/kafka_channel_upstream_test.go
+++ b/test/e2e_new_channel/kafka_channel_upstream_test.go
@@ -17,7 +17,7 @@
  * limitations under the License.
  */
 
-package e2e_new
+package e2e_new_channel
 
 import (
 	"testing"
diff --git a/test/e2e_new_channel/main_test.go b/test/e2e_new_channel/main_test.go
new file mode 100644
index 000000000..8e4d6e5de
--- /dev/null
+++ b/test/e2e_new_channel/main_test.go
@@ -0,0 +1,71 @@
+//go:build e2e
+// +build e2e
+
+/*
+ * Copyright 2020 The Knative Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package e2e_new_channel
+
+import (
+	"flag"
+	"os"
+	"testing"
+
+	"knative.dev/eventing/test/rekt/resources/channel_impl"
+
+	// Uncomment the following line to load the gcp plugin (only required to authenticate against GKE clusters).
+	_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
+
+	"knative.dev/pkg/injection"
+	_ "knative.dev/pkg/system/testing"
+
+	"knative.dev/reconciler-test/pkg/environment"
+)
+
+// global is the singleton instance of GlobalEnvironment. It is used to parse
+// the testing config for the test run. The config will specify the cluster
+// config as well as the parsing level and state flags.
+var global environment.GlobalEnvironment
+
+func init() {
+	// environment.InitFlags registers state and level filter flags.
+	environment.InitFlags(flag.CommandLine)
+
+	// CHANNEL_GROUP_KIND=KafkaChannel.messaging.knative.dev;CHANNEL_VERSION=v1beta1
+	channel_impl.EnvCfg.ChannelGK = "KafkaChannel.messaging.knative.dev"
+	channel_impl.EnvCfg.ChannelV = "v1beta1"
+}
+
+// TestMain is the first entry point for `go test`.
+func TestMain(m *testing.M) {
+	// We get a chance to parse flags to include the framework flags for the
+	// framework as well as any additional flags included in the integration.
+	flag.Parse()
+
+	// EnableInjectionOrDie will enable client injection, this is used by the
+	// testing framework for namespace management, and could be leveraged by
+	// features to pull Kubernetes clients or the test environment out of the
+	// context passed in the features.
+	ctx, startInformers := injection.EnableInjectionOrDie(nil, nil) //nolint
+	startInformers()
+
+	// global is used to make instances of Environments, NewGlobalEnvironment
+	// is passing and saving the client injection enabled context for use later.
+	global = environment.NewGlobalEnvironment(ctx)
+
+	// Run the tests.
+	os.Exit(m.Run())
+}
diff --git a/test/reconciler-tests.sh b/test/reconciler-tests.sh
index 72636f544..0f823dfe1 100755
--- a/test/reconciler-tests.sh
+++ b/test/reconciler-tests.sh
@@ -23,6 +23,8 @@ export_logs_continuously
 
 go_test_e2e -timeout=1h ./test/e2e_new/... || fail_test "E2E (new) suite failed"
 
+go_test_e2e -tags=e2e,cloudevents -timeout=1h ./test/e2e_new_channel/... || fail_test "E2E (new - KafkaChannel) suite failed"
+
 go_test_e2e -tags=deletecm ./test/e2e_new/... || fail_test "E2E (new deletecm) suite failed"
 
 if ! ${LOCAL_DEVELOPMENT}; then
diff --git a/test/upgrade/postupgrade.go b/test/upgrade/postupgrade.go
index f555ce771..04cf80a79 100644
--- a/test/upgrade/postupgrade.go
+++ b/test/upgrade/postupgrade.go
@@ -32,7 +32,7 @@ func BrokerPostUpgradeTest() pkgupgrade.Operation {
 
 // SinkPostUpgradeTest tests sink basic operations post upgrade.
 func SinkPostUpgradeTest() pkgupgrade.Operation {
-	return pkgupgrade.NewOperation("SinkPostDowngradeTest", func(c pkgupgrade.Context) {
+	return pkgupgrade.NewOperation("SinkPostUpgradeTest", func(c pkgupgrade.Context) {
 		e2e.RunTestKafkaSink(c.T, eventing.ModeBinary, nil)
 	})
 }
diff --git a/test/upgrade/preupgrade.go b/test/upgrade/preupgrade.go
index c46b23f41..1df23a95b 100644
--- a/test/upgrade/preupgrade.go
+++ b/test/upgrade/preupgrade.go
@@ -32,7 +32,7 @@ func BrokerPreUpgradeTest() pkgupgrade.Operation {
 
 // SinkPreUpgradeTest tests sink basic operations pre upgrade.
 func SinkPreUpgradeTest() pkgupgrade.Operation {
-	return pkgupgrade.NewOperation("SinkPostDowngradeTest", func(c pkgupgrade.Context) {
+	return pkgupgrade.NewOperation("SinkPreUpgradeTest", func(c pkgupgrade.Context) {
 		e2e.RunTestKafkaSink(c.T, eventing.ModeBinary, nil)
 	})
 }
diff --git a/third_party/eventing-kafka-latest/channel-crds.yaml b/third_party/eventing-kafka-latest/channel-crds.yaml
index ece583caf..71aafe19a 100644
--- a/third_party/eventing-kafka-latest/channel-crds.yaml
+++ b/third_party/eventing-kafka-latest/channel-crds.yaml
@@ -17,7 +17,7 @@ kind: CustomResourceDefinition
 metadata:
   name: kafkachannels.messaging.knative.dev
   labels:
-    kafka.eventing.knative.dev/release: "v20220113-afceb5404"
+    kafka.eventing.knative.dev/release: "v20220131-a14b76602"
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
diff --git a/third_party/eventing-kafka-latest/source-crd.yaml b/third_party/eventing-kafka-latest/source-crd.yaml
index c070768e7..905329876 100644
--- a/third_party/eventing-kafka-latest/source-crd.yaml
+++ b/third_party/eventing-kafka-latest/source-crd.yaml
@@ -16,7 +16,7 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    kafka.eventing.knative.dev/release: "v20220113-afceb5404"
+    kafka.eventing.knative.dev/release: "v20220131-a14b76602"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
diff --git a/third_party/eventing-latest/eventing-core.yaml b/third_party/eventing-latest/eventing-core.yaml
index 83f275c51..a46bb3de0 100644
--- a/third_party/eventing-latest/eventing-core.yaml
+++ b/third_party/eventing-latest/eventing-core.yaml
@@ -16,8 +16,8 @@ kind: Namespace
 metadata:
   name: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 
 ---
@@ -41,8 +41,8 @@ metadata:
   name: eventing-controller
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -50,8 +50,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -67,8 +67,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -84,8 +84,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-source-observer
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -101,8 +101,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-sources-controller
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -118,8 +118,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-manipulator
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -151,8 +151,8 @@ metadata:
   name: pingsource-mt-adapter
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -160,8 +160,8 @@ kind: ClusterRoleBinding
 metadata:
   name: knative-eventing-pingsource-mt-adapter
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -193,8 +193,8 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -202,8 +202,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -220,8 +220,8 @@ metadata:
   namespace: knative-eventing
   name: eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -237,8 +237,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -254,8 +254,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook-podspecable-binding
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -287,8 +287,8 @@ metadata:
   name: config-br-default-channel
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 data:
   channel-template-spec: |
@@ -316,8 +316,8 @@ metadata:
   name: config-br-defaults
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 data:
   # Configures the default for any Broker that does not specify a spec.config or Broker class.
@@ -354,8 +354,8 @@ metadata:
   name: default-ch-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 data:
   # Configuration for defaulting channels that do not specify CRD implementations.
@@ -389,10 +389,10 @@ metadata:
   name: config-ping-defaults
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
   annotations:
     knative.dev/example-checksum: "9185c153"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 data:
   _example: |
@@ -436,10 +436,10 @@ metadata:
   name: config-features
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 data:
   # ALPHA feature: The kreference-group allows you to use the Group field in KReferences.
@@ -483,7 +483,7 @@ metadata:
   name: config-kreference-mapping
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
   annotations:
@@ -532,8 +532,8 @@ metadata:
   name: config-leader-election
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "f7948630"
@@ -594,10 +594,10 @@ metadata:
   name: config-logging
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 data:
   # Common configuration for all Knative codebase
@@ -648,10 +648,10 @@ metadata:
   name: config-observability
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "f46cf09d"
@@ -725,10 +725,10 @@ metadata:
   name: config-tracing
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "0492ceb0"
@@ -783,10 +783,10 @@ metadata:
   name: eventing-controller
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/high-availability: "true"
     app.kubernetes.io/component: eventing-controller
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -796,9 +796,9 @@ spec:
     metadata:
       labels:
         app: eventing-controller
-        eventing.knative.dev/release: "v20220122-f07487898"
+        eventing.knative.dev/release: "v20220131-7a44b07f2"
         app.kubernetes.io/component: eventing-autoscaler
-        app.kubernetes.io/version: "20220122-f07487898"
+        app.kubernetes.io/version: "20220131-7a44b07f2"
         app.kubernetes.io/name: knative-eventing
     spec:
       # To avoid node becoming SPOF, spread our replicas to different nodes.
@@ -816,7 +816,7 @@ spec:
       containers:
         - name: eventing-controller
           terminationMessagePolicy: FallbackToLogsOnError
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/controller@sha256:d51f4e8a1e19a657fdccde63a465d4a4fd00240faa73d847e13d8c96f327ce87
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/controller@sha256:69d2d30440ed84ebc50be23694ca194646fa08411ddbe93487bc003090a52d9c
           resources:
             requests:
               cpu: 100m
@@ -834,7 +834,7 @@ spec:
               value: knative.dev/eventing
             # APIServerSource
             - name: APISERVER_RA_IMAGE
-              value: gcr.io/knative-nightly/knative.dev/eventing/cmd/apiserver_receive_adapter@sha256:c0bde79565c48e297ebf9c7072b205a7127a5090ca2a3e9285f6456555a45bee
+              value: gcr.io/knative-nightly/knative.dev/eventing/cmd/apiserver_receive_adapter@sha256:72b6206cf15de6cfdb16217a17ec5d8e0184dd3a14c206861ab16ad5d94802ce
             - name: POD_NAME
               valueFrom:
                 fieldRef:
@@ -883,9 +883,9 @@ metadata:
   name: pingsource-mt-adapter
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     app.kubernetes.io/component: pingsource-mt-adapter
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   # when set to 0 (and only 0) will be set to 1 when the first PingSource is created.
@@ -898,9 +898,9 @@ spec:
     metadata:
       labels:
         !!merge <<: *labels
-        eventing.knative.dev/release: "v20220122-f07487898"
+        eventing.knative.dev/release: "v20220131-7a44b07f2"
         app.kubernetes.io/component: pingsource-mt-adapter
-        app.kubernetes.io/version: "20220122-f07487898"
+        app.kubernetes.io/version: "20220131-7a44b07f2"
         app.kubernetes.io/name: knative-eventing
     spec:
       affinity:
@@ -914,7 +914,7 @@ spec:
       enableServiceLinks: false
       containers:
         - name: dispatcher
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/mtping@sha256:17f30435a9f39d3121263186c90927a869437d7d7babe51fe1fbecfcececc9fe
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/mtping@sha256:744060290509d1172fbaaded191bf1b5b631f835de27662c6bfe62358526ebaa
           env:
             - name: SYSTEM_NAMESPACE
               value: ''
@@ -979,9 +979,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   scaleTargetRef:
@@ -1005,9 +1005,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   minAvailable: 80%
@@ -1036,9 +1036,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -1049,9 +1049,9 @@ spec:
     metadata:
       labels:
         !!merge <<: *labels
-        eventing.knative.dev/release: "v20220122-f07487898"
+        eventing.knative.dev/release: "v20220131-7a44b07f2"
         app.kubernetes.io/component: eventing-webhook
-        app.kubernetes.io/version: "20220122-f07487898"
+        app.kubernetes.io/version: "20220131-7a44b07f2"
         app.kubernetes.io/name: knative-eventing
     spec:
       # To avoid node becoming SPOF, spread our replicas to different nodes.
@@ -1071,7 +1071,7 @@ spec:
           terminationMessagePolicy: FallbackToLogsOnError
           # This is the Go import path for the binary that is containerized
           # and substituted here.
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/webhook@sha256:ace72d0992e9526b1ea7825eb7647809a4eeb3f6d1f71ff36fc10c92dfd11e0b
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/webhook@sha256:cff89e978a3ecb1e6a3af700525a832058feccf5ec769ce111da673d9fa9b80f
           resources:
             requests:
               # taken from serving.
@@ -1140,10 +1140,10 @@ apiVersion: v1
 kind: Service
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     role: eventing-webhook
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   name: eventing-webhook
   namespace: knative-eventing
@@ -1175,11 +1175,11 @@ kind: CustomResourceDefinition
 metadata:
   creationTimestamp: null
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -1391,10 +1391,10 @@ kind: CustomResourceDefinition
 metadata:
   name: brokers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -1558,11 +1558,11 @@ kind: CustomResourceDefinition
 metadata:
   name: channels.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -1830,11 +1830,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   name: containersources.sources.knative.dev
 spec:
@@ -1984,9 +1984,9 @@ kind: CustomResourceDefinition
 metadata:
   name: eventtypes.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -2113,10 +2113,10 @@ kind: CustomResourceDefinition
 metadata:
   name: parallels.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -2368,11 +2368,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -2559,10 +2559,10 @@ kind: CustomResourceDefinition
 metadata:
   name: sequences.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -2879,12 +2879,12 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   name: sinkbindings.sources.knative.dev
 spec:
@@ -3071,9 +3071,9 @@ kind: CustomResourceDefinition
 metadata:
   name: subscriptions.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -3283,9 +3283,9 @@ kind: CustomResourceDefinition
 metadata:
   name: triggers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -3469,8 +3469,8 @@ kind: ClusterRole
 metadata:
   name: addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -3483,9 +3483,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: service-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3503,9 +3503,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: serving-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3526,9 +3526,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: channel-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3553,9 +3553,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: broker-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3574,9 +3574,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: flows-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3612,8 +3612,8 @@ kind: ClusterRole
 metadata:
   name: eventing-broker-filter
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3639,8 +3639,8 @@ kind: ClusterRole
 metadata:
   name: eventing-broker-ingress
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3657,8 +3657,8 @@ kind: ClusterRole
 metadata:
   name: eventing-config-reader
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3691,8 +3691,8 @@ kind: ClusterRole
 metadata:
   name: channelable-manipulator
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -3705,9 +3705,9 @@ kind: ClusterRole
 metadata:
   name: meta-channelable-manipulator
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/channelable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "channelable-manipulator" role.
 rules:
@@ -3745,9 +3745,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-eventing-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev"]
@@ -3759,9 +3759,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-messaging-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["messaging.knative.dev"]
@@ -3773,9 +3773,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-flows-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["flows.knative.dev"]
@@ -3787,9 +3787,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-sources-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["sources.knative.dev"]
@@ -3801,9 +3801,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-bindings-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["bindings.knative.dev"]
@@ -3816,8 +3816,8 @@ metadata:
   name: knative-eventing-namespaced-edit
   labels:
     rbac.authorization.k8s.io/aggregate-to-edit: "true"
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev", "messaging.knative.dev", "sources.knative.dev", "flows.knative.dev", "bindings.knative.dev"]
@@ -3830,8 +3830,8 @@ metadata:
   name: knative-eventing-namespaced-view
   labels:
     rbac.authorization.k8s.io/aggregate-to-view: "true"
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev", "messaging.knative.dev", "sources.knative.dev", "flows.knative.dev", "bindings.knative.dev"]
@@ -3858,8 +3858,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-controller
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3994,8 +3994,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-pingsource-mt-adapter
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4062,8 +4062,8 @@ kind: ClusterRole
 metadata:
   name: podspecable-binding
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -4076,9 +4076,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: builtin-podspecable-binding
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/podspecable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "podspecable-binding role.
 rules:
@@ -4124,8 +4124,8 @@ kind: ClusterRole
 metadata:
   name: source-observer
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -4138,9 +4138,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: eventing-sources-source-observer
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     duck.knative.dev/source: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "source-observer" role.
 rules:
@@ -4176,8 +4176,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-sources-controller
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4263,8 +4263,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   # For watching logging configuration and getting certs.
@@ -4363,8 +4363,8 @@ metadata:
   namespace: knative-eventing
   name: knative-eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 rules:
   # For manipulating certs into secrets.
@@ -4400,8 +4400,8 @@ kind: ValidatingWebhookConfiguration
 metadata:
   name: config.webhook.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4438,8 +4438,8 @@ kind: MutatingWebhookConfiguration
 metadata:
   name: webhook.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4472,8 +4472,8 @@ kind: ValidatingWebhookConfiguration
 metadata:
   name: validation.webhook.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4507,8 +4507,8 @@ metadata:
   name: eventing-webhook-certs
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 # The data is populated at install time.
 
@@ -4532,8 +4532,8 @@ kind: MutatingWebhookConfiguration
 metadata:
   name: sinkbindings.webhook.sources.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
-    app.kubernetes.io/version: "20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
diff --git a/third_party/eventing-latest/eventing-crds.yaml b/third_party/eventing-latest/eventing-crds.yaml
index 9c9f22eff..99b7e5a89 100644
--- a/third_party/eventing-latest/eventing-crds.yaml
+++ b/third_party/eventing-latest/eventing-crds.yaml
@@ -17,11 +17,11 @@ kind: CustomResourceDefinition
 metadata:
   creationTimestamp: null
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -233,10 +233,10 @@ kind: CustomResourceDefinition
 metadata:
   name: brokers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -400,11 +400,11 @@ kind: CustomResourceDefinition
 metadata:
   name: channels.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -672,11 +672,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   name: containersources.sources.knative.dev
 spec:
@@ -826,9 +826,9 @@ kind: CustomResourceDefinition
 metadata:
   name: eventtypes.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -955,10 +955,10 @@ kind: CustomResourceDefinition
 metadata:
   name: parallels.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -1210,11 +1210,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -1401,10 +1401,10 @@ kind: CustomResourceDefinition
 metadata:
   name: sequences.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -1721,12 +1721,12 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
   name: sinkbindings.sources.knative.dev
 spec:
@@ -1913,9 +1913,9 @@ kind: CustomResourceDefinition
 metadata:
   name: subscriptions.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -2125,9 +2125,9 @@ kind: CustomResourceDefinition
 metadata:
   name: triggers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220122-f07487898"
+    eventing.knative.dev/release: "v20220131-7a44b07f2"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220122-f07487898"
+    app.kubernetes.io/version: "20220131-7a44b07f2"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev