Repository: knative-sandbox/eventing-kafka-broker
Pull request #1888 (2022-02-10 11:05:31)

[Automated] Update eventing-kafka-broker-eventing nightly
/assign @knative/delivery-wg-leads
/cc @knative/delivery-wg-leads

Produced via:
```shell
for x in eventing-crds.yaml eventing-core.yaml; do
  curl https://storage.googleapis.com/knative-nightly/eventing/latest/$x > ${GITHUB_WORKSPACE}/./third_party/eventing-latest/$x
done
```

Details:
```

```

knative-prow-robot: @knative-automation: GitHub didn't allow me to request PR reviews from the following users: knative/delivery-wg-leads.

Note that only [knative-sandbox members](https://github.com/orgs/knative-sandbox/people) and repo collaborators can review this PR, and authors cannot review their own PRs.

<details>

In response to [this](https://github.com/knative-sandbox/eventing-kafka-broker/pull/1888):

>/assign @knative/delivery-wg-leads
>/cc @knative/delivery-wg-leads
>
>Produced via:
>```shell
>for x in eventing-crds.yaml eventing-core.yaml; do
>  curl https://storage.googleapis.com/knative-nightly/eventing/latest/$x > ${GITHUB_WORKSPACE}/./third_party/eventing-latest/$x
>done
>```
>
>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/1888#" title="Author self-approved">knative-automation</a>*
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please assign **xtreme-sameer-vohra** after the PR has been reviewed.
You can assign the PR to them by writing `/assign @xtreme-sameer-vohra` 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":["xtreme-sameer-vohra"]} -->
codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) Report
> Merging [#1888](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (2b50ea2) into [main](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/commit/3bafdc686c83203e3031353c24024f6863adfeff?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (3bafdc6) will **increase** coverage by `0.10%`.
> The diff coverage is `n/a`.

[![Impacted file tree graph](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888/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/1888?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    #1888      +/-   ##
============================================
+ Coverage     66.99%   67.10%   +0.10%     
- Complexity      616      617       +1     
============================================
  Files           135      135              
  Lines          5757     5757              
  Branches        178      178              
============================================
+ Hits           3857     3863       +6     
+ Misses         1585     1580       -5     
+ Partials        315      314       -1     
```

| Flag | Coverage Δ | |
|---|---|---|
| java-unittests | `82.16% <ø> (+0.04%)` | :arrow_up: |

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/1888?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) | Coverage Δ | |
|---|---|---|
| [...lane/pkg/reconciler/consumergroup/consumergroup.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9jb25zdW1lcmdyb3VwL2NvbnN1bWVyZ3JvdXAuZ28=) | `75.92% <0.00%> (ø)` | |
| [...tcher/impl/consumer/UnorderedConsumerVerticle.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvaW1wbC9jb25zdW1lci9Vbm9yZGVyZWRDb25zdW1lclZlcnRpY2xlLmphdmE=) | `91.30% <0.00%> (+4.34%)` | :arrow_up: |
| [control-plane/pkg/prober/cache.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcHJvYmVyL2NhY2hlLmdv) | `100.00% <0.00%> (+4.76%)` | :arrow_up: |
| [control-plane/pkg/prober/prober.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcHJvYmVyL3Byb2Jlci5nbw==) | `75.00% <0.00%> (+15.00%)` | :arrow_up: |

------

[Continue to review full report at Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888?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/1888?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Last update [3bafdc6...2b50ea2](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1888?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: @knative-automation: 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-channel-integration-tests-sasl-ssl | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl/1491730044857356288) | true | `/test pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl`

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

<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 -->
knative-prow-robot: @knative-automation: The following tests **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-channel-integration-tests-sasl-ssl | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl/1491730044857356288) | true | `/test pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl`
pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-ssl | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-ssl/1491730044823801856) | true | `/test pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-ssl`

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

<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 -->
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/1888#" title="Author self-approved">knative-automation</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/1888#pullrequestreview-879790977" 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":[]} -->
matzew: /retest
knative-prow-robot: @knative-automation: 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-unit-tests | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-unit-tests/1492046594239893504) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-unit-tests`

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

<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 -->
knative-prow-robot: @knative-automation: The following tests **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-unit-tests | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-unit-tests/1492046594239893504) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-unit-tests`
pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl/1492046594407665664) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl`

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

<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 -->
knative-prow-robot: @knative-automation: The following tests **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-unit-tests | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-unit-tests/1492046594239893504) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-unit-tests`
pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl/1492046594407665664) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl`
pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-plain | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-plain/1492046594378305536) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-plain`

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

<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 -->
knative-prow-robot: New changes are detected. LGTM label has been removed.
knative-prow-robot: @knative-automation: The following tests **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-channel-reconciler-tests-ssl | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl/1492046594407665664) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-channel-reconciler-tests-ssl`
pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-plain | 2b50ea23a97cfa2ab5925f619d6e9ca2970d3d06 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-plain/1492046594378305536) | unknown | `/test pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-plain`
pull-knative-sandbox-eventing-kafka-broker-unit-tests | 35a055903ea3df40218acc53029ae82ab2fc54fe | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-unit-tests/1492092439668723712) | true | `/test pull-knative-sandbox-eventing-kafka-broker-unit-tests`

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

<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 -->
knative-prow-robot: @knative-automation: The following tests **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-integration-tests | 35a055903ea3df40218acc53029ae82ab2fc54fe | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-integration-tests/1492092439706472448) | true | `/test pull-knative-sandbox-eventing-kafka-broker-integration-tests`
pull-knative-sandbox-eventing-kafka-broker-reconciler-tests | 856ef9c17596820c3557b0ecdc303718f9585ee6 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-reconciler-tests/1493179533858181120) | true | `/test pull-knative-sandbox-eventing-kafka-broker-reconciler-tests`

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

<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 -->
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/1888#" title="Author self-approved">knative-automation</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/1888#pullrequestreview-882491982" 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: New changes are detected. LGTM label has been removed.
knative-prow-robot: @knative-automation: The following tests **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-reconciler-tests | 856ef9c17596820c3557b0ecdc303718f9585ee6 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-reconciler-tests/1493179533858181120) | true | `/test pull-knative-sandbox-eventing-kafka-broker-reconciler-tests`
pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl | c4345b1b793718618dd3501a6a1dd62f1eafe43f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl/1493542833422864384) | true | `/test pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl`

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

<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 -->
knative-prow-robot: @knative-automation: The following tests **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-channel-integration-tests-sasl-ssl | c4345b1b793718618dd3501a6a1dd62f1eafe43f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl/1493542833422864384) | true | `/test pull-knative-sandbox-eventing-kafka-broker-channel-integration-tests-sasl-ssl`
pull-knative-sandbox-eventing-kafka-broker-upgrade-tests | c4345b1b793718618dd3501a6a1dd62f1eafe43f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1888/pull-knative-sandbox-eventing-kafka-broker-upgrade-tests/1493542833301229568) | true | `/test pull-knative-sandbox-eventing-kafka-broker-upgrade-tests`

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

<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 -->

Patch:
diff --git a/control-plane/cmd/post-install/kafka_source_deleter.go b/control-plane/cmd/post-install/kafka_source_deleter.go
new file mode 100644
index 000000000..0ad5f1672
--- /dev/null
+++ b/control-plane/cmd/post-install/kafka_source_deleter.go
@@ -0,0 +1,140 @@
+/*
+ * Copyright 2022 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 main
+
+import (
+	"context"
+	"fmt"
+
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+	"knative.dev/pkg/system"
+)
+
+type kafkaSourceDeleter struct {
+	k8s kubernetes.Interface
+}
+
+func (d *kafkaSourceDeleter) Delete(ctx context.Context) error {
+	// Delete mutatingwebhookconfigurations.admissionregistration.k8s.io/defaulting.webhook.kafka.sources.knative.dev
+	const sourceMutatingWebhookConfigurationName = "defaulting.webhook.kafka.sources.knative.dev"
+	err := d.k8s.
+		AdmissionregistrationV1().
+		MutatingWebhookConfigurations().
+		Delete(ctx, sourceMutatingWebhookConfigurationName, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete mutating webhook configuration %s: %w", sourceMutatingWebhookConfigurationName, err)
+	}
+
+	// Delete validatingwebhookconfigurations.admissionregistration.k8s.io/validation.webhook.kafka.sources.knative.dev
+	const sourceValidatingWebhookConfigurationName = "validation.webhook.kafka.sources.knative.dev"
+	err = d.k8s.
+		AdmissionregistrationV1().
+		ValidatingWebhookConfigurations().
+		Delete(ctx, sourceValidatingWebhookConfigurationName, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete validating webhook configuration %s: %w", sourceMutatingWebhookConfigurationName, err)
+	}
+
+	// Delete validatingwebhookconfigurations.admissionregistration.k8s.io/config.webhook.kafka.sources.knative.dev
+	const sourceConfigValidatingWebhookConfigurationName = "config.webhook.kafka.sources.knative.dev"
+	err = d.k8s.
+		AdmissionregistrationV1().
+		ValidatingWebhookConfigurations().
+		Delete(ctx, sourceConfigValidatingWebhookConfigurationName, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete validating webhook configuration %s: %w", sourceConfigValidatingWebhookConfigurationName, err)
+	}
+
+	// Delete service knative-eventing/kafka-source-webhook
+	const sourceWebhookServiceName = "kafka-source-webhook"
+	err = d.k8s.
+		CoreV1().
+		Services(system.Namespace()).
+		Delete(ctx, sourceWebhookServiceName, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete service %s/%s: %w", system.Namespace(), sourceWebhookServiceName, err)
+	}
+
+	// Delete service knative-eventing/kafka-controller
+	const sourceControllerServiceName = "kafka-controller"
+	err = d.k8s.
+		CoreV1().
+		Services(system.Namespace()).
+		Delete(ctx, sourceControllerServiceName, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete service %s/%s: %w", system.Namespace(), sourceControllerServiceName, err)
+	}
+
+	// Delete deployment.apps/kafka-controller-manager
+	const sourceControllerDeploymentName = "kafka-controller-manager"
+	err = d.k8s.
+		AppsV1().
+		Deployments(system.Namespace()).
+		Delete(ctx, sourceControllerDeploymentName, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete deployment %s/%s: %w", system.Namespace(), sourceControllerDeploymentName, err)
+	}
+
+	const kafkaControllerClusterRoleBinding = "eventing-sources-kafka-controller"
+	err = d.k8s.
+		RbacV1().
+		ClusterRoleBindings().
+		Delete(ctx, kafkaControllerClusterRoleBinding, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete ClusterRoleBinding %s: %w", kafkaControllerClusterRoleBinding, err)
+	}
+
+	const kafkaControllerAddressableResolverClusterRoleBinding = "eventing-sources-kafka-controller-addressable-resolver"
+	err = d.k8s.
+		RbacV1().
+		ClusterRoleBindings().
+		Delete(ctx, kafkaControllerAddressableResolverClusterRoleBinding, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete ClusterRoleBinding %s: %w", kafkaControllerAddressableResolverClusterRoleBinding, err)
+	}
+
+	const kafkaControllerClusterRole = "eventing-sources-kafka-controller"
+	err = d.k8s.
+		RbacV1().
+		ClusterRoles().
+		Delete(ctx, kafkaControllerClusterRole, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete ClusterRole %s: %w", kafkaControllerClusterRole, err)
+	}
+
+	const kafkaControllerServiceAccount = "kafka-controller-manager"
+	err = d.k8s.
+		CoreV1().
+		ServiceAccounts(system.Namespace()).
+		Delete(ctx, kafkaControllerServiceAccount, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete service account %s/%s: %w", system.Namespace(), kafkaControllerServiceAccount, err)
+	}
+
+	const kafkaSourceWebhookSecret = "kafka-source-webhook-certs"
+	err = d.k8s.
+		CoreV1().
+		Secrets(system.Namespace()).
+		Delete(ctx, kafkaSourceWebhookSecret, metav1.DeleteOptions{})
+	if err != nil && !apierrors.IsNotFound(err) {
+		return fmt.Errorf("failed to delete secret %s/%s: %w", system.Namespace(), kafkaSourceWebhookSecret, err)
+	}
+
+	return nil
+}
diff --git a/control-plane/cmd/post-install/main.go b/control-plane/cmd/post-install/main.go
index 7442b5be6..90e3cdd36 100644
--- a/control-plane/cmd/post-install/main.go
+++ b/control-plane/cmd/post-install/main.go
@@ -58,10 +58,20 @@ func run(ctx context.Context) error {
 		return fmt.Errorf("failed to get kubeconfig: %w", err)
 	}
 
-	migrator := &KafkaSourceMigrator{
+	sourceMigrator := &KafkaSourceMigrator{
 		kcs: kcs.NewForConfigOrDie(config),
 		k8s: kubernetes.NewForConfigOrDie(config),
 	}
+	if err := sourceMigrator.Migrate(ctx); err != nil {
+		return fmt.Errorf("source migration failed: %w", err)
+	}
+
+	sourceDeleter := &kafkaSourceDeleter{
+		k8s: kubernetes.NewForConfigOrDie(config),
+	}
+	if err := sourceDeleter.Delete(ctx); err != nil {
+		return fmt.Errorf("source migration failed: %w", err)
+	}
 
-	return migrator.Migrate(ctx)
+	return nil
 }
diff --git a/control-plane/config/post-install/200-controller-cluster-role.yaml b/control-plane/config/post-install/200-controller-cluster-role.yaml
index 09c9707e2..9b1d9ff2b 100644
--- a/control-plane/config/post-install/200-controller-cluster-role.yaml
+++ b/control-plane/config/post-install/200-controller-cluster-role.yaml
@@ -38,3 +38,77 @@ rules:
     verbs:
       - get
       - list
+
+  - apiGroups:
+      - admissionregistration.k8s.io
+    resources:
+      - mutatingwebhookconfigurations
+    resourceNames:
+      - defaulting.webhook.kafka.sources.knative.dev
+    verbs:
+      - delete
+
+  - apiGroups:
+      - admissionregistration.k8s.io
+    resources:
+      - validatingwebhookconfigurations
+    resourceNames:
+      - validation.webhook.kafka.sources.knative.dev
+      - config.webhook.kafka.sources.knative.dev
+    verbs:
+      - delete
+
+  - apiGroups:
+      - "*"
+    resources:
+      - services
+    resourceNames:
+      - kafka-source-webhook
+      - kafka-controller
+    verbs:
+      - delete
+
+  - apiGroups:
+      - apps
+    resources:
+      - deployments
+    resourceNames:
+      - kafka-controller-manager
+    verbs:
+      - delete
+
+  - apiGroups:
+      - rbac.authorization.k8s.io
+    resources:
+      - clusterrolebindings
+    resourceNames:
+      - eventing-sources-kafka-controller
+      - eventing-sources-kafka-controller-addressable-resolver
+    verbs:
+      - delete
+  - apiGroups:
+      - rbac.authorization.k8s.io
+    resources:
+      - clusterroles
+    resourceNames:
+      - eventing-sources-kafka-controller
+    verbs:
+      - delete
+
+  - apiGroups:
+      - "*"
+    resources:
+      - serviceaccounts
+    resourceNames:
+      - kafka-controller-manager
+    verbs:
+      - delete
+
+  - apiGroups:
+      - "*"
+    resources:
+      - secrets
+    resourceNames:
+      - kafka-source-webhook-certs
+    verbs:
+      - delete
diff --git a/control-plane/config/post-install/500-post-install-job.yaml b/control-plane/config/post-install/500-post-install-job.yaml
index 89798e8c8..53f970550 100644
--- a/control-plane/config/post-install/500-post-install-job.yaml
+++ b/control-plane/config/post-install/500-post-install-job.yaml
@@ -36,3 +36,8 @@ spec:
       containers:
         - name: post-install
           image: ko://knative.dev/eventing-kafka-broker/control-plane/cmd/post-install
+          env:
+            - name: SYSTEM_NAMESPACE
+              valueFrom:
+                fieldRef:
+                  fieldPath: metadata.namespace
diff --git a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_types.go b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_types.go
index d28346249..7beb3bd2d 100644
--- a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_types.go
+++ b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_types.go
@@ -98,22 +98,28 @@ type ConsumerSpec struct {
 	CloudEventOverrides *duckv1.CloudEventOverrides `json:"ceOverrides,omitempty"`
 
 	// VReplicas is the number of virtual replicas for a consumer.
-	VReplicas *int32
+	VReplicas *int32 `json:"vReplicas"`
 
 	// PodBind represents a reference to the pod in which the consumer should be placed.
 	PodBind *PodBind `json:"podBind"`
 }
 
 type ReplyStrategy struct {
-	TopicReply *TopicReply
-	URLReply   *DestinationReply
-	NoReply    *struct{}
+	TopicReply *TopicReply       `json:"topicReply,omitempty"`
+	URLReply   *DestinationReply `json:"URLReply,omitempty"`
+	NoReply    *NoReply          `json:"noReply,omitempty"`
+}
+
+type NoReply struct {
+	Enabled bool `json:"enabled"`
 }
 
 type TopicReply struct {
+	Enabled bool `json:"enabled"`
 }
 
 type DestinationReply struct {
+	Enabled     bool `json:"enabled"`
 	Destination duckv1.Destination
 }
 
diff --git a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_validation.go b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_validation.go
index f8dd77591..db02d7e4b 100644
--- a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_validation.go
+++ b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_validation.go
@@ -45,6 +45,7 @@ func (cs *ConsumerSpec) Validate(ctx context.Context) *apis.FieldError {
 		cs.Subscriber.Validate(ctx).ViaField("subscriber"),
 		cs.PodBind.Validate(ctx).ViaField("podBind"),
 		cs.CloudEventOverrides.Validate(ctx).ViaField("ceOverrides"),
+		cs.Reply.Validate(ctx).ViaField("reply"),
 	)
 	return err
 }
@@ -73,6 +74,27 @@ func (f *Filters) Validate(ctx context.Context) *apis.FieldError {
 	return nil
 }
 
+func (in *ReplyStrategy) Validate(ctx context.Context) *apis.FieldError {
+	if in == nil {
+		return nil
+	}
+	setCounter := 0
+	if in.TopicReply != nil && in.TopicReply.Enabled {
+		setCounter++
+	}
+	if in.URLReply != nil && in.URLReply.Enabled {
+		setCounter++
+	}
+	if in.NoReply != nil && in.NoReply.Enabled {
+		setCounter++
+	}
+
+	if setCounter > 1 {
+		return apis.ErrMultipleOneOf("topicReply", "URLReply", "NoReply")
+	}
+	return nil
+}
+
 func (p *PodBind) Validate(ctx context.Context) *apis.FieldError {
 	if p == nil {
 		return apis.ErrMissingField("")
diff --git a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/zz_generated.deepcopy.go b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/zz_generated.deepcopy.go
index 42bfddaa6..2498b1e2d 100644
--- a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/zz_generated.deepcopy.go
+++ b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/zz_generated.deepcopy.go
@@ -451,6 +451,22 @@ func (in *Filters) DeepCopy() *Filters {
 	return out
 }
 
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *NoReply) DeepCopyInto(out *NoReply) {
+	*out = *in
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NoReply.
+func (in *NoReply) DeepCopy() *NoReply {
+	if in == nil {
+		return nil
+	}
+	out := new(NoReply)
+	in.DeepCopyInto(out)
+	return out
+}
+
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
 func (in *PodBind) DeepCopyInto(out *PodBind) {
 	*out = *in
@@ -482,7 +498,7 @@ func (in *ReplyStrategy) DeepCopyInto(out *ReplyStrategy) {
 	}
 	if in.NoReply != nil {
 		in, out := &in.NoReply, &out.NoReply
-		*out = new(struct{})
+		*out = new(NoReply)
 		**out = **in
 	}
 	return
diff --git a/control-plane/pkg/reconciler/channel/channel.go b/control-plane/pkg/reconciler/channel/channel.go
index 57fb269c2..d63fee73b 100644
--- a/control-plane/pkg/reconciler/channel/channel.go
+++ b/control-plane/pkg/reconciler/channel/channel.go
@@ -430,7 +430,7 @@ func (r *Reconciler) reconcileSubscribers(ctx context.Context, kafkaClient saram
 				UID:                s.UID,
 				ObservedGeneration: s.Generation,
 				Ready:              corev1.ConditionFalse,
-				Message:            fmt.Sprint("Subscription not ready", err),
+				Message:            fmt.Sprintf("Subscription not ready: %v", err),
 			})
 			globalErr = multierr.Append(globalErr, err)
 		} else {
@@ -479,8 +479,13 @@ func (r *Reconciler) reconcileInitialOffset(ctx context.Context, channel *messag
 }
 
 func (r *Reconciler) getSubscriberConfig(ctx context.Context, channel *messagingv1beta1.KafkaChannel, subscriber *v1.SubscriberSpec) (*contract.Egress, error) {
+	subscriberURI := subscriber.SubscriberURI.String()
+	if subscriberURI == "" {
+		return nil, fmt.Errorf("failed to resolve Subscription.Spec.Subscriber: empty subscriber URI")
+	}
+
 	egress := &contract.Egress{
-		Destination:   subscriber.SubscriberURI.String(),
+		Destination:   subscriberURI,
 		ConsumerGroup: consumerGroup(channel, subscriber),
 		DeliveryOrder: DefaultDeliveryOrder,
 		Uid:           string(subscriber.UID),
diff --git a/control-plane/pkg/reconciler/consumer/consumer.go b/control-plane/pkg/reconciler/consumer/consumer.go
index d225b5966..b4b58c264 100644
--- a/control-plane/pkg/reconciler/consumer/consumer.go
+++ b/control-plane/pkg/reconciler/consumer/consumer.go
@@ -252,11 +252,11 @@ func (r Reconciler) reconcileReplyStrategy(ctx context.Context, c *kafkainternal
 	if c.Spec.Reply == nil {
 		return nil
 	}
-	if c.Spec.Reply.NoReply != nil {
+	if c.Spec.Reply.NoReply != nil && c.Spec.Reply.NoReply.Enabled {
 		egress.ReplyStrategy = &contract.Egress_DiscardReply{}
 		return nil
 	}
-	if c.Spec.Reply.URLReply != nil {
+	if c.Spec.Reply.URLReply != nil && c.Spec.Reply.URLReply.Enabled {
 		destination, err := r.Resolver.URIFromDestinationV1(ctx, c.Spec.Reply.URLReply.Destination, c)
 		if err != nil {
 			return fmt.Errorf("failed to resolve reply destination: %w", err)
@@ -266,7 +266,7 @@ func (r Reconciler) reconcileReplyStrategy(ctx context.Context, c *kafkainternal
 		}
 		return nil
 	}
-	if c.Spec.Reply.TopicReply != nil {
+	if c.Spec.Reply.TopicReply != nil && c.Spec.Reply.TopicReply.Enabled {
 		egress.ReplyStrategy = &contract.Egress_ReplyToOriginalTopic{}
 		return nil
 	}
diff --git a/control-plane/pkg/reconciler/source/v2/sourcev2.go b/control-plane/pkg/reconciler/source/v2/sourcev2.go
index 88e1e1e20..6558ccf0a 100644
--- a/control-plane/pkg/reconciler/source/v2/sourcev2.go
+++ b/control-plane/pkg/reconciler/source/v2/sourcev2.go
@@ -114,6 +114,7 @@ func (r Reconciler) reconcileConsumerGroup(ctx context.Context, ks *sources.Kafk
 						Ordering: DefaultDeliveryOrder,
 					},
 					Subscriber: ks.Spec.Sink,
+					Reply:      &internalscg.ReplyStrategy{NoReply: &internalscg.NoReply{Enabled: true}},
 				},
 			},
 			Replicas: ks.Spec.Consumers,
diff --git a/control-plane/pkg/reconciler/trigger/v2/triggerv2.go b/control-plane/pkg/reconciler/trigger/v2/triggerv2.go
index eade6ff7b..0e19e9b78 100644
--- a/control-plane/pkg/reconciler/trigger/v2/triggerv2.go
+++ b/control-plane/pkg/reconciler/trigger/v2/triggerv2.go
@@ -140,6 +140,7 @@ func (r Reconciler) reconcileConsumerGroup(ctx context.Context, trigger *eventin
 						Filters: trigger.Spec.Filters,
 					},
 					Subscriber: trigger.Spec.Subscriber,
+					Reply:      &internalscg.ReplyStrategy{TopicReply: &internalscg.TopicReply{Enabled: true}},
 				},
 			},
 		},
diff --git a/data-plane/THIRD-PARTY.txt b/data-plane/THIRD-PARTY.txt
index 6096322d8..deca8a008 100644
--- a/data-plane/THIRD-PARTY.txt
+++ b/data-plane/THIRD-PARTY.txt
@@ -154,7 +154,7 @@ Lists of 158 third-party dependencies.
      (Apache-2.0) Scala Compiler (org.scala-lang:scala-reflect:2.12.13 - https://www.scala-lang.org/)
      (Apache-2.0) scala-collection-compat (org.scala-lang.modules:scala-collection-compat_2.12:2.3.0 - http://www.scala-lang.org/)
      (Apache-2.0) scala-java8-compat (org.scala-lang.modules:scala-java8-compat_2.12:0.9.1 - http://www.scala-lang.org/)
-     (MIT License) SLF4J API Module (org.slf4j:slf4j-api:1.7.35 - http://www.slf4j.org)
-     (MIT License) SLF4J NOP Binding (org.slf4j:slf4j-nop:1.7.35 - http://www.slf4j.org)
+     (MIT License) SLF4J API Module (org.slf4j:slf4j-api:1.7.36 - http://www.slf4j.org)
+     (MIT License) SLF4J NOP Binding (org.slf4j:slf4j-nop:1.7.36 - http://www.slf4j.org)
      (Apache-2.0) snappy-java (org.xerial.snappy:snappy-java:1.1.8.1 - https://github.com/xerial/snappy-java)
      (Apache License, Version 2.0) SnakeYAML (org.yaml:snakeyaml:1.28 - http://www.snakeyaml.org)
diff --git a/data-plane/pom.xml b/data-plane/pom.xml
index a80f071ad..0c2d2f173 100644
--- a/data-plane/pom.xml
+++ b/data-plane/pom.xml
@@ -47,7 +47,7 @@
     <opentelemetry.version>1.11.0</opentelemetry.version>
     <jackson.version>2.13.1</jackson.version>
     <protobuf.version>3.19.4</protobuf.version>
-    <slf4j.version>1.7.35</slf4j.version>
+    <slf4j.version>1.7.36</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>
     <assertj.version>3.22.0</assertj.version>
diff --git a/hack/release.sh b/hack/release.sh
index e6a82d0ac..b47f0f00d 100755
--- a/hack/release.sh
+++ b/hack/release.sh
@@ -66,6 +66,7 @@ function build_release() {
     "${EVENTING_KAFKA_SINK_PROMETHEUS_OPERATOR_ARTIFACT}"
     "${EVENTING_KAFKA_CHANNEL_ARTIFACT}"
     "${EVENTING_KAFKA_CHANNEL_PROMETHEUS_OPERATOR_ARTIFACT}"
+    "${EVENTING_KAFKA_POST_INSTALL_ARTIFACT}"
   )
 
   # ARTIFACTS_TO_PUBLISH has to be a string, not an array.


Test patch:
diff --git a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go
index 3e00b64c7..504c7e9e8 100644
--- a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go
+++ b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go
@@ -118,6 +118,45 @@ func TestConsumerGroup_Validate(t *testing.T) {
 			},
 			wantErr: false,
 		},
+		{
+			name: "invalid multiple reply strategies (topic, destination)",
+			ctx:  context.Background(),
+			given: &ConsumerGroup{
+				Spec: ConsumerGroupSpec{
+					Replicas: pointer.Int32Ptr(1),
+					Selector: map[string]string{"app": "app"},
+					Template: ConsumerTemplateSpec{
+						Spec: ConsumerSpec{
+							Topics: []string{"t1"},
+							Configs: ConsumerConfigs{
+								Configs: map[string]string{
+									"group.id":          "g1",
+									"bootstrap.servers": "kafka:9092",
+								},
+							},
+							Reply: &ReplyStrategy{
+								TopicReply: &TopicReply{Enabled: true},
+								URLReply:   &DestinationReply{Enabled: true},
+							},
+							Delivery: &DeliverySpec{
+								DeliverySpec: &eventingduck.DeliverySpec{},
+							},
+							Subscriber: duckv1.Destination{
+								URI: &apis.URL{
+									Scheme: "http",
+									Host:   "127.0.0.1",
+								},
+							},
+							PodBind: &PodBind{
+								PodName:      "p-0",
+								PodNamespace: "ns",
+							},
+						},
+					},
+				},
+			},
+			wantErr: true,
+		},
 		{
 			name: "invalid no pod name",
 			ctx:  context.Background(),
diff --git a/control-plane/pkg/reconciler/channel/channel_test.go b/control-plane/pkg/reconciler/channel/channel_test.go
index c5e71fdac..a888eee34 100644
--- a/control-plane/pkg/reconciler/channel/channel_test.go
+++ b/control-plane/pkg/reconciler/channel/channel_test.go
@@ -353,6 +353,79 @@ func TestReconcileKind(t *testing.T) {
 				testProber: probertesting.MockProber(prober.StatusUnknown),
 			},
 		},
+		{
+			Name: "Reconciled failed - with single fresh subscriber without URI",
+			Objects: []runtime.Object{
+				NewChannel(WithSubscribers(Subscriber1(WithFreshSubscriber, WithNoSubscriberURI))),
+				NewService(),
+				ChannelReceiverPod(env.SystemNamespace, map[string]string{
+					base.VolumeGenerationAnnotationKey: "0",
+					"annotation_to_preserve":           "value_to_preserve",
+				}),
+				ChannelDispatcherPod(env.SystemNamespace, map[string]string{
+					base.VolumeGenerationAnnotationKey: "0",
+					"annotation_to_preserve":           "value_to_preserve",
+				}),
+				NewConfigMapWithTextData(system.Namespace(), DefaultEnv.GeneralConfigMapName, map[string]string{
+					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
+				}),
+				NewConfigMapWithBinaryData(&env, nil),
+			},
+			Key: testKey,
+			WantUpdates: []clientgotesting.UpdateActionImpl{
+				ConfigMapUpdate(&env, &contract.Contract{
+					Generation: 1,
+					Resources: []*contract.Resource{
+						{
+							Uid:              ChannelUUID,
+							Topics:           []string{ChannelTopic()},
+							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
+							Ingress: &contract.Ingress{
+								IngressType: &contract.Ingress_Path{
+									Path: receiver.Path(ChannelNamespace, ChannelName),
+								},
+							},
+							Egresses: []*contract.Egress{},
+						},
+					},
+				}),
+				ChannelReceiverPodUpdate(env.SystemNamespace, map[string]string{
+					"annotation_to_preserve":           "value_to_preserve",
+					base.VolumeGenerationAnnotationKey: "1",
+				}),
+				ChannelDispatcherPodUpdate(env.SystemNamespace, map[string]string{
+					"annotation_to_preserve":           "value_to_preserve",
+					base.VolumeGenerationAnnotationKey: "1",
+				}),
+			},
+			WantErr:                 true,
+			SkipNamespaceValidation: true, // WantCreates compare the channel namespace with configmap namespace, so skip it
+			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
+				{
+					Object: NewChannel(
+						WithInitKafkaChannelConditions,
+						StatusConfigParsed,
+						StatusConfigMapUpdatedReady(&env),
+						StatusTopicReadyWithName(ChannelTopic()),
+						StatusDataPlaneAvailable,
+						//StatusInitialOffsetsCommitted,
+						WithSubscribers(Subscriber1(WithFreshSubscriber, WithNoSubscriberURI)),
+					),
+				},
+			},
+			WantPatches: []clientgotesting.PatchActionImpl{
+				patchFinalizers(),
+			},
+			WantEvents: []string{
+				finalizerUpdatedEvent,
+				Eventf(
+					corev1.EventTypeWarning,
+					"InternalError",
+					"failed to resolve subscriber config: failed to resolve Subscription.Spec.Subscriber: empty subscriber URI",
+				),
+			},
+		},
 		{
 			Name: "Reconciled normal - with single fresh subscriber - no auth",
 			Objects: []runtime.Object{
diff --git a/control-plane/pkg/reconciler/source/v2/sourcev2_test.go b/control-plane/pkg/reconciler/source/v2/sourcev2_test.go
index eec524aeb..070abf219 100644
--- a/control-plane/pkg/reconciler/source/v2/sourcev2_test.go
+++ b/control-plane/pkg/reconciler/source/v2/sourcev2_test.go
@@ -70,6 +70,7 @@ func TestReconcileKind(t *testing.T) {
 						ConsumerAuth(NewConsumerSpecAuth()),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerSubscriber(NewSourceSinkReference()),
+						ConsumerReply(ConsumerNoReply()),
 					)),
 					ConsumerGroupReplicas(1),
 				),
@@ -107,6 +108,7 @@ func TestReconcileKind(t *testing.T) {
 						ConsumerAuth(NewConsumerSpecAuth()),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerSubscriber(NewSourceSinkReference()),
+						ConsumerReply(ConsumerNoReply()),
 						ConsumerCloudEventOverrides(&duckv1.CloudEventOverrides{
 							Extensions: map[string]string{"a": "foo", "b": "foo"},
 						}),
@@ -144,6 +146,7 @@ func TestReconcileKind(t *testing.T) {
 						ConsumerAuth(NewConsumerSpecAuth()),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerSubscriber(NewSourceSinkReference()),
+						ConsumerReply(ConsumerNoReply()),
 					)),
 					ConsumerGroupReplicas(1),
 					ConsumerGroupReady,
@@ -166,6 +169,7 @@ func TestReconcileKind(t *testing.T) {
 							ConsumerAuth(NewConsumerSpecAuth()),
 							ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 							ConsumerSubscriber(NewSourceSink2Reference()),
+							ConsumerReply(ConsumerNoReply()),
 						)),
 						ConsumerGroupReplicas(1),
 						ConsumerGroupReady,
@@ -212,6 +216,7 @@ func TestReconcileKind(t *testing.T) {
 							ConsumerAuth(NewConsumerSpecAuth()),
 							ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 							ConsumerSubscriber(NewSourceSinkReference()),
+							ConsumerReply(ConsumerNoReply()),
 						)),
 						ConsumerGroupReplicas(1),
 						ConsumerGroupReady,
@@ -257,6 +262,7 @@ func TestReconcileKind(t *testing.T) {
 							ConsumerAuth(NewConsumerSpecAuth()),
 							ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 							ConsumerSubscriber(NewSourceSinkReference()),
+							ConsumerReply(ConsumerNoReply()),
 						)),
 						ConsumerGroupReplicas(1),
 					),
@@ -289,6 +295,7 @@ func TestReconcileKind(t *testing.T) {
 						ConsumerAuth(NewConsumerSpecAuth()),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerSubscriber(NewSourceSinkReference()),
+						ConsumerReply(ConsumerNoReply()),
 					)),
 					ConsumerGroupReplicas(1),
 					ConsumerGroupReady,
@@ -322,6 +329,7 @@ func TestReconcileKind(t *testing.T) {
 						ConsumerAuth(NewConsumerSpecAuth()),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerSubscriber(NewSourceSinkReference()),
+						ConsumerReply(ConsumerNoReply()),
 					)),
 					ConsumerGroupReplicas(1),
 				),
@@ -355,6 +363,7 @@ func TestReconcileKind(t *testing.T) {
 						ConsumerAuth(NewConsumerSpecAuth()),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerSubscriber(NewSourceSinkReference()),
+						ConsumerReply(ConsumerNoReply()),
 					)),
 					ConsumerGroupReplicas(1),
 					WithConsumerGroupFailed("failed", "failed"),
@@ -389,6 +398,7 @@ func TestReconcileKind(t *testing.T) {
 						ConsumerAuth(NewConsumerSpecAuth()),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerSubscriber(NewSourceSinkReference()),
+						ConsumerReply(ConsumerNoReply()),
 					)),
 					ConsumerGroupReplicas(1),
 					ConsumerGroupReplicasStatus(1),
diff --git a/control-plane/pkg/reconciler/testing/objects_channel.go b/control-plane/pkg/reconciler/testing/objects_channel.go
index cdfe2c636..a1147647b 100644
--- a/control-plane/pkg/reconciler/testing/objects_channel.go
+++ b/control-plane/pkg/reconciler/testing/objects_channel.go
@@ -261,6 +261,18 @@ func WithFreshSubscriber(sub *SubscriberInfo) {
 	sub.status = nil
 }
 
+func WithNoSubscriberURI(sub *SubscriberInfo) {
+	sub.spec.SubscriberURI = nil
+	if sub.status == nil {
+		sub.status = &eventingduckv1.SubscriberStatus{
+			UID:                sub.spec.UID,
+			ObservedGeneration: sub.spec.Generation,
+		}
+	}
+	sub.status.Ready = "False"
+	sub.status.Message = "Subscription not ready: failed to resolve subscriber config: failed to resolve Subscription.Spec.Subscriber: empty subscriber URI"
+}
+
 func WithUnreadySubscriber(sub *SubscriberInfo) {
 	sub.status.Ready = "False"
 }
diff --git a/control-plane/pkg/reconciler/testing/objects_consumer.go b/control-plane/pkg/reconciler/testing/objects_consumer.go
index bb2a6ca3b..1a99d7f2f 100644
--- a/control-plane/pkg/reconciler/testing/objects_consumer.go
+++ b/control-plane/pkg/reconciler/testing/objects_consumer.go
@@ -226,3 +226,17 @@ func ConsumerReady() ConsumerOption {
 		}
 	}
 }
+
+func ConsumerReply(s *kafkainternals.ReplyStrategy) ConsumerSpecOption {
+	return func(c *kafkainternals.ConsumerSpec) {
+		c.Reply = s
+	}
+}
+
+func ConsumerNoReply() *kafkainternals.ReplyStrategy {
+	return &kafkainternals.ReplyStrategy{NoReply: &kafkainternals.NoReply{Enabled: true}}
+}
+
+func ConsumerTopicReply() *kafkainternals.ReplyStrategy {
+	return &kafkainternals.ReplyStrategy{TopicReply: &kafkainternals.TopicReply{Enabled: true}}
+}
diff --git a/control-plane/pkg/reconciler/trigger/v2/triggerv2_test.go b/control-plane/pkg/reconciler/trigger/v2/triggerv2_test.go
index 6e6fe7e24..f723e0743 100644
--- a/control-plane/pkg/reconciler/trigger/v2/triggerv2_test.go
+++ b/control-plane/pkg/reconciler/trigger/v2/triggerv2_test.go
@@ -91,6 +91,7 @@ func TestReconcileKind(t *testing.T) {
 						),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 						ConsumerFilters(NewConsumerSpecFilters()),
+						ConsumerReply(ConsumerTopicReply()),
 					)),
 				),
 			},
@@ -128,6 +129,7 @@ func TestReconcileKind(t *testing.T) {
 						),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Ordered)),
 						ConsumerFilters(NewConsumerSpecFilters()),
+						ConsumerReply(ConsumerTopicReply()),
 					)),
 				),
 			},
@@ -166,6 +168,7 @@ func TestReconcileKind(t *testing.T) {
 						),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 						ConsumerFilters(NewConsumerSpecFilters()),
+						ConsumerReply(ConsumerTopicReply()),
 					)),
 				),
 			},
@@ -244,6 +247,7 @@ func TestReconcileKind(t *testing.T) {
 							),
 							ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 							ConsumerFilters(NewConsumerSpecFilters()),
+							ConsumerReply(ConsumerTopicReply()),
 						)),
 						ConsumerGroupReady,
 					),
@@ -291,6 +295,7 @@ func TestReconcileKind(t *testing.T) {
 							),
 							ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 							ConsumerFilters(NewConsumerSpecFilters()),
+							ConsumerReply(ConsumerTopicReply()),
 						)),
 					),
 				},
@@ -326,6 +331,7 @@ func TestReconcileKind(t *testing.T) {
 						),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 						ConsumerFilters(NewConsumerSpecFilters()),
+						ConsumerReply(ConsumerTopicReply()),
 					)),
 					ConsumerGroupReady,
 				),
@@ -362,6 +368,7 @@ func TestReconcileKind(t *testing.T) {
 						),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 						ConsumerFilters(NewConsumerSpecFilters()),
+						ConsumerReply(ConsumerTopicReply()),
 					)),
 				),
 			},
@@ -397,6 +404,7 @@ func TestReconcileKind(t *testing.T) {
 						),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 						ConsumerFilters(NewConsumerSpecFilters()),
+						ConsumerReply(ConsumerTopicReply()),
 					)),
 					WithConsumerGroupFailed("failed", "failed"),
 				),
@@ -433,6 +441,7 @@ func TestReconcileKind(t *testing.T) {
 						),
 						ConsumerDelivery(NewConsumerSpecDelivery(internals.Unordered)),
 						ConsumerFilters(NewConsumerSpecFilters()),
+						ConsumerReply(ConsumerTopicReply()),
 					)),
 					WithDeadLetterSinkURI(url.String()),
 				),
diff --git a/data-plane/dispatcher/src/test/java/dev/knative/eventing/kafka/broker/dispatcher/impl/RecordDispatcherTest.java b/data-plane/dispatcher/src/test/java/dev/knative/eventing/kafka/broker/dispatcher/impl/RecordDispatcherTest.java
index a297cf662..9f7099d61 100644
--- a/data-plane/dispatcher/src/test/java/dev/knative/eventing/kafka/broker/dispatcher/impl/RecordDispatcherTest.java
+++ b/data-plane/dispatcher/src/test/java/dev/knative/eventing/kafka/broker/dispatcher/impl/RecordDispatcherTest.java
@@ -118,6 +118,7 @@ public class RecordDispatcherTest {
       new CloudEventSenderMock(
         record -> {
           sendCalled.set(true);
+          simulateLatency(); // Simulate dispatch latency
           return Future.succeededFuture();
         }
       ),
@@ -160,6 +161,7 @@ public class RecordDispatcherTest {
       new CloudEventSenderMock(
         record -> {
           subscriberSenderSendCalled.set(true);
+          simulateLatency(); // Simulate dispatch latency
           return Future.failedFuture("");
         }
       ),
@@ -201,6 +203,7 @@ public class RecordDispatcherTest {
       value -> true, new CloudEventSenderMock(
       record -> {
         subscriberSenderSendCalled.set(true);
+        simulateLatency(); // Simulate dispatch latency
         return Future.failedFuture("");
       }
     ),
@@ -242,6 +245,7 @@ public class RecordDispatcherTest {
       new CloudEventSenderMock(
         record -> {
           subscriberSenderSendCalled.set(true);
+          simulateLatency(); // Simulate dispatch latency
           return Future.failedFuture("");
         }
       ),
@@ -381,4 +385,11 @@ public class RecordDispatcherTest {
     );
   }
 
+  private void simulateLatency() {
+    try {
+      Thread.sleep(100);
+    } catch (InterruptedException ignored) {
+    }
+  }
+
 }
diff --git a/third_party/eventing-latest/eventing-core.yaml b/third_party/eventing-latest/eventing-core.yaml
index 0deb19dc4..806b2a038 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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 
 ---
@@ -41,8 +41,8 @@ metadata:
   name: eventing-controller
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
   annotations:
     knative.dev/example-checksum: "9185c153"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 data:
   _example: |
@@ -436,10 +436,10 @@ metadata:
   name: config-features
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/high-availability: "true"
     app.kubernetes.io/component: eventing-controller
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -796,9 +796,9 @@ spec:
     metadata:
       labels:
         app: eventing-controller
-        eventing.knative.dev/release: "v20220208-20718e264"
+        eventing.knative.dev/release: "v20220214-f13248e5a"
         app.kubernetes.io/component: eventing-controller
-        app.kubernetes.io/version: "20220208-20718e264"
+        app.kubernetes.io/version: "20220214-f13248e5a"
         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:de448d61329c04a7f8f0ad72f43022cc19dc618c1074c3a24def274b11d73562
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/controller@sha256:64f77a28867952baad093e5807636b72665e81938a3d7ee5264b8e0cc4461fee
           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:ce98de86265e2072e7a12433374869d9ad526ceb076ced609bc9dabc3609c60b
+              value: gcr.io/knative-nightly/knative.dev/eventing/cmd/apiserver_receive_adapter@sha256:bed26f5550913f7798ce7b76d85766c9a52f937cdab75afcb495b8bb68c19bbb
             - name: POD_NAME
               valueFrom:
                 fieldRef:
@@ -883,9 +883,9 @@ metadata:
   name: pingsource-mt-adapter
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     app.kubernetes.io/component: pingsource-mt-adapter
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+        eventing.knative.dev/release: "v20220214-f13248e5a"
         app.kubernetes.io/component: pingsource-mt-adapter
-        app.kubernetes.io/version: "20220208-20718e264"
+        app.kubernetes.io/version: "20220214-f13248e5a"
         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:f12bfa0b060ea80d2ad2a666894540aca9c661fd3e0484decaebde0dc54623b6
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/mtping@sha256:3cef3ef61cd5910441bafd081de25521b8da933a4ddc6bfe5f81deeb0905a65e
           env:
             - name: SYSTEM_NAMESPACE
               value: ''
@@ -979,9 +979,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 spec:
   scaleTargetRef:
@@ -1005,9 +1005,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -1049,9 +1049,9 @@ spec:
     metadata:
       labels:
         !!merge <<: *labels
-        eventing.knative.dev/release: "v20220208-20718e264"
+        eventing.knative.dev/release: "v20220214-f13248e5a"
         app.kubernetes.io/component: eventing-webhook
-        app.kubernetes.io/version: "20220208-20718e264"
+        app.kubernetes.io/version: "20220214-f13248e5a"
         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:2704f8da50bc9267f8dbe4cdc19a6e8ac64f63528da17118a0a25c7f84273617
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/webhook@sha256:a52a93752605d9580069b572ccb1a551567c82b083b69a041534a7f28827452e
           resources:
             requests:
               # taken from serving.
@@ -1140,10 +1140,10 @@ apiVersion: v1
 kind: Service
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     role: eventing-webhook
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3639,8 +3639,8 @@ kind: ClusterRole
 metadata:
   name: eventing-broker-ingress
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3657,8 +3657,8 @@ kind: ClusterRole
 metadata:
   name: eventing-config-reader
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3691,8 +3691,8 @@ kind: ClusterRole
 metadata:
   name: channelable-manipulator
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -3705,9 +3705,9 @@ kind: ClusterRole
 metadata:
   name: meta-channelable-manipulator
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/channelable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4062,8 +4062,8 @@ kind: ClusterRole
 metadata:
   name: podspecable-binding
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/podspecable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     duck.knative.dev/source: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4263,8 +4263,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
-    app.kubernetes.io/version: "20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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 86b2e1332..49bec222c 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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     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: "v20220208-20718e264"
+    eventing.knative.dev/release: "v20220214-f13248e5a"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220208-20718e264"
+    app.kubernetes.io/version: "20220214-f13248e5a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev