Repository: knative-sandbox/eventing-kafka-broker
Pull request #3126 (2023-06-01 13:43:41)

[main] Upgrade to latest dependencies
Cron -knative-prow-robot

/cc knative-sandbox/eventing-writers
/assign knative-sandbox/eventing-writers

Produced by: knative-sandbox/knobots/actions/update-deps

knative-prow[bot]: @knative-automation: GitHub didn't allow me to request PR reviews from the following users: knative-sandbox/eventing-writers.

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/3126):

>Cron -knative-prow-robot
>
>/cc knative-sandbox/eventing-writers
>/assign knative-sandbox/eventing-writers
>
>Produced by: knative-sandbox/knobots/actions/update-deps


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[bot]: [APPROVALNOTIFIER] This PR is **NOT APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/3126#" title="Author self-approved">knative-automation</a>*
**Once this PR has been reviewed and has the lgtm label**, please assign lionelvillard for approval. For more information see [the Kubernetes Code Review Process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process).

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":["lionelvillard"]} -->
knative-prow[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | ae2585024c9d135b089d0eedc26c53aa3946a7b8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1664266479480082432) | true | `/test channel-integration-tests-sasl-plain`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: [APPROVALNOTIFIER] This PR is **APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/3126#" title="Author self-approved">knative-automation</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/3126#pullrequestreview-1462362853" title="Approved">pierDipi</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)~~ [pierDipi]

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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | ae2585024c9d135b089d0eedc26c53aa3946a7b8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1665700414542057472) | unknown | `/test channel-integration-tests-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: New changes are detected. LGTM label has been removed.
knative-prow[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | ae2585024c9d135b089d0eedc26c53aa3946a7b8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1665700414542057472) | unknown | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1665716442214961152) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | ae2585024c9d135b089d0eedc26c53aa3946a7b8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1665700414542057472) | unknown | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1665716442214961152) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1665716442093326336) | true | `/test build-tests`
upgrade-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665716442445647872) | true | `/test upgrade-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
build-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1665716442093326336) | true | `/test build-tests`
upgrade-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665716442445647872) | true | `/test upgrade-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1665716442911215616) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1665907943393988608) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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 -->
codecov[bot]: ## [Codecov](https://app.codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/3126?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) Report
> Merging [#3126](https://app.codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/3126?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (f4be9ab) into [main](https://app.codecov.io/gh/knative-sandbox/eventing-kafka-broker/commit/157d1bfc6202f0648ab9216376ac5bbccd8af643?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (157d1bf) will **increase** coverage by `0.30%`.
> The diff coverage is `n/a`.

```diff
@@             Coverage Diff              @@
##               main    #3126      +/-   ##
============================================
+ Coverage     81.28%   81.58%   +0.30%     
- Complexity      758      761       +3     
============================================
  Files            77       77              
  Lines          2639     2639              
  Branches        233      233              
============================================
+ Hits           2145     2153       +8     
+ Misses          359      354       -5     
+ Partials        135      132       -3     
```

| Flag | Coverage Δ | |
|---|---|---|
| java-unittests | `81.58% <ø> (+0.30%)` | :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.

[see 3 files with indirect coverage changes](https://app.codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/3126/indirect-changes?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)


knative-prow[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665716442445647872) | true | `/test upgrade-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1665716442911215616) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1665907943393988608) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1665907943335268352) | true | `/test build-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665716442445647872) | true | `/test upgrade-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1665716442911215616) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1665907943393988608) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1665907943335268352) | true | `/test build-tests`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1665907943846973440) | true | `/test channel-integration-tests-sasl-plain`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | dbd3b9dc694423672fa00fb0cce4a89aebf8c4de | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665716442445647872) | true | `/test upgrade-tests`
unit-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1665907943393988608) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1665907943335268352) | true | `/test build-tests`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1665907943846973440) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1665907943779864576) | true | `/test channel-integration-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
unit-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1665907943393988608) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1665907943335268352) | true | `/test build-tests`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1665907943846973440) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1665907943779864576) | true | `/test channel-integration-tests-sasl-ssl`
upgrade-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665907943515623424) | true | `/test upgrade-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
build-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1665907943335268352) | true | `/test build-tests`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1665907943846973440) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1665907943779864576) | true | `/test channel-integration-tests-sasl-ssl`
upgrade-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665907943515623424) | true | `/test upgrade-tests`
unit-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1666078608084439040) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1665907943846973440) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1665907943779864576) | true | `/test channel-integration-tests-sasl-ssl`
upgrade-tests_eventing-kafka-broker_main | f4be9abc6f6517a868eab00e94c35fb9be4014fd | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1665907943515623424) | true | `/test upgrade-tests`
unit-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1666078608084439040) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1666078608021524480) | true | `/test build-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
unit-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1666078608084439040) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1666078608021524480) | true | `/test build-tests`
reconciler-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1666078608264794112) | true | `/test reconciler-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
build-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1666078608021524480) | true | `/test build-tests`
reconciler-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1666078608264794112) | true | `/test reconciler-tests`
unit-tests_eventing-kafka-broker_main | 00b79a0d5cefef12cc5ec3eb72e02fbd5bfc27cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1666631022772490240) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
reconciler-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1666078608264794112) | true | `/test reconciler-tests`
unit-tests_eventing-kafka-broker_main | 00b79a0d5cefef12cc5ec3eb72e02fbd5bfc27cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1666631022772490240) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | 00b79a0d5cefef12cc5ec3eb72e02fbd5bfc27cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1666631022713769984) | true | `/test build-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
reconciler-tests_eventing-kafka-broker_main | ae845ca91c8d6ffc9cba0fa79ed946851c908c5d | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1666078608264794112) | true | `/test reconciler-tests`
unit-tests_eventing-kafka-broker_main | 00b79a0d5cefef12cc5ec3eb72e02fbd5bfc27cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1666631022772490240) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | 00b79a0d5cefef12cc5ec3eb72e02fbd5bfc27cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1666631022713769984) | true | `/test build-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 00b79a0d5cefef12cc5ec3eb72e02fbd5bfc27cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1666631023137394688) | true | `/test channel-integration-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 00b79a0d5cefef12cc5ec3eb72e02fbd5bfc27cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1666631023137394688) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1667165747664654336) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1667165747618516992) | true | `/test build-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
unit-tests_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1667165747664654336) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1667165747618516992) | true | `/test build-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1667165747996004352) | true | `/test channel-integration-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
build-tests_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1667165747618516992) | true | `/test build-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1667165747996004352) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1668077950655795200) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | d209269fd4992b15fb99028c5782853c2538940b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1667165747996004352) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1668077950655795200) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1668077950571909120) | true | `/test build-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
unit-tests_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1668077950655795200) | true | `/test unit-tests`
build-tests_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1668077950571909120) | true | `/test build-tests`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1668077951071031296) | true | `/test reconciler-tests-namespaced-broker`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
build-tests_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/build-tests_eventing-kafka-broker_main/1668077950571909120) | true | `/test build-tests`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1668077951071031296) | true | `/test reconciler-tests-namespaced-broker`
unit-tests_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1669340210825007104) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1668077951071031296) | true | `/test reconciler-tests-namespaced-broker`
unit-tests_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1669340210825007104) | true | `/test unit-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669340209902260225) | true | `/test channel-integration-tests-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1668077951071031296) | true | `/test reconciler-tests-namespaced-broker`
unit-tests_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1669340210825007104) | true | `/test unit-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669340209902260225) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1669340209906454529) | true | `/test channel-integration-tests-sasl-plain`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8f0572466c45280ab3a07792830a531057528ed1 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1668077951071031296) | true | `/test reconciler-tests-namespaced-broker`
unit-tests_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1669340210825007104) | true | `/test unit-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669340209902260225) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1669340209906454529) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1669340209906454530) | true | `/test channel-integration-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669340209902260225) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1669340209906454529) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1669340209906454530) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 9bef37b1efad6398c49faad9e4bda40f13a4b077 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1669527774244638720) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1669340209906454529) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 3f7a993701f8650d367ae528931f90b8eb44c85b | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1669340209906454530) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 9bef37b1efad6398c49faad9e4bda40f13a4b077 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1669527774244638720) | true | `/test unit-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 9bef37b1efad6398c49faad9e4bda40f13a4b077 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669527774571794432) | true | `/test channel-integration-tests-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | 9bef37b1efad6398c49faad9e4bda40f13a4b077 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669527774571794432) | true | `/test channel-integration-tests-ssl`
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1669702460211466240) | true | `/test channel-integration-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1669702460211466240) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1669702460211466240) | true | `/test channel-integration-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1670614726540791808) | true | `/test channel-integration-tests-sasl-plain`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1670614726540791808) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1670614726893113344) | true | `/test channel-reconciler-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
upgrade-tests_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1669702459955613696) | true | `/test upgrade-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1670614726540791808) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1670614726893113344) | true | `/test channel-reconciler-tests-sasl-ssl`
reconciler-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1670614726297522176) | true | `/test reconciler-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1670614726540791808) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1670614726893113344) | true | `/test channel-reconciler-tests-sasl-ssl`
reconciler-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1670614726297522176) | true | `/test reconciler-tests`
upgrade-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1670614726222024704) | true | `/test upgrade-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1670614726540791808) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1670614726893113344) | true | `/test channel-reconciler-tests-sasl-ssl`
reconciler-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1670614726297522176) | true | `/test reconciler-tests`
upgrade-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1670614726222024704) | true | `/test upgrade-tests`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1670614727702614016) | true | `/test channel-reconciler-tests-sasl-plain`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-ssl_eventing-kafka-broker_main | 0668d0a63e39c700f02af6caa3ab6d09bbe41fb9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1669702460148551680) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1670614726540791808) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1670614726893113344) | true | `/test channel-reconciler-tests-sasl-ssl`
reconciler-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1670614726297522176) | true | `/test reconciler-tests`
upgrade-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1670614726222024704) | true | `/test upgrade-tests`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1670614727702614016) | true | `/test channel-reconciler-tests-sasl-plain`
integration-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/integration-tests_eventing-kafka-broker_main/1670614726159110144) | true | `/test integration-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
unit-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670614726100389888) | true | `/test unit-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1670614726603706368) | true | `/test channel-reconciler-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1670614726477877248) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1670614726540791808) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1670614726893113344) | true | `/test channel-reconciler-tests-sasl-ssl`
reconciler-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/reconciler-tests_eventing-kafka-broker_main/1670614726297522176) | true | `/test reconciler-tests`
upgrade-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/upgrade-tests_eventing-kafka-broker_main/1670614726222024704) | true | `/test upgrade-tests`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1670614727702614016) | true | `/test channel-reconciler-tests-sasl-plain`
integration-tests_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/integration-tests_eventing-kafka-broker_main/1670614726159110144) | true | `/test integration-tests`
channel-integration-tests-ssl_eventing-kafka-broker_main | 82c6f18c66d176c22a57fa14c2d6020a30e9c08a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1670614726423351296) | true | `/test channel-integration-tests-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
unit-tests_eventing-kafka-broker_main | 1d2d47229680cc5c0f01c514f216c08bbdb7f4b7 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1670977005039915008) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | b7cce10c3b03c57b774c496c46d6c303f646bace | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1671339046195957760) | true | `/test channel-integration-tests-sasl-plain`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | b7cce10c3b03c57b774c496c46d6c303f646bace | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1671339046195957760) | true | `/test channel-integration-tests-sasl-plain`
unit-tests_eventing-kafka-broker_main | 8ba02fbfd61aebfadd73b59b581e710053a6dde5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1671701608708182016) | true | `/test unit-tests`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | b7cce10c3b03c57b774c496c46d6c303f646bace | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1671339046195957760) | true | `/test channel-integration-tests-sasl-plain`
unit-tests_eventing-kafka-broker_main | 8ba02fbfd61aebfadd73b59b581e710053a6dde5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/unit-tests_eventing-kafka-broker_main/1671701608708182016) | true | `/test unit-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8ba02fbfd61aebfadd73b59b581e710053a6dde5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1671701609123418112) | true | `/test channel-integration-tests-sasl-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 704796f0e3d556a6585809c6fbc43934e81601cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1672063054256279552) | true | `/test channel-integration-tests-sasl-plain`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: @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
--- | --- | --- | --- | ---
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 704796f0e3d556a6585809c6fbc43934e81601cb | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1672063054256279552) | true | `/test channel-integration-tests-sasl-plain`
channel-integration-tests-ssl_eventing-kafka-broker_main | d2371b8775508e720a84466972eb457ad6165acf | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/3126/channel-integration-tests-ssl_eventing-kafka-broker_main/1672239249199468544) | true | `/test channel-integration-tests-ssl`

[Your PR dashboard](https://prow.knative.dev/pr).

<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[bot]: [APPROVALNOTIFIER] This PR is **APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/3126#" title="Author self-approved">knative-automation</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/3126#pullrequestreview-1498589326" title="Approved">matzew</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/3126#pullrequestreview-1462362853" title="Approved">pierDipi</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,pierDipi]

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":[]} -->

Patch:
diff --git a/control-plane/pkg/receiver/address.go b/control-plane/pkg/receiver/address.go
index c6ff34fee..0579d582b 100644
--- a/control-plane/pkg/receiver/address.go
+++ b/control-plane/pkg/receiver/address.go
@@ -44,6 +44,15 @@ func HTTPAddress(host string, object metav1.Object) duckv1.Addressable {
 	return httpAddress
 }
 
+// HTTPAddress returns the addressable
+func ChannelHTTPAddress(host string) duckv1.Addressable {
+	httpAddress := duckv1.Addressable{
+		Name: pointer.String("http"),
+		URL:  apis.HTTP(host),
+	}
+	return httpAddress
+}
+
 func HTTPSAddress(host string, object metav1.Object, caCerts string) duckv1.Addressable {
 	httpsAddress := duckv1.Addressable{
 		Name:    pointer.String("https"),
diff --git a/control-plane/pkg/reconciler/channel/channel.go b/control-plane/pkg/reconciler/channel/channel.go
index f06f5fd5e..da1c2bc23 100644
--- a/control-plane/pkg/reconciler/channel/channel.go
+++ b/control-plane/pkg/reconciler/channel/channel.go
@@ -19,15 +19,16 @@ package channel
 import (
 	"context"
 	"fmt"
-	"net/url"
 	"strconv"
 	"time"
 
 	"k8s.io/apimachinery/pkg/api/equality"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"knative.dev/eventing/pkg/apis/feature"
 	messaging "knative.dev/eventing/pkg/apis/messaging/v1"
 	"knative.dev/pkg/network"
+	"knative.dev/pkg/system"
 
 	"github.com/Shopify/sarama"
 	"go.uber.org/multierr"
@@ -41,6 +42,7 @@ import (
 
 	v1 "knative.dev/eventing/pkg/apis/duck/v1"
 	messaginglisters "knative.dev/eventing/pkg/client/listers/messaging/v1"
+	duckv1 "knative.dev/pkg/apis/duck/v1"
 	"knative.dev/pkg/controller"
 	"knative.dev/pkg/reconciler"
 	"knative.dev/pkg/resolver"
@@ -64,6 +66,8 @@ const (
 	TopicPrefix                  = "knative-messaging-kafka"
 	DefaultDeliveryOrder         = contract.DeliveryOrder_ORDERED
 	NewChannelIngressServiceName = "kafka-channel-ingress"
+	kafkaChannelTLSSecretName    = "kafka-channel-ingress-server-tls" //nolint:gosec // This is not a hardcoded credential
+	caCertsSecretKey             = "ca.crt"
 )
 
 type Reconciler struct {
@@ -286,7 +290,45 @@ func (r *Reconciler) reconcileKind(ctx context.Context, channel *messagingv1beta
 		return err
 	}
 
-	address, _ := url.Parse(fmt.Sprintf("http://%s.%s.svc.%s", channelService.Name, channelService.Namespace, network.GetClusterDomainName()))
+	var addressableStatus duckv1.AddressStatus
+	channelHttpsHost := network.GetServiceHostname(r.Env.IngressName, r.SystemNamespace)
+	channelHttpHost := network.GetServiceHostname(channelService.Name, channel.Namespace)
+	transportEncryptionFlags := feature.FromContext(ctx)
+	if transportEncryptionFlags.IsPermissiveTransportEncryption() {
+		caCerts, err := r.getCaCerts()
+		if err != nil {
+			return err
+		}
+
+		httpAddress := receiver.ChannelHTTPAddress(channelHttpHost)
+		httpsAddress := receiver.HTTPSAddress(channelHttpsHost, channelService, caCerts)
+		// Permissive mode:
+		// - status.address http address with path-based routing
+		// - status.addresses:
+		//   - https address with path-based routing
+		//   - http address with path-based routing
+		addressableStatus.Addresses = []duckv1.Addressable{httpsAddress, httpAddress}
+		addressableStatus.Address = &httpAddress
+	} else if transportEncryptionFlags.IsStrictTransportEncryption() {
+		// Strict mode: (only https addresses)
+		// - status.address https address with path-based routing
+		// - status.addresses:
+		//   - https address with path-based routing
+		caCerts, err := r.getCaCerts()
+		if err != nil {
+			return err
+		}
+
+		httpsAddress := receiver.HTTPSAddress(channelHttpsHost, channelService, caCerts)
+		addressableStatus.Addresses = []duckv1.Addressable{httpsAddress}
+		addressableStatus.Address = &httpsAddress
+	} else {
+		httpAddress := receiver.ChannelHTTPAddress(channelHttpHost)
+		addressableStatus.Address = &httpAddress
+		addressableStatus.Addresses = []duckv1.Addressable{httpAddress}
+	}
+
+	address := addressableStatus.Address.URL.URL()
 	proberAddressable := prober.Addressable{
 		Address: address,
 		ResourceKey: types.NamespacedName{
@@ -301,7 +343,10 @@ func (r *Reconciler) reconcileKind(ctx context.Context, channel *messagingv1beta
 		statusConditionManager.ProbesStatusNotReady(status)
 		return nil // Object will get re-queued once probe status changes.
 	}
-	statusConditionManager.Addressable(address)
+	statusConditionManager.ProbesStatusReady()
+	channel.Status.Address = addressableStatus.Address
+	channel.Status.Addresses = addressableStatus.Addresses
+	channel.GetConditionSet().Manage(channel.GetStatus()).MarkTrue(base.ConditionAddressable)
 
 	return nil
 }
@@ -670,6 +715,18 @@ func (r *Reconciler) getSubscriptionName(channel *messagingv1beta1.KafkaChannel,
 	return "", apierrors.NewNotFound(messaging.SchemeGroupVersion.WithResource("subscriptions").GroupResource(), string(subscriber.UID))
 }
 
+func (r *Reconciler) getCaCerts() (string, error) {
+	secret, err := r.SecretLister.Secrets(system.Namespace()).Get(kafkaChannelTLSSecretName)
+	if err != nil {
+		return "", fmt.Errorf("failed to get CA certs from %s/%s: %w", system.Namespace(), kafkaChannelTLSSecretName, err)
+	}
+	caCerts, ok := secret.Data[caCertsSecretKey]
+	if !ok {
+		return "", fmt.Errorf("failed to get CA certs from %s/%s: missing %s key", system.Namespace(), kafkaChannelTLSSecretName, caCertsSecretKey)
+	}
+	return string(caCerts), nil
+}
+
 // consumerGroup returns a consumerGroup name for the given channel and subscription
 func consumerGroup(channel *messagingv1beta1.KafkaChannel, sub *v1.SubscriberSpec) string {
 	return fmt.Sprintf("kafka.%s.%s.%s", channel.Namespace, channel.Name, string(sub.UID))
diff --git a/control-plane/pkg/reconciler/channel/controller.go b/control-plane/pkg/reconciler/channel/controller.go
index 9da869dd4..cf90d72af 100644
--- a/control-plane/pkg/reconciler/channel/controller.go
+++ b/control-plane/pkg/reconciler/channel/controller.go
@@ -117,6 +117,11 @@ func NewController(ctx context.Context, configs *config.Env) *controller.Impl {
 	reconciler.Tracker = impl.Tracker
 
 	secretinformer.Get(ctx).Informer().AddEventHandler(controller.HandleAll(reconciler.Tracker.OnChanged))
+	secretinformer.Get(ctx).Informer().AddEventHandler(cache.FilteringResourceEventHandler{
+		FilterFunc: controller.FilterWithName(kafkaChannelTLSSecretName),
+		Handler:    controller.HandleAll(globalResync),
+	})
+
 	configmapinformer.Get(ctx).Informer().AddEventHandler(controller.HandleAll(
 		// Call the tracker's OnChanged method, but we've seen the objects
 		// coming through this path missing TypeMeta, so ensure it is properly
diff --git a/control-plane/pkg/reconciler/channel/v2/channelv2.go b/control-plane/pkg/reconciler/channel/v2/channelv2.go
index 35b56451a..a4cdb3902 100644
--- a/control-plane/pkg/reconciler/channel/v2/channelv2.go
+++ b/control-plane/pkg/reconciler/channel/v2/channelv2.go
@@ -20,7 +20,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"net/url"
 	"strconv"
 	"strings"
 	"time"
@@ -36,8 +35,10 @@ import (
 	"k8s.io/apimachinery/pkg/types"
 	corelisters "k8s.io/client-go/listers/core/v1"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/channel/resources"
+	"knative.dev/eventing/pkg/apis/feature"
 	"knative.dev/pkg/network"
 	"knative.dev/pkg/resolver"
+	"knative.dev/pkg/system"
 
 	messagingv1beta1 "knative.dev/eventing-kafka-broker/control-plane/pkg/apis/messaging/v1beta1"
 	v1 "knative.dev/eventing/pkg/apis/duck/v1"
@@ -74,6 +75,9 @@ const (
 	DefaultDeliveryOrder = kafkasource.Ordered
 
 	KafkaChannelConditionSubscribersReady apis.ConditionType = "Subscribers" // condition is registered by controller
+
+	kafkaChannelTLSSecretName = "kafka-channel-ingress-server-tls" //nolint:gosec // This is not a hardcoded credential
+	caCertsSecretKey          = "ca.crt"
 )
 
 var (
@@ -258,7 +262,46 @@ func (r *Reconciler) ReconcileKind(ctx context.Context, channel *messagingv1beta
 		return err
 	}
 
-	address, _ := url.Parse(fmt.Sprintf("http://%s.%s.svc.%s", channelService.Name, channelService.Namespace, network.GetClusterDomainName()))
+	var addressableStatus duckv1.AddressStatus
+	channelHttpsHost := network.GetServiceHostname(r.Env.IngressName, r.SystemNamespace)
+	channelHttpHost := network.GetServiceHostname(channelService.Name, channel.Namespace)
+	transportEncryptionFlags := feature.FromContext(ctx)
+	if transportEncryptionFlags.IsPermissiveTransportEncryption() {
+		caCerts, err := r.getCaCerts()
+		if err != nil {
+			return err
+		}
+
+		httpAddress := receiver.ChannelHTTPAddress(channelHttpHost)
+		httpsAddress := receiver.HTTPSAddress(channelHttpsHost, channelService, caCerts)
+		// Permissive mode:
+		// - status.address http address with path-based routing
+		// - status.addresses:
+		//   - https address with path-based routing
+		//   - http address with path-based routing
+		addressableStatus.Addresses = []duckv1.Addressable{httpsAddress, httpAddress}
+		addressableStatus.Address = &httpAddress
+	} else if transportEncryptionFlags.IsStrictTransportEncryption() {
+		// Strict mode: (only https addresses)
+		// - status.address https address with path-based routing
+		// - status.addresses:
+		//   - https address with path-based routing
+		caCerts, err := r.getCaCerts()
+		if err != nil {
+			return err
+		}
+
+		httpsAddress := receiver.HTTPSAddress(channelHttpsHost, channelService, caCerts)
+		addressableStatus.Addresses = []duckv1.Addressable{httpsAddress}
+		addressableStatus.Address = &httpsAddress
+	} else {
+		httpAddress := receiver.ChannelHTTPAddress(channelHttpHost)
+		addressableStatus.Address = &httpAddress
+		addressableStatus.Addresses = []duckv1.Addressable{httpAddress}
+	}
+
+	address := addressableStatus.Address.URL.URL()
+
 	proberAddressable := prober.Addressable{
 		Address: address,
 		ResourceKey: types.NamespacedName{
@@ -273,7 +316,11 @@ func (r *Reconciler) ReconcileKind(ctx context.Context, channel *messagingv1beta
 		statusConditionManager.ProbesStatusNotReady(status)
 		return nil // Object will get re-queued once probe status changes.
 	}
-	statusConditionManager.Addressable(address)
+
+	statusConditionManager.ProbesStatusReady()
+	channel.Status.Address = addressableStatus.Address
+	channel.Status.Addresses = addressableStatus.Addresses
+	channel.GetConditionSet().Manage(channel.GetStatus()).MarkTrue(base.ConditionAddressable)
 
 	return nil
 }
@@ -698,3 +745,15 @@ func (r *Reconciler) getSubscriptionAnnotations(channel *messagingv1beta1.KafkaC
 
 	return nil, apierrors.NewNotFound(messaging.SchemeGroupVersion.WithResource("subscriptions").GroupResource(), string(subscriber.UID))
 }
+
+func (r *Reconciler) getCaCerts() (string, error) {
+	secret, err := r.SecretLister.Secrets(system.Namespace()).Get(kafkaChannelTLSSecretName)
+	if err != nil {
+		return "", fmt.Errorf("failed to get CA certs from %s/%s: %w", system.Namespace(), kafkaChannelTLSSecretName, err)
+	}
+	caCerts, ok := secret.Data[caCertsSecretKey]
+	if !ok {
+		return "", fmt.Errorf("failed to get CA certs from %s/%s: missing %s key", system.Namespace(), kafkaChannelTLSSecretName, caCertsSecretKey)
+	}
+	return string(caCerts), nil
+}
diff --git a/control-plane/pkg/reconciler/channel/v2/controllerv2.go b/control-plane/pkg/reconciler/channel/v2/controllerv2.go
index 3ad842be5..9d3b9f86a 100644
--- a/control-plane/pkg/reconciler/channel/v2/controllerv2.go
+++ b/control-plane/pkg/reconciler/channel/v2/controllerv2.go
@@ -95,6 +95,10 @@ func NewController(ctx context.Context, configs *config.Env) *controller.Impl {
 
 	reconciler.Tracker = impl.Tracker
 	secretinformer.Get(ctx).Informer().AddEventHandler(controller.HandleAll(reconciler.Tracker.OnChanged))
+	secretinformer.Get(ctx).Informer().AddEventHandler(cache.FilteringResourceEventHandler{
+		FilterFunc: controller.FilterWithName(kafkaChannelTLSSecretName),
+		Handler:    controller.HandleAll(consumergroup.Enqueue("kafkachannel", impl.EnqueueKey)),
+	})
 
 	reconciler.Tracker = impl.Tracker
 	configmapinformer.Get(ctx).Informer().AddEventHandler(controller.HandleAll(
diff --git a/data-plane/dispatcher-vertx/src/main/java/dev/knative/eventing/kafka/broker/dispatchervertx/VertxConsumerFactory.java b/data-plane/dispatcher-vertx/src/main/java/dev/knative/eventing/kafka/broker/dispatchervertx/VertxConsumerFactory.java
new file mode 100644
index 000000000..531277c88
--- /dev/null
+++ b/data-plane/dispatcher-vertx/src/main/java/dev/knative/eventing/kafka/broker/dispatchervertx/VertxConsumerFactory.java
@@ -0,0 +1,34 @@
+/*
+ * Copyright © 2018 Knative Authors (knative-dev@googlegroups.com)
+ *
+ * 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 dev.knative.eventing.kafka.broker.dispatchervertx;
+
+import java.util.Map;
+
+import dev.knative.eventing.kafka.broker.dispatcher.ReactiveConsumerFactory;
+import dev.knative.eventing.kafka.broker.dispatcher.ReactiveKafkaConsumer;
+import io.vertx.core.Vertx;
+import io.vertx.core.tracing.TracingPolicy;
+import io.vertx.kafka.client.common.KafkaClientOptions;
+
+public class VertxConsumerFactory<K, V> implements ReactiveConsumerFactory<K, V> {
+
+    @Override
+    public ReactiveKafkaConsumer<K, V> create(Vertx vertx, Map<String, Object> configs) {
+        return new VertxKafkaConsumer<>(vertx, new KafkaClientOptions().setConfig(configs).setTracingPolicy(TracingPolicy.IGNORE));
+    }
+
+    
+}
diff --git a/data-plane/dispatcher-vertx/src/main/java/dev/knative/eventing/kafka/broker/dispatchervertx/VertxKafkaConsumer.java b/data-plane/dispatcher-vertx/src/main/java/dev/knative/eventing/kafka/broker/dispatchervertx/VertxKafkaConsumer.java
index b94213796..237f20095 100644
--- a/data-plane/dispatcher-vertx/src/main/java/dev/knative/eventing/kafka/broker/dispatchervertx/VertxKafkaConsumer.java
+++ b/data-plane/dispatcher-vertx/src/main/java/dev/knative/eventing/kafka/broker/dispatchervertx/VertxKafkaConsumer.java
@@ -15,8 +15,90 @@
  */
 package dev.knative.eventing.kafka.broker.dispatchervertx;
 
-public class VertxKafkaConsumer {
-    public static void main(String[] args) {
-        System.out.println("Hello Vertx KafkaConsumer!");
+import java.time.Duration;
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import org.apache.kafka.clients.consumer.Consumer;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.OffsetAndMetadata;
+import org.apache.kafka.common.TopicPartition;
+import dev.knative.eventing.kafka.broker.dispatcher.ReactiveKafkaConsumer;
+import io.vertx.core.Future;
+import io.vertx.core.Handler;
+import io.vertx.core.Vertx;
+import io.vertx.kafka.client.common.KafkaClientOptions;
+import io.vertx.kafka.client.consumer.KafkaConsumer;
+
+public class VertxKafkaConsumer<K, V> implements ReactiveKafkaConsumer<K, V> {
+
+    private KafkaConsumer<K, V> consumer;
+
+    public VertxKafkaConsumer(Vertx v, KafkaClientOptions configs) {
+        consumer = KafkaConsumer.create(v, configs);
+    }
+
+    @Override
+    public Future<Map<TopicPartition, OffsetAndMetadata>> commit(Map<TopicPartition, OffsetAndMetadata> offset) {
+
+        final var vertxOffset = offset.entrySet().stream()
+            .collect(Collectors.toMap(
+                entry -> new io.vertx.kafka.client.common.TopicPartition(entry.getKey().topic(),entry.getKey().partition()),
+                entry -> new io.vertx.kafka.client.consumer.OffsetAndMetadata(entry.getValue().offset(),entry.getValue().metadata())
+            ));
+
+        return consumer.commit(vertxOffset).map(vertxOffset.entrySet().stream()
+            .collect(Collectors.toMap(
+                entry -> new TopicPartition(entry.getKey().getTopic(), entry.getKey().getPartition()),
+                entry -> new OffsetAndMetadata(entry.getValue().getOffset(), entry.getValue().getMetadata())
+            ))
+        );
+    }
+
+    @Override
+    public Future<Void> close() {
+        return consumer.close();
+    }
+
+    @Override
+    public Future<Void> pause(Collection<TopicPartition> partitions) {
+        var vertxTopicPartitions = partitions.stream()
+            .map(topicPartition -> new io.vertx.kafka.client.common.TopicPartition(topicPartition.topic(),topicPartition.partition()))
+            .collect(Collectors.toSet());
+
+        return consumer.pause(vertxTopicPartitions);
     }
+
+    @Override
+    public Future<ConsumerRecords<K, V>> poll(Duration timeout) {
+        return consumer.poll(timeout).map(kafkaConsumerRecords -> kafkaConsumerRecords.records());
+    }
+
+    @Override
+    public Future<Void> resume(Collection<TopicPartition> partitions) {
+        var vertxTopicPartitions = partitions.stream()
+            .map(topicPartition -> new io.vertx.kafka.client.common.TopicPartition(topicPartition.topic(),topicPartition.partition()))
+            .collect(Collectors.toSet());
+
+        return consumer.resume(vertxTopicPartitions);
+    }
+
+    @Override
+    public Future<Void> subscribe(Collection<String> topics) {
+        return consumer.subscribe(new HashSet<>(topics));
+    }
+
+    @Override
+    public Consumer<K, V> unwrap() {
+        return consumer.unwrap();
+    }
+
+    @Override
+    public ReactiveKafkaConsumer<K, V> exceptionHandler(Handler<Throwable> handler) {
+        consumer = consumer.exceptionHandler(handler);
+        return this;
+    }
+
 }
diff --git a/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/ReactiveConsumerFactory.java b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/ReactiveConsumerFactory.java
new file mode 100644
index 000000000..cb419722e
--- /dev/null
+++ b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/ReactiveConsumerFactory.java
@@ -0,0 +1,39 @@
+/*
+ * Copyright © 2018 Knative Authors (knative-dev@googlegroups.com)
+ *
+ * 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 dev.knative.eventing.kafka.broker.dispatcher;
+
+import java.util.Map;
+
+import io.vertx.core.Vertx;
+
+/**
+ * A factory interface for creating reactive Kafka consumers.
+ *
+ * @param <K> The type of the Kafka message key.
+ * @param <V> The type of the Kafka message value.
+ */
+@FunctionalInterface
+public interface ReactiveConsumerFactory<K, V> {
+
+    /**
+     * Creates a new reactive Kafka consumer using the provided Vertx instance and configuration.
+     *
+     * @param vertx   The Vertx instance to be used by the vertx consumer only.
+     * @param configs The configuration options for the consumer.
+     * @return The created reactive Kafka consumer.
+     */
+    ReactiveKafkaConsumer<K, V> create(Vertx vertx, Map<String, Object> configs);
+}
diff --git a/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/ReactiveKafkaConsumer.java b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/ReactiveKafkaConsumer.java
new file mode 100644
index 000000000..66c8bf287
--- /dev/null
+++ b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/ReactiveKafkaConsumer.java
@@ -0,0 +1,98 @@
+/*
+ * Copyright © 2018 Knative Authors (knative-dev@googlegroups.com)
+ *
+ * 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 dev.knative.eventing.kafka.broker.dispatcher;
+
+import java.time.Duration;
+import java.util.Collection;
+import java.util.Map;
+
+import org.apache.kafka.clients.consumer.Consumer;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.OffsetAndMetadata;
+import org.apache.kafka.common.TopicPartition;
+import io.vertx.core.Future;
+import io.vertx.core.Handler;
+
+/**
+ * A reactive Kafka consumer interface for handling Kafka communication.
+ *
+ * @param <K> The type of the Kafka message key.
+ * @param <V> The type of the Kafka message value.
+ */
+public interface ReactiveKafkaConsumer<K, V> {
+
+    /**
+     * Commits the specified offsets.
+     *
+     * @param offsets The offsets to commit.
+     * @return A future containing the offsets that were committed.
+     */
+    Future<Map<TopicPartition, OffsetAndMetadata>> commit(Map<TopicPartition, OffsetAndMetadata> offset);
+
+    /**
+     * Closes the consumer.
+     *
+     * @return A future indicating the success or failure of the close operation.
+     */
+    Future<Void> close();
+
+    /**
+     * Pauses consumption from the specified partitions.
+     *
+     * @param partitions The partitions to pause consumption from.
+     * @return A future indicating the success or failure of the pause operation.
+     */
+    Future<Void> pause(Collection<TopicPartition> partitions);
+
+    /**
+     * Polls for records from Kafka with a specified timeout.
+     *
+     * @param timeout The maximum time to wait for records to be available.
+     * @return A future containing the records retrieved from Kafka.
+     */
+    Future<ConsumerRecords<K, V>> poll(Duration timeout);
+
+    /**
+     * Resumes consumption from the specified partitions.
+     *
+     * @param partitions The partitions to resume consumption from.
+     * @return A future indicating the success or failure of the resume operation.
+     */
+    Future<Void> resume(Collection<TopicPartition> partitions);
+
+    /**
+     * Subscribes to the specified topics to start consuming from them.
+     *
+     * @param topics The topics to subscribe to.
+     * @return A future indicating the success or failure of the subscribe operation.
+     */
+    Future<Void> subscribe(Collection<String> topics);
+
+    /**
+     * Retrieves the underlying Kafka Consumer instance.
+     *
+     * @return The KafkaConsumer instance.
+     */
+    Consumer<K, V> unwrap();
+
+    /**
+     * Sets an exception handler for handling exceptions thrown by the consumer.
+     *
+     * @param handler The exception handler.
+     * @return This consumer instance with the exception handler set.
+     */
+    ReactiveKafkaConsumer<K, V> exceptionHandler(Handler<Throwable> handler);
+}
diff --git a/go.mod b/go.mod
index 2e8c909c0..9c486e910 100644
--- a/go.mod
+++ b/go.mod
@@ -38,9 +38,9 @@ require (
 require (
 	github.com/google/gofuzz v1.2.0
 	github.com/kedacore/keda/v2 v2.8.1
-	knative.dev/eventing v0.37.1-0.20230613122645-e5ae71769098
-	knative.dev/hack v0.0.0-20230606014732-a861c8e9da08
-	knative.dev/pkg v0.0.0-20230612155445-74c4be5e935e
+	knative.dev/eventing v0.37.1-0.20230626075347-901ef61643d3
+	knative.dev/hack v0.0.0-20230615155948-d7586a218601
+	knative.dev/pkg v0.0.0-20230616134650-eb63a40adfb0
 	knative.dev/reconciler-test v0.0.0-20230613125845-0061957b480e
 	sigs.k8s.io/controller-runtime v0.12.3
 )
diff --git a/go.sum b/go.sum
index 96d48c721..3f5fd9c1d 100644
--- a/go.sum
+++ b/go.sum
@@ -1523,12 +1523,12 @@ k8s.io/utils v0.0.0-20200912215256-4140de9c8800/go.mod h1:jPW/WVKK9YHAvNhRxK0md/
 k8s.io/utils v0.0.0-20210819203725-bdf08cb9a70a/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
 k8s.io/utils v0.0.0-20221108210102-8e77b1f39fe2 h1:GfD9OzL11kvZN5iArC6oTS7RTj7oJOIfnislxYlqTj8=
 k8s.io/utils v0.0.0-20221108210102-8e77b1f39fe2/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0=
-knative.dev/eventing v0.37.1-0.20230613122645-e5ae71769098 h1:3/tNBkJN6WzN/I5PCMWVVwzlQnOQ7vCSlJVNE/kR6Lo=
-knative.dev/eventing v0.37.1-0.20230613122645-e5ae71769098/go.mod h1:00ZmViqsuF5wC8D9XvPGxfrT3Fb3JIaRvIzjk+3ppHo=
-knative.dev/hack v0.0.0-20230606014732-a861c8e9da08 h1:6DH2ktsj5KoKMAxPFmiDopMCVR1LzhxFNy3D/JCg7JE=
-knative.dev/hack v0.0.0-20230606014732-a861c8e9da08/go.mod h1:yk2OjGDsbEnQjfxdm0/HJKS2WqTLEFg/N6nUs6Rqx3Q=
-knative.dev/pkg v0.0.0-20230612155445-74c4be5e935e h1:koM+NopG2Yw738NlJhQF3ZwpyS+HHznuLm294VYlUKg=
-knative.dev/pkg v0.0.0-20230612155445-74c4be5e935e/go.mod h1:dqC6IrvyBE7E+oZocs5PkVhq1G59pDTA7r8U17EAKMk=
+knative.dev/eventing v0.37.1-0.20230626075347-901ef61643d3 h1:Z5CDWqrT6+ki38ZI2ZBdW21bDRs7bpe79jOoh8f1iSc=
+knative.dev/eventing v0.37.1-0.20230626075347-901ef61643d3/go.mod h1:MRpJ0pRqodV9mlPvRTLXnUOo0ExPDHyEk04Zxjn3bA0=
+knative.dev/hack v0.0.0-20230615155948-d7586a218601 h1:yMe29SMHrAIt3+J+APvf4WVP6cW7ZDtUhh5uxD5ERdA=
+knative.dev/hack v0.0.0-20230615155948-d7586a218601/go.mod h1:yk2OjGDsbEnQjfxdm0/HJKS2WqTLEFg/N6nUs6Rqx3Q=
+knative.dev/pkg v0.0.0-20230616134650-eb63a40adfb0 h1:weQWWxEEbNOPuL4qtGiBZuMSFhcjF/Cu163uktd/xFE=
+knative.dev/pkg v0.0.0-20230616134650-eb63a40adfb0/go.mod h1:dqC6IrvyBE7E+oZocs5PkVhq1G59pDTA7r8U17EAKMk=
 knative.dev/reconciler-test v0.0.0-20230613125845-0061957b480e h1:m9YZbaTbljnHrdIstFP/jXikjYKRuBHz4CQ3YfDS1Og=
 knative.dev/reconciler-test v0.0.0-20230613125845-0061957b480e/go.mod h1:iB/uRML7hm+V0YvUrAxO+SSq1wg0FRi2p8aVCIjbzeo=
 pgregory.net/rapid v0.3.3 h1:jCjBsY4ln4Atz78QoBWxUEvAHaFyNDQg9+WU62aCn1U=
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_conversion.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_conversion.go
index 89911f65e..b3e0ae6ba 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_conversion.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_conversion.go
@@ -35,16 +35,26 @@ func (source *EventType) ConvertTo(ctx context.Context, obj apis.Convertible) er
 			Status: source.Status.Status,
 		}
 		sink.Spec = v1beta2.EventTypeSpec{
-			Type:       source.Spec.Type,
-			Source:     source.Spec.Source,
-			Schema:     source.Spec.Schema,
-			SchemaData: source.Spec.SchemaData,
-			Reference: &duckv1.KReference{
+			Type:        source.Spec.Type,
+			Source:      source.Spec.Source,
+			Schema:      source.Spec.Schema,
+			SchemaData:  source.Spec.SchemaData,
+			Description: source.Spec.Description,
+		}
+
+		// for old stuff, we play nice here
+		// default to broker, but as a reference
+		if source.Spec.Reference == nil && source.Spec.Broker != "" {
+			sink.Spec.Reference = &duckv1.KReference{
 				APIVersion: "eventing.knative.dev/v1",
 				Kind:       "Broker",
 				Name:       source.Spec.Broker,
-			},
-			Description: source.Spec.Description,
+			}
+		}
+
+		// if we have a reference, use it
+		if source.Spec.Reference != nil {
+			sink.Spec.Reference = source.Spec.Reference
 		}
 
 		return nil
@@ -67,7 +77,7 @@ func (sink *EventType) ConvertFrom(ctx context.Context, obj apis.Convertible) er
 			Source:      source.Spec.Source,
 			Schema:      source.Spec.Schema,
 			SchemaData:  source.Spec.SchemaData,
-			Broker:      source.Spec.Reference.Name,
+			Reference:   source.Spec.Reference,
 			Description: source.Spec.Description,
 		}
 
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_defaults.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_defaults.go
index bdcfbf357..115df98d4 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_defaults.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_defaults.go
@@ -23,7 +23,7 @@ func (et *EventType) SetDefaults(ctx context.Context) {
 }
 
 func (ets *EventTypeSpec) SetDefaults(ctx context.Context) {
-	if ets.Broker == "" {
+	if ets.Reference == nil && ets.Broker == "" {
 		ets.Broker = "default"
 	}
 }
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go
index c674e16fc..0c3fd2e8e 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_types.go
@@ -79,6 +79,10 @@ type EventTypeSpec struct {
 	// Broker refers to the Broker that can provide the EventType.
 	// +optional
 	Broker string `json:"broker,omitempty"`
+	// Reference is a KReference to the belonging addressable.
+	// For example, this could be a pointer to a Broker.
+	// +optional
+	Reference *duckv1.KReference `json:"reference,omitempty"`
 	// Description is an optional field used to describe the EventType, in any meaningful way.
 	// +optional
 	Description string `json:"description,omitempty"`
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/zz_generated.deepcopy.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/zz_generated.deepcopy.go
index 20ea81675..381fbe4f5 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/zz_generated.deepcopy.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/zz_generated.deepcopy.go
@@ -24,6 +24,7 @@ package v1beta1
 import (
 	runtime "k8s.io/apimachinery/pkg/runtime"
 	apis "knative.dev/pkg/apis"
+	v1 "knative.dev/pkg/apis/duck/v1"
 )
 
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
@@ -100,6 +101,11 @@ func (in *EventTypeSpec) DeepCopyInto(out *EventTypeSpec) {
 		*out = new(apis.URL)
 		(*in).DeepCopyInto(*out)
 	}
+	if in.Reference != nil {
+		in, out := &in.Reference, &out.Reference
+		*out = new(v1.KReference)
+		(*in).DeepCopyInto(*out)
+	}
 	return
 }
 
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_defaults.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_defaults.go
index 3657729b5..02b6f0f2a 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_defaults.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_defaults.go
@@ -18,20 +18,18 @@ package v1beta2
 
 import (
 	"context"
-
-	duckv1 "knative.dev/pkg/apis/duck/v1"
 )
 
 func (et *EventType) SetDefaults(ctx context.Context) {
 	et.Spec.SetDefaults(ctx)
+	setReferenceNs(et)
 }
 
 func (ets *EventTypeSpec) SetDefaults(ctx context.Context) {
-	if ets.Reference == nil {
-		ets.Reference = &duckv1.KReference{
-			APIVersion: "eventing.knative.dev/v1",
-			Kind:       "Broker",
-			Name:       "default",
-		}
+}
+
+func setReferenceNs(et *EventType) {
+	if et.Spec.Reference != nil && et.Spec.Reference.Namespace == "" {
+		et.Spec.Reference.Namespace = et.GetNamespace()
 	}
 }
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_lifecycle.go
index d19eacef8..300114a8c 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_lifecycle.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta2/eventtype_lifecycle.go
@@ -20,11 +20,11 @@ import (
 	"knative.dev/pkg/apis"
 )
 
-var eventTypeCondSet = apis.NewLivingConditionSet(EventTypeConditionBrokerExists)
+var eventTypeCondSet = apis.NewLivingConditionSet(EventTypeConditionReferenceExists)
 
 const (
-	EventTypeConditionReady                           = apis.ConditionReady
-	EventTypeConditionBrokerExists apis.ConditionType = "BrokerExists"
+	EventTypeConditionReady                              = apis.ConditionReady
+	EventTypeConditionReferenceExists apis.ConditionType = "ReferenceExists"
 )
 
 // GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
@@ -52,14 +52,14 @@ func (et *EventTypeStatus) InitializeConditions() {
 	eventTypeCondSet.Manage(et).InitializeConditions()
 }
 
-func (et *EventTypeStatus) MarkBrokerExists() {
-	eventTypeCondSet.Manage(et).MarkTrue(EventTypeConditionBrokerExists)
+func (et *EventTypeStatus) MarkReferenceExists() {
+	eventTypeCondSet.Manage(et).MarkTrue(EventTypeConditionReferenceExists)
 }
 
-func (et *EventTypeStatus) MarkBrokerDoesNotExist() {
-	eventTypeCondSet.Manage(et).MarkFalse(EventTypeConditionBrokerExists, "BrokerDoesNotExist", "Broker does not exist")
+func (et *EventTypeStatus) MarkReferenceDoesNotExist() {
+	eventTypeCondSet.Manage(et).MarkFalse(EventTypeConditionReferenceExists, "ResourceDoesNotExist", "Resource in spec.reference does not exist")
 }
 
-func (et *EventTypeStatus) MarkBrokerExistsUnknown(reason, messageFormat string, messageA ...interface{}) {
-	eventTypeCondSet.Manage(et).MarkUnknown(EventTypeConditionBrokerExists, reason, messageFormat, messageA...)
+func (et *EventTypeStatus) MarkReferenceExistsUnknown(reason, messageFormat string, messageA ...interface{}) {
+	eventTypeCondSet.Manage(et).MarkUnknown(EventTypeConditionReferenceExists, reason, messageFormat, messageA...)
 }
diff --git a/vendor/knative.dev/eventing/pkg/kncloudevents/http_client_new.go b/vendor/knative.dev/eventing/pkg/kncloudevents/http_client_new.go
index 0c9f1be1a..c5b7abc33 100644
--- a/vendor/knative.dev/eventing/pkg/kncloudevents/http_client_new.go
+++ b/vendor/knative.dev/eventing/pkg/kncloudevents/http_client_new.go
@@ -17,6 +17,7 @@ limitations under the License.
 package kncloudevents
 
 import (
+	"context"
 	"fmt"
 	nethttp "net/http"
 	"sync"
@@ -29,8 +30,9 @@ import (
 )
 
 const (
-	defaultRetryWaitMin = 1 * time.Second
-	defaultRetryWaitMax = 30 * time.Second
+	defaultRetryWaitMin    = 1 * time.Second
+	defaultRetryWaitMax    = 30 * time.Second
+	defaultCleanupInterval = 5 * time.Minute
 )
 
 var (
@@ -38,20 +40,27 @@ var (
 )
 
 type clientsHolder struct {
-	mu             sync.Mutex
-	clients        map[string]*nethttp.Client
-	connectionArgs *ConnectionArgs
+	clientsMu       sync.Mutex
+	clients         map[string]*nethttp.Client
+	timerMu         sync.Mutex
+	connectionArgs  *ConnectionArgs
+	cleanupInterval time.Duration
+	cancelCleanup   context.CancelFunc
 }
 
 func init() {
+	ctx, cancel := context.WithCancel(context.Background())
 	clients = clientsHolder{
-		clients: make(map[string]*nethttp.Client),
+		clients:         make(map[string]*nethttp.Client),
+		cancelCleanup:   cancel,
+		cleanupInterval: defaultCleanupInterval,
 	}
+	go cleanupClientsMap(ctx)
 }
 
 func getClientForAddressable(addressable duckv1.Addressable) (*nethttp.Client, error) {
-	clients.mu.Lock()
-	defer clients.mu.Unlock()
+	clients.clientsMu.Lock()
+	defer clients.clientsMu.Unlock()
 
 	clientKey := addressable.URL.String()
 
@@ -98,8 +107,8 @@ func createNewClient(addressable duckv1.Addressable) (*nethttp.Client, error) {
 }
 
 func AddOrUpdateAddressableHandler(addressable duckv1.Addressable) {
-	clients.mu.Lock()
-	defer clients.mu.Unlock()
+	clients.clientsMu.Lock()
+	defer clients.clientsMu.Unlock()
 
 	clientKey := addressable.URL.String()
 
@@ -112,8 +121,8 @@ func AddOrUpdateAddressableHandler(addressable duckv1.Addressable) {
 }
 
 func DeleteAddressableHandler(addressable duckv1.Addressable) {
-	clients.mu.Lock()
-	defer clients.mu.Unlock()
+	clients.clientsMu.Lock()
+	defer clients.clientsMu.Unlock()
 
 	clientKey := addressable.URL.String()
 
@@ -125,8 +134,8 @@ func DeleteAddressableHandler(addressable duckv1.Addressable) {
 func ConfigureConnectionArgs(ca *ConnectionArgs) {
 	configureConnectionArgsOldClient(ca) //also configure the connection args of the old client
 
-	clients.mu.Lock()
-	defer clients.mu.Unlock()
+	clients.clientsMu.Lock()
+	defer clients.clientsMu.Unlock()
 
 	// Check if same config
 	if clients.connectionArgs != nil &&
@@ -139,8 +148,8 @@ func ConfigureConnectionArgs(ca *ConnectionArgs) {
 	if len(clients.clients) > 0 {
 		// Let's try to clean up a bit the existing clients
 		// Note: this won't remove it nor close it
-		for _, client := range clients.clients {
-			client.CloseIdleConnections()
+		for _, clientEntry := range clients.clients {
+			clientEntry.CloseIdleConnections()
 		}
 
 		// Resetting clients
@@ -150,6 +159,22 @@ func ConfigureConnectionArgs(ca *ConnectionArgs) {
 	clients.connectionArgs = ca
 }
 
+// SetClientCleanupInterval sets the interval before the clients map is re-checked for expired entries.
+// forceRestart will force the loop to restart with the new interval, cancelling the current iteration.
+func SetClientCleanupInterval(cleanupInterval time.Duration, forceRestart bool) {
+	clients.timerMu.Lock()
+	clients.cleanupInterval = cleanupInterval
+	clients.timerMu.Unlock()
+	if forceRestart {
+		clients.clientsMu.Lock()
+		clients.cancelCleanup()
+		ctx, cancel := context.WithCancel(context.Background())
+		clients.cancelCleanup = cancel
+		clients.clientsMu.Unlock()
+		go cleanupClientsMap(ctx)
+	}
+}
+
 // ConnectionArgs allow to configure connection parameters to the underlying
 // HTTP Client transport.
 type ConnectionArgs struct {
@@ -166,3 +191,24 @@ func (ca *ConnectionArgs) configureTransport(transport *nethttp.Transport) {
 	transport.MaxIdleConns = ca.MaxIdleConns
 	transport.MaxIdleConnsPerHost = ca.MaxIdleConnsPerHost
 }
+
+func cleanupClientsMap(ctx context.Context) {
+	for {
+		clients.timerMu.Lock()
+		t := time.NewTimer(clients.cleanupInterval)
+		clients.timerMu.Unlock()
+		select {
+		case <-ctx.Done():
+			clients.timerMu.Lock()
+			t.Stop()
+			clients.timerMu.Unlock()
+			return
+		case <-t.C:
+			clients.clientsMu.Lock()
+			for _, cme := range clients.clients {
+				cme.CloseIdleConnections()
+			}
+			clients.clientsMu.Unlock()
+		}
+	}
+}
diff --git a/vendor/knative.dev/hack/README.md b/vendor/knative.dev/hack/README.md
index b3ad76c5a..5dc34c8ed 100644
--- a/vendor/knative.dev/hack/README.md
+++ b/vendor/knative.dev/hack/README.md
@@ -96,7 +96,7 @@ main "$@"
 This is a helper script for Knative E2E test scripts. To use it:
 
 1. [optional] Customize the test cluster. Pass the flags as described
-   [here](../tools/kntest/pkg/kubetest2/gke/README.md) to the `initialize` function
+   [here](https://github.com/knative/toolbox/blob/main/kntest/pkg/kubetest2/gke/README.md) to the `initialize` function
    call if the default values don't fit your needs.
 
 1. Source the script.
diff --git a/vendor/knative.dev/pkg/environment/client_config.go b/vendor/knative.dev/pkg/environment/client_config.go
index 04d4220b0..aef33927e 100644
--- a/vendor/knative.dev/pkg/environment/client_config.go
+++ b/vendor/knative.dev/pkg/environment/client_config.go
@@ -19,8 +19,10 @@ package environment
 import (
 	"flag"
 	"fmt"
+	"log"
 	"math"
 	"os"
+	"strconv"
 
 	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
@@ -45,9 +47,19 @@ func (c *ClientConfig) InitFlags(fs *flag.FlagSet) {
 	fs.StringVar(&c.Kubeconfig, "kubeconfig", os.Getenv("KUBECONFIG"),
 		"Path to a kubeconfig. Only required if out-of-cluster.")
 
-	fs.IntVar(&c.Burst, "kube-api-burst", 0, "Maximum burst for throttle.")
+	fs.IntVar(&c.Burst, "kube-api-burst", int(envVarOrDefault("KUBE_API_BURST", 0)), "Maximum burst for throttle.")
 
-	fs.Float64Var(&c.QPS, "kube-api-qps", 0, "Maximum QPS to the server from the client.")
+	fs.Float64Var(&c.QPS, "kube-api-qps", envVarOrDefault("KUBE_API_QPS", 0.0), "Maximum QPS to the server from the client.")
+}
+
+func envVarOrDefault(key string, val float64) float64 {
+	var err error
+	if v := os.Getenv(key); v != "" {
+		if val, err = strconv.ParseFloat(v, 64); err != nil {
+			log.Fatal(err)
+		}
+	}
+	return val
 }
 
 func (c *ClientConfig) GetRESTConfig() (*rest.Config, error) {
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 6ee8f1a93..d4cc429ba 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -1236,7 +1236,7 @@ k8s.io/utils/net
 k8s.io/utils/pointer
 k8s.io/utils/strings/slices
 k8s.io/utils/trace
-# knative.dev/eventing v0.37.1-0.20230613122645-e5ae71769098
+# knative.dev/eventing v0.37.1-0.20230626075347-901ef61643d3
 ## explicit; go 1.19
 knative.dev/eventing/cmd/event_display
 knative.dev/eventing/cmd/heartbeats
@@ -1358,6 +1358,7 @@ knative.dev/eventing/test/performance/infra/receiver
 knative.dev/eventing/test/performance/infra/sender
 knative.dev/eventing/test/rekt/features/broker
 knative.dev/eventing/test/rekt/features/channel
+knative.dev/eventing/test/rekt/features/featureflags
 knative.dev/eventing/test/rekt/features/knconf
 knative.dev/eventing/test/rekt/features/trigger
 knative.dev/eventing/test/rekt/resources/account_role
@@ -1389,11 +1390,11 @@ knative.dev/eventing/test/upgrade/prober/wathola/fetcher
 knative.dev/eventing/test/upgrade/prober/wathola/forwarder
 knative.dev/eventing/test/upgrade/prober/wathola/receiver
 knative.dev/eventing/test/upgrade/prober/wathola/sender
-# knative.dev/hack v0.0.0-20230606014732-a861c8e9da08
+# knative.dev/hack v0.0.0-20230615155948-d7586a218601
 ## explicit; go 1.18
 knative.dev/hack
 knative.dev/hack/shell
-# knative.dev/pkg v0.0.0-20230612155445-74c4be5e935e
+# knative.dev/pkg v0.0.0-20230616134650-eb63a40adfb0
 ## explicit; go 1.18
 knative.dev/pkg/apiextensions/storageversion
 knative.dev/pkg/apiextensions/storageversion/cmd/migrate


Test patch:
diff --git a/control-plane/pkg/reconciler/channel/channel_test.go b/control-plane/pkg/reconciler/channel/channel_test.go
index 079413cd1..47e1b53c2 100644
--- a/control-plane/pkg/reconciler/channel/channel_test.go
+++ b/control-plane/pkg/reconciler/channel/channel_test.go
@@ -25,7 +25,10 @@ import (
 	"github.com/Shopify/sarama"
 	"k8s.io/utils/pointer"
 	eventingduck "knative.dev/eventing/pkg/apis/duck/v1"
+	"knative.dev/eventing/pkg/apis/feature"
+	"knative.dev/eventing/pkg/eventingtls/eventingtlstesting"
 	eventingrekttesting "knative.dev/eventing/pkg/reconciler/testing/v1"
+	"knative.dev/pkg/apis"
 	"knative.dev/pkg/network"
 
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/kafka"
@@ -33,9 +36,11 @@ import (
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/security"
 
 	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/types"
 	clientgotesting "k8s.io/client-go/testing"
+	duckv1 "knative.dev/pkg/apis/duck/v1"
 	kubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	"knative.dev/pkg/controller"
 	"knative.dev/pkg/logging"
@@ -68,6 +73,12 @@ const (
 	TestExpectedRetentionDuration = "TestExpectedRetentionDuration"
 )
 
+var (
+	testCaCerts = string(eventingtlstesting.CA)
+
+	kafkaChannelTLSSecretName = "kafka-channel-ingress-server-tls"
+)
+
 var finalizerUpdatedEvent = Eventf(
 	corev1.EventTypeNormal,
 	"FinalizerUpdate",
@@ -1673,6 +1684,205 @@ func TestReconcileKind(t *testing.T) {
 				),
 			},
 		},
+		{
+			Name: "Reconciled normal - TLS Permissive",
+			Objects: []runtime.Object{
+				NewChannel(
+					WithChannelDelivery(&eventingduck.DeliverySpec{
+						DeadLetterSink: ServiceDestination,
+						Retry:          pointer.Int32(5),
+					}),
+				),
+				NewService(),
+				NewPerChannelService(DefaultEnv),
+				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,
+				}),
+				makeTLSSecret(),
+			},
+			Key: testKey,
+			Ctx: feature.ToContext(context.Background(), feature.Flags{
+				feature.TransportEncryption: feature.Permissive,
+			}),
+			WantUpdates: []clientgotesting.UpdateActionImpl{
+				ConfigMapUpdate(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, env.ContractConfigMapFormat, &contract.Contract{
+					Generation: 1,
+					Resources: []*contract.Resource{
+						{
+							Uid:              ChannelUUID,
+							Topics:           []string{ChannelTopic()},
+							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
+							Ingress: &contract.Ingress{
+								Host: receiver.Host(ChannelNamespace, ChannelName),
+							},
+							EgressConfig: &contract.EgressConfig{
+								DeadLetter: ServiceURL,
+								Retry:      5,
+							},
+						},
+					},
+				}),
+				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",
+				}),
+			},
+			SkipNamespaceValidation: true, // WantCreates compare the channel namespace with configmap namespace, so skip it
+			WantCreates: []runtime.Object{
+				NewConfigMapWithBinaryData(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, nil),
+			},
+			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
+				{
+					Object: NewChannel(
+						WithChannelDelivery(&eventingduck.DeliverySpec{
+							DeadLetterSink: ServiceDestination,
+							Retry:          pointer.Int32(5),
+						}),
+						WithInitKafkaChannelConditions,
+						StatusConfigParsed,
+						StatusConfigMapUpdatedReady(&env),
+						StatusTopicReadyWithName(ChannelTopic()),
+						StatusDataPlaneAvailable,
+						ChannelAddressable(&env),
+						StatusProbeSucceeded,
+						WithChannelDeadLetterSinkURI(ServiceURL),
+						WithChannelAddresses([]duckv1.Addressable{
+							{
+								Name:    pointer.String("https"),
+								URL:     httpsURL(ChannelServiceName, ChannelNamespace),
+								CACerts: pointer.String(testCaCerts),
+							},
+							{
+								Name: pointer.String("http"),
+								URL:  ChannelAddress(),
+							},
+						}),
+						WithChannelAddress(duckv1.Addressable{
+							Name: pointer.String("http"),
+							URL:  ChannelAddress(),
+						}),
+						WithChannelAddessable(),
+					),
+				},
+			},
+			WantPatches: []clientgotesting.PatchActionImpl{
+				patchFinalizers(),
+			},
+			WantEvents: []string{
+				finalizerUpdatedEvent,
+			},
+		},
+		{
+			Name: "Reconciled normal - TLS Strict",
+			Objects: []runtime.Object{
+				NewChannel(
+					WithChannelDelivery(&eventingduck.DeliverySpec{
+						DeadLetterSink: ServiceDestination,
+						Retry:          pointer.Int32(5),
+					}),
+				),
+				NewService(),
+				NewPerChannelService(DefaultEnv),
+				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,
+				}),
+				makeTLSSecret(),
+			},
+			Key: testKey,
+			Ctx: feature.ToContext(context.Background(), feature.Flags{
+				feature.TransportEncryption: feature.Strict,
+			}),
+			WantUpdates: []clientgotesting.UpdateActionImpl{
+				ConfigMapUpdate(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, env.ContractConfigMapFormat, &contract.Contract{
+					Generation: 1,
+					Resources: []*contract.Resource{
+						{
+							Uid:              ChannelUUID,
+							Topics:           []string{ChannelTopic()},
+							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
+							Ingress: &contract.Ingress{
+								Host: receiver.Host(ChannelNamespace, ChannelName),
+							},
+							EgressConfig: &contract.EgressConfig{
+								DeadLetter: ServiceURL,
+								Retry:      5,
+							},
+						},
+					},
+				}),
+				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",
+				}),
+			},
+			SkipNamespaceValidation: true, // WantCreates compare the channel namespace with configmap namespace, so skip it
+			WantCreates: []runtime.Object{
+				NewConfigMapWithBinaryData(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, nil),
+			},
+			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
+				{
+					Object: NewChannel(
+						WithChannelDelivery(&eventingduck.DeliverySpec{
+							DeadLetterSink: ServiceDestination,
+							Retry:          pointer.Int32(5),
+						}),
+						WithInitKafkaChannelConditions,
+						StatusConfigParsed,
+						StatusConfigMapUpdatedReady(&env),
+						StatusTopicReadyWithName(ChannelTopic()),
+						StatusDataPlaneAvailable,
+						ChannelAddressable(&env),
+						StatusProbeSucceeded,
+						WithChannelDeadLetterSinkURI(ServiceURL),
+						WithChannelAddresses([]duckv1.Addressable{
+							{
+								Name:    pointer.String("https"),
+								URL:     httpsURL(ChannelServiceName, ChannelNamespace),
+								CACerts: pointer.String(testCaCerts),
+							},
+						}),
+						WithChannelAddress(duckv1.Addressable{
+							Name:    pointer.String("https"),
+							URL:     httpsURL(ChannelServiceName, ChannelNamespace),
+							CACerts: pointer.String(testCaCerts),
+						}),
+						WithChannelAddessable(),
+					),
+				},
+			},
+			WantPatches: []clientgotesting.PatchActionImpl{
+				patchFinalizers(),
+			},
+			WantEvents: []string{
+				finalizerUpdatedEvent,
+			},
+		},
 	}
 
 	useTable(t, table, env)
@@ -1835,3 +2045,24 @@ func patchFinalizers() clientgotesting.PatchActionImpl {
 	action.Patch = []byte(patch)
 	return action
 }
+
+func makeTLSSecret() *corev1.Secret {
+	return &corev1.Secret{
+		ObjectMeta: metav1.ObjectMeta{
+			Namespace: DefaultEnv.SystemNamespace,
+			Name:      kafkaChannelTLSSecretName,
+		},
+		Data: map[string][]byte{
+			"ca.crt": []byte(testCaCerts),
+		},
+		Type: corev1.SecretTypeTLS,
+	}
+}
+
+func httpsURL(name string, namespace string) *apis.URL {
+	return &apis.URL{
+		Scheme: "https",
+		Host:   network.GetServiceHostname(DefaultEnv.IngressName, DefaultEnv.SystemNamespace),
+		Path:   fmt.Sprintf("/%s/%s", namespace, name),
+	}
+}
diff --git a/control-plane/pkg/reconciler/channel/controller_test.go b/control-plane/pkg/reconciler/channel/controller_test.go
index ecc385569..3536a31f2 100644
--- a/control-plane/pkg/reconciler/channel/controller_test.go
+++ b/control-plane/pkg/reconciler/channel/controller_test.go
@@ -22,13 +22,16 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/types"
 	fakekubeclientset "k8s.io/client-go/kubernetes/fake"
 	_ "knative.dev/eventing-kafka-broker/control-plane/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake"
 	_ "knative.dev/eventing/pkg/client/injection/informers/messaging/v1/subscription/fake"
+	"knative.dev/eventing/pkg/eventingtls/eventingtlstesting"
 	_ "knative.dev/pkg/client/injection/ducks/duck/v1/addressable/fake"
 	fakekubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/configmap/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/pod/fake"
+	secretinformer "knative.dev/pkg/client/injection/kube/informers/core/v1/secret"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/secret/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/service/fake"
 	dynamicclient "knative.dev/pkg/injection/clients/dynamicclient/fake"
@@ -46,6 +49,22 @@ func TestNewController(t *testing.T) {
 		IngressPodPort:       "8080",
 	}
 
+	secret := types.NamespacedName{
+		Namespace: "knative-eventing",
+		Name:      kafkaChannelTLSSecretName,
+	}
+
+	_ = secretinformer.Get(ctx).Informer().GetStore().Add(&corev1.Secret{
+		ObjectMeta: metav1.ObjectMeta{
+			Namespace: secret.Namespace,
+			Name:      secret.Name,
+		},
+		Data: map[string][]byte{
+			"ca.crt": eventingtlstesting.CA,
+		},
+		Type: corev1.SecretTypeTLS,
+	})
+
 	ctx, _ = fakekubeclient.With(
 		ctx,
 		&corev1.ConfigMap{
diff --git a/control-plane/pkg/reconciler/channel/v2/channelv2_test.go b/control-plane/pkg/reconciler/channel/v2/channelv2_test.go
index eb5887b85..86a81a051 100644
--- a/control-plane/pkg/reconciler/channel/v2/channelv2_test.go
+++ b/control-plane/pkg/reconciler/channel/v2/channelv2_test.go
@@ -24,11 +24,15 @@ import (
 
 	"github.com/Shopify/sarama"
 	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	clientgotesting "k8s.io/client-go/testing"
 	"k8s.io/utils/pointer"
 	eventingduck "knative.dev/eventing/pkg/apis/duck/v1"
+	"knative.dev/eventing/pkg/apis/feature"
+	"knative.dev/eventing/pkg/eventingtls/eventingtlstesting"
+	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 	kubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	"knative.dev/pkg/controller"
@@ -36,6 +40,7 @@ import (
 	"knative.dev/pkg/logging"
 	"knative.dev/pkg/network"
 	. "knative.dev/pkg/reconciler/testing"
+	"knative.dev/pkg/system"
 
 	kafkasource "knative.dev/eventing-kafka-broker/control-plane/pkg/apis/sources/v1beta1"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/config"
@@ -84,6 +89,10 @@ var DefaultEnv = &config.Env{
 	ContractConfigMapFormat:     base.Json,
 }
 
+var (
+	testCaCerts = string(eventingtlstesting.CA)
+)
+
 func TestReconcileKind(t *testing.T) {
 
 	messagingv1beta.RegisterAlternateKafkaChannelConditionSet(conditionSet)
@@ -410,7 +419,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single fresh subscriber - cg unknown - no auth",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1(WithFreshSubscriber))),
+				NewChannel(
+					WithSubscribers(Subscriber1(WithFreshSubscriber))),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
 					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
 				}),
@@ -477,7 +487,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single unready subscriber - cg unknown - no auth",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1(WithUnreadySubscriber))),
+				NewChannel(
+					WithSubscribers(Subscriber1(WithUnreadySubscriber))),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
 					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
 				}),
@@ -523,6 +534,7 @@ func TestReconcileKind(t *testing.T) {
 			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
 				{
 					Object: NewChannel(
+
 						WithInitKafkaChannelConditions,
 						StatusConfigParsed,
 						StatusConfigMapUpdatedReady(&env),
@@ -544,7 +556,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single ready subscriber - cg unknown - no auth",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1())),
+				NewChannel(
+					WithSubscribers(Subscriber1())),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
 					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
 				}),
@@ -611,7 +624,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single fresh subscriber - existing ready cg with update - no auth",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1(WithFreshSubscriber))),
+				NewChannel(
+					WithSubscribers(Subscriber1(WithFreshSubscriber))),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
 					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
 				}),
@@ -666,6 +680,7 @@ func TestReconcileKind(t *testing.T) {
 			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
 				{
 					Object: NewChannel(
+
 						WithInitKafkaChannelConditions,
 						StatusConfigParsed,
 						StatusConfigMapUpdatedReady(&env),
@@ -687,7 +702,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single fresh subscriber - existing cg but failed - no auth",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1(WithFreshSubscriber))),
+				NewChannel(
+					WithSubscribers(Subscriber1(WithFreshSubscriber))),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
 					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
 				}),
@@ -756,6 +772,7 @@ func TestReconcileKind(t *testing.T) {
 			Name: "Reconciled normal - with two fresh subscribers - no auth",
 			Objects: []runtime.Object{
 				NewChannel(
+
 					WithSubscribers(Subscriber1(WithFreshSubscriber)),
 					WithSubscribers(Subscriber2(WithFreshSubscriber)),
 				),
@@ -820,6 +837,7 @@ func TestReconcileKind(t *testing.T) {
 			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
 				{
 					Object: NewChannel(
+
 						WithInitKafkaChannelConditions,
 						StatusConfigParsed,
 						StatusConfigMapUpdatedReady(&env),
@@ -842,6 +860,7 @@ func TestReconcileKind(t *testing.T) {
 			Name: "Reconciled normal - with one fresh subscriber and one removed subscriber (cg removal needed)",
 			Objects: []runtime.Object{
 				NewChannel(
+
 					WithSubscribers(Subscriber1(WithFreshSubscriber)),
 				),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
@@ -1029,6 +1048,7 @@ func TestReconcileKind(t *testing.T) {
 			Name: "Channel spec is used properly",
 			Objects: []runtime.Object{
 				NewChannel(
+
 					WithNumPartitions(3),
 					WithReplicationFactor(4),
 					WithRetentionDuration("PT10M"),
@@ -1090,7 +1110,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single fresh subscriber - with auth - SSL",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1(WithFreshSubscriber))),
+				NewChannel(
+					WithSubscribers(Subscriber1(WithFreshSubscriber))),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
 					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
 					security.AuthSecretNameKey:         "secret-1",
@@ -1188,7 +1209,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single fresh subscriber - with auth - SASL SSL",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1(WithFreshSubscriber))),
+				NewChannel(
+					WithSubscribers(Subscriber1(WithFreshSubscriber))),
 				//NewService(),
 				NewPerChannelService(DefaultEnv),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
@@ -1288,7 +1310,8 @@ func TestReconcileKind(t *testing.T) {
 		{
 			Name: "Reconciled normal - with single fresh subscriber - with auth - SASL",
 			Objects: []runtime.Object{
-				NewChannel(WithSubscribers(Subscriber1(WithFreshSubscriber))),
+				NewChannel(
+					WithSubscribers(Subscriber1(WithFreshSubscriber))),
 				NewPerChannelService(DefaultEnv),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
 					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
@@ -1385,6 +1408,7 @@ func TestReconcileKind(t *testing.T) {
 			Name: "Reconciled normal - with single fresh subscriber - with autoscaling annotations",
 			Objects: []runtime.Object{
 				NewChannel(
+
 					WithSubscribers(Subscriber1(WithFreshSubscriber)),
 				),
 				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
@@ -1591,6 +1615,187 @@ func TestReconcileKind(t *testing.T) {
 				),
 			},
 		},
+		{
+			Name: "Reconciled normal - TLS Permissive",
+			Objects: []runtime.Object{
+				NewChannel(
+					WithChannelDelivery(&eventingduck.DeliverySpec{
+						DeadLetterSink: ServiceDestination,
+						Retry:          pointer.Int32(5),
+					}),
+				),
+				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
+					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
+				}),
+				ChannelReceiverPod(env.SystemNamespace, map[string]string{
+					base.VolumeGenerationAnnotationKey: "0",
+					"annotation_to_preserve":           "value_to_preserve",
+				}),
+				makeTLSSecret(),
+			},
+			Key: testKey,
+			Ctx: feature.ToContext(context.Background(), feature.Flags{
+				feature.TransportEncryption: feature.Permissive,
+			}),
+			WantUpdates: []clientgotesting.UpdateActionImpl{
+				ConfigMapUpdate(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, env.ContractConfigMapFormat, &contract.Contract{
+					Generation: 1,
+					Resources: []*contract.Resource{
+						{
+							Uid:              ChannelUUID,
+							Topics:           []string{ChannelTopic()},
+							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
+							Ingress: &contract.Ingress{
+								Host: receiver.Host(ChannelNamespace, ChannelName),
+							},
+							EgressConfig: &contract.EgressConfig{
+								DeadLetter: ServiceURL,
+								Retry:      5,
+							},
+						},
+					},
+				}),
+				ChannelReceiverPodUpdate(env.SystemNamespace, map[string]string{
+					"annotation_to_preserve":           "value_to_preserve",
+					base.VolumeGenerationAnnotationKey: "1",
+				}),
+			},
+			SkipNamespaceValidation: true, // WantCreates compare the channel namespace with configmap namespace, so skip it
+			WantCreates: []runtime.Object{
+				NewConfigMapWithBinaryData(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, nil),
+				NewPerChannelService(&env),
+			},
+			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
+				{
+					Object: NewChannel(
+						WithChannelDelivery(&eventingduck.DeliverySpec{
+							DeadLetterSink: ServiceDestination,
+							Retry:          pointer.Int32(5),
+						}),
+						WithInitKafkaChannelConditions,
+						StatusConfigParsed,
+						StatusConfigMapUpdatedReady(&env),
+						StatusTopicReadyWithName(ChannelTopic()),
+						ChannelAddressable(&env),
+						StatusProbeSucceeded,
+						StatusChannelSubscribers(),
+						WithChannelDeadLetterSinkURI(ServiceURL),
+						WithChannelAddresses([]duckv1.Addressable{
+							{
+								Name:    pointer.String("https"),
+								URL:     httpsURL(ChannelServiceName, ChannelNamespace),
+								CACerts: pointer.String(testCaCerts),
+							},
+							{
+								Name: pointer.String("http"),
+								URL:  ChannelAddress(),
+							},
+						}),
+						WithChannelAddress(duckv1.Addressable{
+							Name: pointer.String("http"),
+							URL:  ChannelAddress(),
+						}),
+						WithChannelAddessable(),
+					),
+				},
+			},
+			WantPatches: []clientgotesting.PatchActionImpl{
+				patchFinalizers(),
+			},
+			WantEvents: []string{
+				finalizerUpdatedEvent,
+			},
+		},
+		{
+			Name: "Reconciled normal - TLS Strict",
+			Objects: []runtime.Object{
+				NewChannel(
+					WithChannelDelivery(&eventingduck.DeliverySpec{
+						DeadLetterSink: ServiceDestination,
+						Retry:          pointer.Int32(5),
+					}),
+				),
+				NewConfigMapWithTextData(env.SystemNamespace, DefaultEnv.GeneralConfigMapName, map[string]string{
+					kafka.BootstrapServersConfigMapKey: ChannelBootstrapServers,
+				}),
+				ChannelReceiverPod(env.SystemNamespace, map[string]string{
+					base.VolumeGenerationAnnotationKey: "0",
+					"annotation_to_preserve":           "value_to_preserve",
+				}),
+				makeTLSSecret(),
+			},
+			Key: testKey,
+			Ctx: feature.ToContext(context.Background(), feature.Flags{
+				feature.TransportEncryption: feature.Strict,
+			}),
+			WantUpdates: []clientgotesting.UpdateActionImpl{
+				ConfigMapUpdate(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, env.ContractConfigMapFormat, &contract.Contract{
+					Generation: 1,
+					Resources: []*contract.Resource{
+						{
+							Uid:              ChannelUUID,
+							Topics:           []string{ChannelTopic()},
+							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
+							Ingress: &contract.Ingress{
+								Host: receiver.Host(ChannelNamespace, ChannelName),
+							},
+							EgressConfig: &contract.EgressConfig{
+								DeadLetter: ServiceURL,
+								Retry:      5,
+							},
+						},
+					},
+				}),
+				ChannelReceiverPodUpdate(env.SystemNamespace, map[string]string{
+					"annotation_to_preserve":           "value_to_preserve",
+					base.VolumeGenerationAnnotationKey: "1",
+				}),
+			},
+			SkipNamespaceValidation: true, // WantCreates compare the channel namespace with configmap namespace, so skip it
+			WantCreates: []runtime.Object{
+				NewConfigMapWithBinaryData(env.DataPlaneConfigMapNamespace, env.ContractConfigMapName, nil),
+				NewPerChannelService(&env),
+			},
+			WantStatusUpdates: []clientgotesting.UpdateActionImpl{
+				{
+					Object: NewChannel(
+						WithChannelDelivery(&eventingduck.DeliverySpec{
+							DeadLetterSink: ServiceDestination,
+							Retry:          pointer.Int32(5),
+						}),
+						WithInitKafkaChannelConditions,
+						StatusConfigParsed,
+						StatusConfigMapUpdatedReady(&env),
+						StatusTopicReadyWithName(ChannelTopic()),
+						ChannelAddressable(&env),
+						StatusProbeSucceeded,
+						StatusChannelSubscribers(),
+						WithChannelDeadLetterSinkURI(ServiceURL),
+						WithChannelAddresses([]duckv1.Addressable{
+							{
+								Name:    pointer.String("https"),
+								URL:     httpsURL(ChannelServiceName, ChannelNamespace),
+								CACerts: pointer.String(testCaCerts),
+							},
+						}),
+						WithChannelAddress(duckv1.Addressable{
+							Name:    pointer.String("https"),
+							URL:     httpsURL(ChannelServiceName, ChannelNamespace),
+							CACerts: pointer.String(testCaCerts),
+						}),
+						WithChannelAddessable(),
+					),
+				},
+			},
+			WantPatches: []clientgotesting.PatchActionImpl{
+				patchFinalizers(),
+			},
+			WantEvents: []string{
+				finalizerUpdatedEvent,
+			},
+		},
 	}
 
 	table.Test(t, NewFactory(&env, func(ctx context.Context, listers *Listers, env *config.Env, row *TableRow) controller.Reconciler {
@@ -1698,3 +1903,24 @@ func patchFinalizers() clientgotesting.PatchActionImpl {
 	action.Patch = []byte(patch)
 	return action
 }
+
+func makeTLSSecret() *corev1.Secret {
+	return &corev1.Secret{
+		ObjectMeta: metav1.ObjectMeta{
+			Namespace: system.Namespace(),
+			Name:      kafkaChannelTLSSecretName,
+		},
+		Data: map[string][]byte{
+			"ca.crt": []byte(testCaCerts),
+		},
+		Type: corev1.SecretTypeTLS,
+	}
+}
+
+func httpsURL(name string, namespace string) *apis.URL {
+	return &apis.URL{
+		Scheme: "https",
+		Host:   network.GetServiceHostname(DefaultEnv.IngressName, DefaultEnv.SystemNamespace),
+		Path:   fmt.Sprintf("/%s/%s", namespace, name),
+	}
+}
diff --git a/control-plane/pkg/reconciler/channel/v2/controllerv2_test.go b/control-plane/pkg/reconciler/channel/v2/controllerv2_test.go
index 12f8c92c2..c0e209c1d 100644
--- a/control-plane/pkg/reconciler/channel/v2/controllerv2_test.go
+++ b/control-plane/pkg/reconciler/channel/v2/controllerv2_test.go
@@ -22,14 +22,17 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/types"
 	fakekubeclientset "k8s.io/client-go/kubernetes/fake"
 
 	_ "knative.dev/eventing-kafka-broker/control-plane/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake"
 	_ "knative.dev/eventing/pkg/client/injection/informers/messaging/v1/subscription/fake"
+	"knative.dev/eventing/pkg/eventingtls/eventingtlstesting"
 	_ "knative.dev/pkg/client/injection/ducks/duck/v1/addressable/fake"
 	fakekubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/configmap/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/pod/fake"
+	secretinformer "knative.dev/pkg/client/injection/kube/informers/core/v1/secret"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/secret/fake"
 	_ "knative.dev/pkg/client/injection/kube/informers/core/v1/service/fake"
 	dynamicclient "knative.dev/pkg/injection/clients/dynamicclient/fake"
@@ -49,6 +52,22 @@ func TestNewController(t *testing.T) {
 		IngressPodPort:       "8080",
 	}
 
+	secret := types.NamespacedName{
+		Namespace: "knative-eventing",
+		Name:      kafkaChannelTLSSecretName,
+	}
+
+	_ = secretinformer.Get(ctx).Informer().GetStore().Add(&corev1.Secret{
+		ObjectMeta: metav1.ObjectMeta{
+			Namespace: secret.Namespace,
+			Name:      secret.Name,
+		},
+		Data: map[string][]byte{
+			"ca.crt": eventingtlstesting.CA,
+		},
+		Type: corev1.SecretTypeTLS,
+	})
+
 	ctx, _ = fakekubeclient.With(
 		ctx,
 		&corev1.ConfigMap{
diff --git a/control-plane/pkg/reconciler/testing/objects_channel.go b/control-plane/pkg/reconciler/testing/objects_channel.go
index 2a7b6127b..f6195d7f2 100644
--- a/control-plane/pkg/reconciler/testing/objects_channel.go
+++ b/control-plane/pkg/reconciler/testing/objects_channel.go
@@ -209,13 +209,17 @@ func ChannelAddressable(env *config.Env) func(obj duckv1.KRShaped) {
 	return func(obj duckv1.KRShaped) {
 		channel := obj.(*messagingv1beta1.KafkaChannel)
 
-		channel.Status.Address = &duckv1.Addressable{}
-
-		channel.Status.Address.URL = &apis.URL{
-			Scheme: "http",
-			Host:   fmt.Sprintf("%s.%s.svc.%s", resources.MakeChannelServiceName(channel.Name), channel.Namespace, network.GetClusterDomainName()),
+		httpAddress := &duckv1.Addressable{
+			Name: pointer.String("http"),
+			URL: &apis.URL{
+				Scheme: "http",
+				Host:   fmt.Sprintf("%s.%s.svc.%s", resources.MakeChannelServiceName(channel.Name), channel.Namespace, network.GetClusterDomainName()),
+			},
 		}
 
+		channel.Status.Address = httpAddress
+		channel.Status.Addresses = []duckv1.Addressable{*httpAddress}
+
 		channel.GetConditionSet().Manage(&channel.Status).MarkTrue(base.ConditionAddressable)
 	}
 }
@@ -376,3 +380,31 @@ func ChannelAsOwnerReference() metav1.OwnerReference {
 		BlockOwnerDeletion: pointer.Bool(true),
 	}
 }
+
+func WithChannelAddress(address duckv1.Addressable) KRShapedOption {
+	return func(obj duckv1.KRShaped) {
+		ch := obj.(*messagingv1beta1.KafkaChannel)
+		ch.Status.Address = &address
+	}
+}
+
+func WithChannelAddresses(addresses []duckv1.Addressable) KRShapedOption {
+	return func(obj duckv1.KRShaped) {
+		ch := obj.(*messagingv1beta1.KafkaChannel)
+		ch.Status.Addresses = addresses
+	}
+}
+
+func WithChannelAddessable() KRShapedOption {
+	return func(obj duckv1.KRShaped) {
+		ch := obj.(*messagingv1beta1.KafkaChannel)
+		ch.GetConditionSet().Manage(ch.GetStatus()).MarkTrue(base.ConditionAddressable)
+	}
+}
+
+func ChannelAddress() *apis.URL {
+	return &apis.URL{
+		Scheme: "http",
+		Host:   fmt.Sprintf("%s.%s.svc.%s", ChannelServiceName, ChannelNamespace, network.GetClusterDomainName()),
+	}
+}
diff --git a/third_party/eventing-latest/eventing-core.yaml b/third_party/eventing-latest/eventing-core.yaml
index 3b78a8682..6f7f9b4a3 100644
--- a/third_party/eventing-latest/eventing-core.yaml
+++ b/third_party/eventing-latest/eventing-core.yaml
@@ -16,7 +16,7 @@ kind: Namespace
 metadata:
   name: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 
 ---
@@ -40,7 +40,7 @@ metadata:
   name: eventing-controller
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -48,7 +48,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -64,7 +64,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-resolver
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -80,7 +80,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-source-observer
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -96,7 +96,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-sources-controller
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -112,7 +112,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-manipulator
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -144,7 +144,7 @@ metadata:
   name: pingsource-mt-adapter
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -152,7 +152,7 @@ kind: ClusterRoleBinding
 metadata:
   name: knative-eventing-pingsource-mt-adapter
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -184,7 +184,7 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -192,7 +192,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -209,7 +209,7 @@ metadata:
   namespace: knative-eventing
   name: eventing-webhook
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -225,7 +225,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook-resolver
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -241,7 +241,7 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook-podspecable-binding
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -273,7 +273,7 @@ metadata:
   name: config-br-default-channel
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 data:
   channel-template-spec: |
@@ -301,7 +301,7 @@ metadata:
   name: config-br-defaults
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 data:
   # Configures the default for any Broker that does not specify a spec.config or Broker class.
@@ -338,7 +338,7 @@ metadata:
   name: default-ch-webhook
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 data:
   # Configuration for defaulting channels that do not specify CRD implementations.
@@ -374,7 +374,7 @@ metadata:
   labels:
   annotations:
     knative.dev/example-checksum: "9185c153"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 data:
   _example: |
@@ -420,7 +420,7 @@ metadata:
   labels:
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 data:
   # ALPHA feature: The kreference-group allows you to use the Group field in KReferences.
@@ -512,7 +512,7 @@ metadata:
   name: config-leader-election
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "f7948630"
@@ -575,7 +575,7 @@ metadata:
   labels:
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 data:
   # Common configuration for all Knative codebase
@@ -628,7 +628,7 @@ metadata:
   labels:
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "f46cf09d"
@@ -702,7 +702,7 @@ metadata:
   name: config-sugar
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "62dfac6f"
@@ -761,7 +761,7 @@ metadata:
   labels:
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "0492ceb0"
@@ -818,7 +818,7 @@ metadata:
   labels:
     knative.dev/high-availability: "true"
     app.kubernetes.io/component: eventing-controller
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -829,7 +829,7 @@ spec:
       labels:
         app: eventing-controller
         app.kubernetes.io/component: eventing-controller
-        app.kubernetes.io/version: "20230614-49d4acd9a"
+        app.kubernetes.io/version: "20230625-95cdbaa7a"
         app.kubernetes.io/name: knative-eventing
     spec:
       # To avoid node becoming SPOF, spread our replicas to different nodes.
@@ -847,7 +847,7 @@ spec:
       containers:
         - name: eventing-controller
           terminationMessagePolicy: FallbackToLogsOnError
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/controller@sha256:484ca728f6254881151cd8685054b93a9f76a011a17d5d6f613c4ae958437a85
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/controller@sha256:8d58b547886de5414122cade411aa59645536f86524f94bbb4a739c9f3e850f9
           resources:
             requests:
               cpu: 100m
@@ -865,7 +865,7 @@ spec:
               value: knative.dev/eventing
             # APIServerSource
             - name: APISERVER_RA_IMAGE
-              value: gcr.io/knative-nightly/knative.dev/eventing/cmd/apiserver_receive_adapter@sha256:5765872fe7b715674fbf807b5470fab189962460f417e48ff7f30e5d58a0d5ec
+              value: gcr.io/knative-nightly/knative.dev/eventing/cmd/apiserver_receive_adapter@sha256:9ba9bd9931420b1edeb8be756fd5d6a15e59778ea954d0f52b7cde2217f3ae8e
             - name: POD_NAME
               valueFrom:
                 fieldRef:
@@ -935,7 +935,7 @@ metadata:
   namespace: knative-eventing
   labels:
     app.kubernetes.io/component: pingsource-mt-adapter
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     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.
@@ -949,7 +949,7 @@ spec:
       labels:
         !!merge <<: *labels
         app.kubernetes.io/component: pingsource-mt-adapter
-        app.kubernetes.io/version: "20230614-49d4acd9a"
+        app.kubernetes.io/version: "20230625-95cdbaa7a"
         app.kubernetes.io/name: knative-eventing
     spec:
       affinity:
@@ -963,7 +963,7 @@ spec:
       enableServiceLinks: false
       containers:
         - name: dispatcher
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/mtping@sha256:4340739106f18d021c467d4c5f6bd59ad81ca0f50d0e99b35eadfcf50d38cc42
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/mtping@sha256:592a82a6419701528b8c5f709095960f6519cb67474fdb0f12cc6367e46ecb4d
           env:
             - name: SYSTEM_NAMESPACE
               value: ''
@@ -1037,7 +1037,7 @@ metadata:
   namespace: knative-eventing
   labels:
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   scaleTargetRef:
@@ -1062,7 +1062,7 @@ metadata:
   namespace: knative-eventing
   labels:
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   minAvailable: 80%
@@ -1092,7 +1092,7 @@ metadata:
   namespace: knative-eventing
   labels:
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -1104,7 +1104,7 @@ spec:
       labels:
         !!merge <<: *labels
         app.kubernetes.io/component: eventing-webhook
-        app.kubernetes.io/version: "20230614-49d4acd9a"
+        app.kubernetes.io/version: "20230625-95cdbaa7a"
         app.kubernetes.io/name: knative-eventing
     spec:
       # To avoid node becoming SPOF, spread our replicas to different nodes.
@@ -1124,7 +1124,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:36c655dd47b177298166edea2794c0c82c5a837062fb49028d80dfc9aa17ffd8
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/webhook@sha256:1980ecdfa0f037e76d77109c2d331f799890d333e338b8cfebff9fea6b4bc1ac
           resources:
             requests:
               # taken from serving.
@@ -1197,7 +1197,7 @@ metadata:
   labels:
     role: eventing-webhook
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   name: eventing-webhook
   namespace: knative-eventing
@@ -1232,7 +1232,7 @@ metadata:
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -1482,7 +1482,7 @@ metadata:
   labels:
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -1659,7 +1659,7 @@ metadata:
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -1945,7 +1945,7 @@ metadata:
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   name: containersources.sources.knative.dev
 spec:
@@ -2102,7 +2102,7 @@ metadata:
   name: eventtypes.eventing.knative.dev
   labels:
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -2124,6 +2124,22 @@ spec:
               properties:
                 broker:
                   type: string
+                reference:
+                  description: Reference Broker. For example
+                  type: object
+                  properties:
+                    apiVersion:
+                      description: API version of the referent.
+                      type: string
+                    kind:
+                      description: 'Kind of the referent. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
+                      type: string
+                    name:
+                      description: 'Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names'
+                      type: string
+                    namespace:
+                      description: 'Namespace of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/namespaces/ This is an optional field, it gets defaulted to the object holding it if left out.'
+                      type: string
                 description:
                   description: 'Description is an optional field used to describe the EventType, in any meaningful way.'
                   type: string
@@ -2207,87 +2223,7 @@ spec:
       name: v1beta2
       served: true
       storage: false
-      schema:
-        openAPIV3Schema:
-          type: object
-          description: 'EventType represents a type of event that can be consumed from a Broker.'
-          properties:
-            spec:
-              description: 'Spec defines the desired state of the EventType.'
-              type: object
-              properties:
-                broker:
-                  type: string
-                reference:
-                  description: Reference Broker. For example
-                  type: object
-                  properties:
-                    apiVersion:
-                      description: API version of the referent.
-                      type: string
-                    kind:
-                      description: 'Kind of the referent. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
-                      type: string
-                    name:
-                      description: 'Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names'
-                      type: string
-                    namespace:
-                      description: 'Namespace of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/namespaces/ This is optional field, it gets defaulted to the object holding it if left out.'
-                      type: string
-                description:
-                  description: 'Description is an optional field used to describe the EventType, in any meaningful way.'
-                  type: string
-                schema:
-                  description: 'Schema is a URI, it represents the CloudEvents schemaurl extension attribute. It may be a JSON schema, a protobuf schema, etc. It is optional.'
-                  type: string
-                schemaData:
-                  description: 'SchemaData allows the CloudEvents schema to be stored directly in the EventType. Content is dependent on the encoding. Optional attribute. The contents are not validated or manipulated by the system.'
-                  type: string
-                source:
-                  description: 'Source is a URI, it represents the CloudEvents source.'
-                  type: string
-                type:
-                  description: 'Type represents the CloudEvents type. It is authoritative.'
-                  type: string
-            status:
-              description: 'Status represents the current state of the EventType. This data may be out of date.'
-              type: object
-              properties:
-                annotations:
-                  description: 'Annotations is additional Status fields for the Resource to save some additional State as well as convey more information to the user. This is roughly akin to Annotations on any k8s resource, just the reconciler conveying richer information outwards.'
-                  type: object
-                  x-kubernetes-preserve-unknown-fields: true
-                conditions:
-                  description: 'Conditions the latest available observations of a resource''s current state.'
-                  type: array
-                  items:
-                    type: object
-                    required:
-                      - type
-                      - status
-                    properties:
-                      lastTransitionTime:
-                        description: 'LastTransitionTime is the last time the condition transitioned from one status to another. We use VolatileTime in place of metav1.Time to exclude this from creating equality.Semantic differences (all other things held constant).'
-                        type: string
-                      message:
-                        description: 'A human readable message indicating details about the transition.'
-                        type: string
-                      reason:
-                        description: 'The reason for the condition''s last transition.'
-                        type: string
-                      severity:
-                        description: 'Severity with which to treat failures of this type of condition. When this is not specified, it defaults to Error.'
-                        type: string
-                      status:
-                        description: 'Status of the condition, one of True, False, Unknown.'
-                        type: string
-                      type:
-                        description: 'Type of condition.'
-                        type: string
-                observedGeneration:
-                  description: 'ObservedGeneration is the ''Generation'' of the Service that was last processed by the controller.'
-                  type: integer
-                  format: int64
+      # v1beta1 schema is identical to the v1beta2 schema
   names:
     kind: EventType
     plural: eventtypes
@@ -2327,7 +2263,7 @@ metadata:
   labels:
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -2585,7 +2521,7 @@ metadata:
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -2780,7 +2716,7 @@ metadata:
   labels:
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -3107,7 +3043,7 @@ metadata:
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   name: sinkbindings.sources.knative.dev
 spec:
@@ -3301,7 +3237,7 @@ metadata:
   name: subscriptions.messaging.knative.dev
   labels:
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -3527,7 +3463,7 @@ metadata:
   name: triggers.eventing.knative.dev
   labels:
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -3723,7 +3659,7 @@ kind: ClusterRole
 metadata:
   name: addressable-resolver
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -3737,7 +3673,7 @@ metadata:
   name: service-addressable-resolver
   labels:
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3756,7 +3692,7 @@ metadata:
   name: serving-addressable-resolver
   labels:
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3778,7 +3714,7 @@ metadata:
   name: channel-addressable-resolver
   labels:
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3804,7 +3740,7 @@ metadata:
   name: broker-addressable-resolver
   labels:
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3824,7 +3760,7 @@ metadata:
   name: flows-addressable-resolver
   labels:
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3860,7 +3796,7 @@ kind: ClusterRole
 metadata:
   name: eventing-broker-filter
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3886,7 +3822,7 @@ kind: ClusterRole
 metadata:
   name: eventing-broker-ingress
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3903,7 +3839,7 @@ kind: ClusterRole
 metadata:
   name: eventing-config-reader
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3936,7 +3872,7 @@ kind: ClusterRole
 metadata:
   name: channelable-manipulator
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -3950,7 +3886,7 @@ metadata:
   name: meta-channelable-manipulator
   labels:
     duck.knative.dev/channelable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "channelable-manipulator" role.
 rules:
@@ -3989,7 +3925,7 @@ metadata:
   name: knative-eventing-namespaced-admin
   labels:
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev"]
@@ -4002,7 +3938,7 @@ metadata:
   name: knative-messaging-namespaced-admin
   labels:
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["messaging.knative.dev"]
@@ -4015,7 +3951,7 @@ metadata:
   name: knative-flows-namespaced-admin
   labels:
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["flows.knative.dev"]
@@ -4028,7 +3964,7 @@ metadata:
   name: knative-sources-namespaced-admin
   labels:
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["sources.knative.dev"]
@@ -4041,7 +3977,7 @@ metadata:
   name: knative-bindings-namespaced-admin
   labels:
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["bindings.knative.dev"]
@@ -4054,7 +3990,7 @@ metadata:
   name: knative-eventing-namespaced-edit
   labels:
     rbac.authorization.k8s.io/aggregate-to-view: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev", "messaging.knative.dev", "sources.knative.dev", "flows.knative.dev", "bindings.knative.dev"]
@@ -4067,7 +4003,7 @@ metadata:
   name: knative-eventing-namespaced-view
   labels:
     rbac.authorization.k8s.io/aggregate-to-view: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev", "messaging.knative.dev", "sources.knative.dev", "flows.knative.dev", "bindings.knative.dev"]
@@ -4094,7 +4030,7 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-controller
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4229,7 +4165,7 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-pingsource-mt-adapter
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4296,7 +4232,7 @@ kind: ClusterRole
 metadata:
   name: podspecable-binding
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -4310,7 +4246,7 @@ metadata:
   name: builtin-podspecable-binding
   labels:
     duck.knative.dev/podspecable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "podspecable-binding role.
 rules:
@@ -4356,7 +4292,7 @@ kind: ClusterRole
 metadata:
   name: source-observer
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -4370,7 +4306,7 @@ metadata:
   name: eventing-sources-source-observer
   labels:
     duck.knative.dev/source: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "source-observer" role.
 rules:
@@ -4406,7 +4342,7 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-sources-controller
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4492,7 +4428,7 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-webhook
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   # For watching logging configuration and getting certs.
@@ -4602,7 +4538,7 @@ metadata:
   namespace: knative-eventing
   name: knative-eventing-webhook
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 rules:
   # For manipulating certs into secrets.
@@ -4638,7 +4574,7 @@ kind: ValidatingWebhookConfiguration
 metadata:
   name: config.webhook.eventing.knative.dev
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4673,7 +4609,7 @@ kind: MutatingWebhookConfiguration
 metadata:
   name: webhook.eventing.knative.dev
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4706,7 +4642,7 @@ kind: ValidatingWebhookConfiguration
 metadata:
   name: validation.webhook.eventing.knative.dev
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4740,7 +4676,7 @@ metadata:
   name: eventing-webhook-certs
   namespace: knative-eventing
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 # The data is populated at install time.
 
@@ -4764,7 +4700,7 @@ kind: MutatingWebhookConfiguration
 metadata:
   name: sinkbindings.webhook.sources.knative.dev
   labels:
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     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 02b93ffaa..79015b597 100644
--- a/third_party/eventing-latest/eventing-crds.yaml
+++ b/third_party/eventing-latest/eventing-crds.yaml
@@ -20,7 +20,7 @@ metadata:
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -270,7 +270,7 @@ metadata:
   labels:
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -447,7 +447,7 @@ metadata:
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -733,7 +733,7 @@ metadata:
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   name: containersources.sources.knative.dev
 spec:
@@ -890,7 +890,7 @@ metadata:
   name: eventtypes.eventing.knative.dev
   labels:
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -912,6 +912,22 @@ spec:
               properties:
                 broker:
                   type: string
+                reference:
+                  description: Reference Broker. For example
+                  type: object
+                  properties:
+                    apiVersion:
+                      description: API version of the referent.
+                      type: string
+                    kind:
+                      description: 'Kind of the referent. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
+                      type: string
+                    name:
+                      description: 'Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names'
+                      type: string
+                    namespace:
+                      description: 'Namespace of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/namespaces/ This is an optional field, it gets defaulted to the object holding it if left out.'
+                      type: string
                 description:
                   description: 'Description is an optional field used to describe the EventType, in any meaningful way.'
                   type: string
@@ -995,87 +1011,7 @@ spec:
       name: v1beta2
       served: true
       storage: false
-      schema:
-        openAPIV3Schema:
-          type: object
-          description: 'EventType represents a type of event that can be consumed from a Broker.'
-          properties:
-            spec:
-              description: 'Spec defines the desired state of the EventType.'
-              type: object
-              properties:
-                broker:
-                  type: string
-                reference:
-                  description: Reference Broker. For example
-                  type: object
-                  properties:
-                    apiVersion:
-                      description: API version of the referent.
-                      type: string
-                    kind:
-                      description: 'Kind of the referent. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
-                      type: string
-                    name:
-                      description: 'Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names'
-                      type: string
-                    namespace:
-                      description: 'Namespace of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/namespaces/ This is optional field, it gets defaulted to the object holding it if left out.'
-                      type: string
-                description:
-                  description: 'Description is an optional field used to describe the EventType, in any meaningful way.'
-                  type: string
-                schema:
-                  description: 'Schema is a URI, it represents the CloudEvents schemaurl extension attribute. It may be a JSON schema, a protobuf schema, etc. It is optional.'
-                  type: string
-                schemaData:
-                  description: 'SchemaData allows the CloudEvents schema to be stored directly in the EventType. Content is dependent on the encoding. Optional attribute. The contents are not validated or manipulated by the system.'
-                  type: string
-                source:
-                  description: 'Source is a URI, it represents the CloudEvents source.'
-                  type: string
-                type:
-                  description: 'Type represents the CloudEvents type. It is authoritative.'
-                  type: string
-            status:
-              description: 'Status represents the current state of the EventType. This data may be out of date.'
-              type: object
-              properties:
-                annotations:
-                  description: 'Annotations is additional Status fields for the Resource to save some additional State as well as convey more information to the user. This is roughly akin to Annotations on any k8s resource, just the reconciler conveying richer information outwards.'
-                  type: object
-                  x-kubernetes-preserve-unknown-fields: true
-                conditions:
-                  description: 'Conditions the latest available observations of a resource''s current state.'
-                  type: array
-                  items:
-                    type: object
-                    required:
-                      - type
-                      - status
-                    properties:
-                      lastTransitionTime:
-                        description: 'LastTransitionTime is the last time the condition transitioned from one status to another. We use VolatileTime in place of metav1.Time to exclude this from creating equality.Semantic differences (all other things held constant).'
-                        type: string
-                      message:
-                        description: 'A human readable message indicating details about the transition.'
-                        type: string
-                      reason:
-                        description: 'The reason for the condition''s last transition.'
-                        type: string
-                      severity:
-                        description: 'Severity with which to treat failures of this type of condition. When this is not specified, it defaults to Error.'
-                        type: string
-                      status:
-                        description: 'Status of the condition, one of True, False, Unknown.'
-                        type: string
-                      type:
-                        description: 'Type of condition.'
-                        type: string
-                observedGeneration:
-                  description: 'ObservedGeneration is the ''Generation'' of the Service that was last processed by the controller.'
-                  type: integer
-                  format: int64
+      # v1beta1 schema is identical to the v1beta2 schema
   names:
     kind: EventType
     plural: eventtypes
@@ -1115,7 +1051,7 @@ metadata:
   labels:
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -1373,7 +1309,7 @@ metadata:
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -1568,7 +1504,7 @@ metadata:
   labels:
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -1895,7 +1831,7 @@ metadata:
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
   name: sinkbindings.sources.knative.dev
 spec:
@@ -2089,7 +2025,7 @@ metadata:
   name: subscriptions.messaging.knative.dev
   labels:
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -2315,7 +2251,7 @@ metadata:
   name: triggers.eventing.knative.dev
   labels:
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20230614-49d4acd9a"
+    app.kubernetes.io/version: "20230625-95cdbaa7a"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/eventtype.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/eventtype.go
index 7eaedc05a..871b90cb3 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/eventtype.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/eventtype.go
@@ -93,12 +93,12 @@ func WithEventTypeDeletionTimestamp(et *v1beta2.EventType) {
 	et.ObjectMeta.SetDeletionTimestamp(&t)
 }
 
-// WithEventTypeBrokerNotFound calls .Status.MarkFilterFailed on the EventType.
-func WithEventTypeBrokerDoesNotExist(et *v1beta2.EventType) {
-	et.Status.MarkBrokerDoesNotExist()
+// WithEventTypeResourceDoesNotExist calls .Status.MarkFilterFailed on the EventType.
+func WithEventTypeResourceDoesNotExist(et *v1beta2.EventType) {
+	et.Status.MarkReferenceDoesNotExist()
 }
 
-// WithEventTypeBrokerExists calls .Status.MarkBrokerExists on the EventType.
-func WithEventTypeBrokerExists(et *v1beta2.EventType) {
-	et.Status.MarkBrokerExists()
+// WithEventTypeResourceExists calls .Status.MarkReferenceExists on the EventType.
+func WithEventTypeResourceExists(et *v1beta2.EventType) {
+	et.Status.MarkReferenceExists()
 }
diff --git a/vendor/knative.dev/eventing/test/rekt/features/featureflags/featureflags.go b/vendor/knative.dev/eventing/test/rekt/features/featureflags/featureflags.go
new file mode 100644
index 000000000..0ba4a2c7c
--- /dev/null
+++ b/vendor/knative.dev/eventing/test/rekt/features/featureflags/featureflags.go
@@ -0,0 +1,74 @@
+/*
+Copyright 2023 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 featureflags
+
+import (
+	"context"
+	"fmt"
+
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	kubeclient "knative.dev/pkg/client/injection/kube/client"
+	"knative.dev/pkg/system"
+	"knative.dev/reconciler-test/pkg/feature"
+
+	apifeature "knative.dev/eventing/pkg/apis/feature"
+)
+
+const (
+	istioFeatureFlagName = "istio"
+)
+
+func TransportEncryptionPermissiveOrStrict() feature.ShouldRun {
+	return func(ctx context.Context, t feature.T) (feature.PrerequisiteResult, error) {
+		flags, err := getFeatureFlags(ctx, "config-features")
+		if err != nil {
+			return feature.PrerequisiteResult{}, err
+		}
+
+		return feature.PrerequisiteResult{
+			ShouldRun: flags.IsPermissiveTransportEncryption() || flags.IsStrictTransportEncryption(),
+			Reason:    flags.String(),
+		}, nil
+	}
+}
+
+func IstioDisabled() feature.ShouldRun {
+	return func(ctx context.Context, t feature.T) (feature.PrerequisiteResult, error) {
+		flags, err := getFeatureFlags(ctx, "config-features")
+		if err != nil {
+			return feature.PrerequisiteResult{}, err
+		}
+
+		return feature.PrerequisiteResult{
+			ShouldRun: !flags.IsEnabled(istioFeatureFlagName),
+			Reason:    flags.String(),
+		}, nil
+	}
+}
+
+func getFeatureFlags(ctx context.Context, cmName string) (apifeature.Flags, error) {
+	ns := system.Namespace()
+	cm, err := kubeclient.Get(ctx).
+		CoreV1().
+		ConfigMaps(ns).
+		Get(ctx, cmName, metav1.GetOptions{})
+	if err != nil {
+		return nil, fmt.Errorf("failed to get cm %s/%s: %s", ns, cmName, err)
+	}
+
+	return apifeature.NewFlagsConfigFromConfigMap(cm)
+}
diff --git a/vendor/knative.dev/eventing/test/rekt/features/trigger/feature.go b/vendor/knative.dev/eventing/test/rekt/features/trigger/feature.go
index ca4c67343..2ed3e2f76 100644
--- a/vendor/knative.dev/eventing/test/rekt/features/trigger/feature.go
+++ b/vendor/knative.dev/eventing/test/rekt/features/trigger/feature.go
@@ -28,6 +28,7 @@ import (
 
 	"knative.dev/reconciler-test/pkg/eventshub/assert"
 
+	"knative.dev/eventing/test/rekt/features/featureflags"
 	"knative.dev/eventing/test/rekt/resources/broker"
 	"knative.dev/eventing/test/rekt/resources/pingsource"
 	"knative.dev/eventing/test/rekt/resources/trigger"
@@ -90,6 +91,8 @@ func TriggerDependencyAnnotation() *feature.Feature {
 func TriggerWithTLSSubscriber() *feature.Feature {
 	f := feature.NewFeatureNamed("Trigger with TLS subscriber")
 
+	f.Prerequisite("should not run when Istio is enabled", featureflags.IstioDisabled())
+
 	brokerName := feature.MakeRandomK8sName("broker")
 	sourceName := feature.MakeRandomK8sName("source")
 	sinkName := feature.MakeRandomK8sName("sink")