Repository: knative-sandbox/eventing-kafka-broker
Pull request #2703 (2022-10-05 18:18:32)

Adding consumergroup and consumer to defaulting webhook plus validation logic updates
Signed-off-by: aavarghese <avarghese@us.ibm.com>

As per title

/cc @pierDipi 

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/2703#" title="Author self-approved">aavarghese</a>*
**Once this PR has been reviewed and has the lgtm label**, please assign matzew for approval by writing `/assign @matzew` in a comment. 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":["matzew"]} -->
codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/2703?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) Report
> Merging [#2703](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/2703?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (8b41d8a) into [main](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/commit/d0d8aeb62f813ba69018656d2ab92475ac864cb8?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (d0d8aeb) will **increase** coverage by `0.10%`.
> The diff coverage is `100.00%`.

```diff
@@            Coverage Diff             @@
##             main    #2703      +/-   ##
==========================================
+ Coverage   55.98%   56.08%   +0.10%     
==========================================
  Files          75       75              
  Lines        7888     7893       +5     
==========================================
+ Hits         4416     4427      +11     
+ Misses       3154     3148       -6     
  Partials      318      318              
```


| [Impacted Files](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/2703?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) | Coverage Δ | |
|---|---|---|
| [...fka/eventing/v1alpha1/consumer\_group\_validation.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/2703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvYXBpcy9pbnRlcm5hbHMva2Fma2EvZXZlbnRpbmcvdjFhbHBoYTEvY29uc3VtZXJfZ3JvdXBfdmFsaWRhdGlvbi5nbw==) | `100.00% <100.00%> (ø)` | |
| [...als/kafka/eventing/v1alpha1/consumer\_validation.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/2703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvYXBpcy9pbnRlcm5hbHMva2Fma2EvZXZlbnRpbmcvdjFhbHBoYTEvY29uc3VtZXJfdmFsaWRhdGlvbi5nbw==) | `83.33% <0.00%> (+6.25%)` | :arrow_up: |

Help us with your feedback. Take ten seconds to tell us [how you rate us](https://about.codecov.io/nps?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Have a feature suggestion? [Share it here.](https://app.codecov.io/gh/feedback/?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)

knative-prow[bot]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | true | `/test channel-integration-tests-sasl-plain`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577724942483460096) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | true | `/test channel-integration-tests-sasl-plain`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577724942483460096) | true | `/test reconciler-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577724942839975936) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | true | `/test channel-integration-tests-sasl-plain`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577724942483460096) | true | `/test reconciler-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577724942839975936) | true | `/test channel-reconciler-tests-ssl`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577724944488337408) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577724942080806912) | true | `/test unit-tests`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | true | `/test channel-integration-tests-sasl-plain`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577724942483460096) | true | `/test reconciler-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577724942839975936) | true | `/test channel-reconciler-tests-ssl`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577724944488337408) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577724943641088000) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | true | `/test channel-integration-tests-sasl-plain`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577724942483460096) | true | `/test reconciler-tests`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577724942839975936) | true | `/test channel-reconciler-tests-ssl`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577724944488337408) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577724943641088000) | true | `/test channel-reconciler-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577724942693175296) | true | `/test channel-integration-tests-sasl-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577724942839975936) | true | `/test channel-reconciler-tests-ssl`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577724944488337408) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577724943641088000) | true | `/test channel-reconciler-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577724942764478464) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577724942839975936) | true | `/test channel-reconciler-tests-ssl`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577724944488337408) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577724943641088000) | true | `/test channel-reconciler-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577724942550568960) | true | `/test reconciler-tests-namespaced-broker`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577724944488337408) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577724943641088000) | true | `/test channel-reconciler-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577724944488337408) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577724943641088000) | true | `/test channel-reconciler-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | true | `/test channel-reconciler-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577724943641088000) | true | `/test channel-reconciler-tests-sasl-ssl`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | true | `/test channel-reconciler-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | true | `/test reconciler-tests-namespaced-broker`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577740805685121024) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577724942626066432) | true | `/test channel-integration-tests-ssl`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | true | `/test channel-reconciler-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | true | `/test reconciler-tests-namespaced-broker`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577740805685121024) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577740805592846336) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577724942277939200) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | true | `/test channel-reconciler-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | true | `/test reconciler-tests-namespaced-broker`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577740805685121024) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577740805592846336) | true | `/test channel-reconciler-tests-sasl-ssl`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577740805236330496) | 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]: @aavarghese: 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
--- | --- | --- | --- | ---
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577724942349242368) | true | `/test integration-tests-namespaced-broker`
unit-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | true | `/test channel-reconciler-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | true | `/test reconciler-tests-namespaced-broker`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577740805685121024) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577740805592846336) | true | `/test channel-reconciler-tests-sasl-ssl`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577740805236330496) | true | `/test channel-integration-tests-ssl`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577740804896591872) | 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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577740804800122880) | true | `/test unit-tests`
reconciler-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | true | `/test channel-reconciler-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | true | `/test reconciler-tests-namespaced-broker`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577740805685121024) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577740805592846336) | true | `/test channel-reconciler-tests-sasl-ssl`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577740805236330496) | true | `/test channel-integration-tests-ssl`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577740804896591872) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577740804980477952) | true | `/test integration-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]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
channel-reconciler-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-ssl_eventing-kafka-broker_main/1577740805534126080) | true | `/test channel-reconciler-tests-ssl`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | true | `/test reconciler-tests-namespaced-broker`
channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-plain_eventing-kafka-broker_main/1577740805685121024) | true | `/test channel-reconciler-tests-sasl-plain`
channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-reconciler-tests-sasl-ssl_eventing-kafka-broker_main/1577740805592846336) | true | `/test channel-reconciler-tests-sasl-ssl`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577740805236330496) | true | `/test channel-integration-tests-ssl`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577740804896591872) | true | `/test integration-tests`
integration-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests-namespaced-broker_eventing-kafka-broker_main/1577740804980477952) | true | `/test integration-tests-namespaced-broker`
unit-tests_eventing-kafka-broker_main | e3a607c3847f5d62534127340ab0da5ccf5fde44 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577750586034491392) | 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 -->
aavarghese: /test unit-tests
knative-prow[bot]: @aavarghese: 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 | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests_eventing-kafka-broker_main/1577740805076946944) | true | `/test reconciler-tests`
channel-integration-tests-sasl-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-ssl_eventing-kafka-broker_main/1577740805324410880) | true | `/test channel-integration-tests-sasl-ssl`
channel-integration-tests-sasl-plain_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-sasl-plain_eventing-kafka-broker_main/1577740805408296960) | true | `/test channel-integration-tests-sasl-plain`
reconciler-tests-namespaced-broker_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/reconciler-tests-namespaced-broker_eventing-kafka-broker_main/1577740805148250112) | true | `/test reconciler-tests-namespaced-broker`
channel-integration-tests-ssl_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/channel-integration-tests-ssl_eventing-kafka-broker_main/1577740805236330496) | true | `/test channel-integration-tests-ssl`
integration-tests_eventing-kafka-broker_main | 8b41d8aac3699f103510db1385a2c4c26ad5d9ff | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/integration-tests_eventing-kafka-broker_main/1577740804896591872) | true | `/test integration-tests`
unit-tests_eventing-kafka-broker_main | e3a607c3847f5d62534127340ab0da5ccf5fde44 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577758269395439616) | 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 -->
aavarghese: /test unit-tests
knative-prow[bot]: @aavarghese: 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 | e3a607c3847f5d62534127340ab0da5ccf5fde44 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577771601812787200) | 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 -->
aavarghese: /test unit-tests
knative-prow[bot]: @aavarghese: 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 | e3a607c3847f5d62534127340ab0da5ccf5fde44 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577774330593415168) | 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]: @aavarghese: 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 | e3a607c3847f5d62534127340ab0da5ccf5fde44 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/2703/unit-tests_eventing-kafka-broker_main/1577881106080862208) | 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]: [APPROVALNOTIFIER] This PR is **APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/2703#" title="Author self-approved">aavarghese</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/2703#pullrequestreview-1133359592" 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":[]} -->

Patch:
diff --git a/control-plane/cmd/webhook-kafka/main.go b/control-plane/cmd/webhook-kafka/main.go
index fe73316c1..4c2931a24 100644
--- a/control-plane/cmd/webhook-kafka/main.go
+++ b/control-plane/cmd/webhook-kafka/main.go
@@ -24,6 +24,7 @@ import (
 	"knative.dev/pkg/configmap"
 	"knative.dev/pkg/controller"
 	"knative.dev/pkg/injection/sharedmain"
+	"knative.dev/pkg/logging"
 	"knative.dev/pkg/signals"
 	"knative.dev/pkg/webhook"
 	"knative.dev/pkg/webhook/certificates"
@@ -33,12 +34,14 @@ import (
 
 	sourcesv1beta1 "knative.dev/eventing-kafka/pkg/apis/sources/v1beta1"
 	eventingcorev1 "knative.dev/eventing/pkg/apis/eventing/v1"
+	"knative.dev/eventing/pkg/apis/feature"
 
 	messagingv1beta1 "knative.dev/eventing-kafka/pkg/apis/messaging/v1beta1"
 
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/apis/core"
 	eventingv1 "knative.dev/eventing-kafka-broker/control-plane/pkg/apis/eventing/v1"
 	eventingv1alpha1 "knative.dev/eventing-kafka-broker/control-plane/pkg/apis/eventing/v1alpha1"
+	kafkainternals "knative.dev/eventing-kafka-broker/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1"
 )
 
 const (
@@ -50,6 +53,8 @@ var types = map[schema.GroupVersionKind]resourcesemantics.GenericCRD{
 	sourcesv1beta1.SchemeGroupVersion.WithKind("KafkaSource"):    &sourcesv1beta1.KafkaSource{},
 	messagingv1beta1.SchemeGroupVersion.WithKind("KafkaChannel"): &messagingv1beta1.KafkaChannel{},
 	eventingcorev1.SchemeGroupVersion.WithKind("Broker"):         &eventingv1.BrokerStub{},
+	kafkainternals.SchemeGroupVersion.WithKind("ConsumerGroup"):  &kafkainternals.ConsumerGroup{},
+	kafkainternals.SchemeGroupVersion.WithKind("Consumer"):       &kafkainternals.Consumer{},
 }
 
 var defaultingCallbacks = map[schema.GroupVersionKind]defaulting.Callback{
@@ -110,7 +115,15 @@ func NewPodDefaultingAdmissionController(ctx context.Context, _ configmap.Watche
 	)
 }
 
-func NewValidationAdmissionController(ctx context.Context, _ configmap.Watcher) *controller.Impl {
+func NewValidationAdmissionController(ctx context.Context, cmw configmap.Watcher) *controller.Impl {
+	featureStore := feature.NewStore(logging.FromContext(ctx).Named("feature-config-store"))
+	featureStore.WatchConfigs(cmw)
+
+	// Decorate contexts with the current state of the config.
+	ctxFunc := func(ctx context.Context) context.Context {
+		return featureStore.ToContext(ctx)
+	}
+
 	return validation.NewAdmissionController(ctx,
 		// Name of the resource webhook.
 		"validation.webhook.kafka.eventing.knative.dev",
@@ -122,9 +135,7 @@ func NewValidationAdmissionController(ctx context.Context, _ configmap.Watcher)
 		types,
 
 		// A function that infuses the context passed to Validate/SetDefaults with custom metadata.
-		func(ctx context.Context) context.Context {
-			return ctx
-		},
+		ctxFunc,
 
 		// Whether to disallow unknown fields.
 		true,
diff --git a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation.go b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation.go
index c95b782b5..68fedcbb4 100644
--- a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation.go
+++ b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation.go
@@ -49,10 +49,15 @@ func (cgs *ConsumerGroupSpec) Validate(ctx context.Context) *apis.FieldError {
 
 func (cts *ConsumerTemplateSpec) Validate(ctx context.Context) *apis.FieldError {
 	specCtx := ctx
+	var err *apis.FieldError
 	if apis.IsInUpdate(ctx) {
 		specCtx = apis.WithinUpdate(ctx, apis.GetBaseline(ctx).(*ConsumerGroup).Spec.Template.Spec)
 	}
-	return cts.Spec.Validate(specCtx).ViaField("spec")
+	err = err.Also( // fields with defaults
+		cts.Spec.Delivery.Validate(specCtx).ViaField("delivery"),
+		cts.Spec.Subscriber.Validate(specCtx).ViaField("subscriber"),
+	)
+	return err
 }
 
 func (c *ConsumerGroup) CheckImmutableFields(ctx context.Context, original map[string]string) *apis.FieldError {


Test patch:
diff --git a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go
index 42a62f714..04418ff67 100644
--- a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go
+++ b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_group_validation_test.go
@@ -22,12 +22,20 @@ import (
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/utils/pointer"
+	internals "knative.dev/eventing-kafka-broker/control-plane/pkg/apis/internals/kafka/eventing"
 	eventingduck "knative.dev/eventing/pkg/apis/duck/v1"
+	"knative.dev/eventing/pkg/apis/feature"
 	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 )
 
+const (
+	DefaultDeliveryOrder = internals.Ordered
+)
+
 func TestConsumerGroup_Validate(t *testing.T) {
+	backoffPolicy := eventingduck.BackoffPolicyExponential
+
 	tests := []struct {
 		name    string
 		ctx     context.Context
@@ -51,19 +59,18 @@ func TestConsumerGroup_Validate(t *testing.T) {
 			wantErr: true,
 		},
 		{
-			name: "no topics",
+			name: "no consumer template",
 			ctx:  context.Background(),
 			given: &ConsumerGroup{
 				Spec: ConsumerGroupSpec{
 					Replicas: pointer.Int32Ptr(1),
 					Selector: map[string]string{"app": "app"},
-					Template: ConsumerTemplateSpec{},
 				},
 			},
 			wantErr: true,
 		},
 		{
-			name: "missing group.id",
+			name: "no subscriber",
 			ctx:  context.Background(),
 			given: &ConsumerGroup{
 				Spec: ConsumerGroupSpec{
@@ -71,12 +78,14 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Subscriber: duckv1.Destination{
-								URI: &apis.URL{
-									Scheme: "http",
-									Host:   "127.0.0.1",
+							Delivery: &DeliverySpec{
+								DeliverySpec: &eventingduck.DeliverySpec{
+									Retry:         pointer.Int32(10),
+									BackoffPolicy: &backoffPolicy,
+									BackoffDelay:  pointer.String("PT0.3S"),
+									Timeout:       pointer.String("PT600S"),
 								},
+								Ordering: DefaultDeliveryOrder,
 							},
 						},
 					},
@@ -85,7 +94,7 @@ func TestConsumerGroup_Validate(t *testing.T) {
 			wantErr: true,
 		},
 		{
-			name: "valid",
+			name: "no delivery",
 			ctx:  context.Background(),
 			given: &ConsumerGroup{
 				Spec: ConsumerGroupSpec{
@@ -93,26 +102,12 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
-							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
-							},
 							Subscriber: duckv1.Destination{
 								URI: &apis.URL{
 									Scheme: "http",
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -120,7 +115,7 @@ func TestConsumerGroup_Validate(t *testing.T) {
 			wantErr: false,
 		},
 		{
-			name: "invalid multiple reply strategies (topic, destination)",
+			name: "invalid delivery - timeout feature disabled",
 			ctx:  context.Background(),
 			given: &ConsumerGroup{
 				Spec: ConsumerGroupSpec{
@@ -128,54 +123,12 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
-							Reply: &ReplyStrategy{
-								TopicReply: &TopicReply{Enabled: true},
-								URLReply:   &DestinationReply{Enabled: true},
-							},
 							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
-							},
-							Subscriber: duckv1.Destination{
-								URI: &apis.URL{
-									Scheme: "http",
-									Host:   "127.0.0.1",
+								DeliverySpec: &eventingduck.DeliverySpec{
+									Retry:   pointer.Int32(-10),
+									Timeout: pointer.String("PT600S"),
 								},
-							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
-						},
-					},
-				},
-			},
-			wantErr: true,
-		},
-		{
-			name: "invalid no pod name",
-			ctx:  context.Background(),
-			given: &ConsumerGroup{
-				Spec: ConsumerGroupSpec{
-					Replicas: pointer.Int32Ptr(1),
-					Selector: map[string]string{"app": "app"},
-					Template: ConsumerTemplateSpec{
-						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
-							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
+								Ordering: DefaultDeliveryOrder,
 							},
 							Subscriber: duckv1.Destination{
 								URI: &apis.URL{
@@ -183,9 +136,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -193,86 +143,19 @@ func TestConsumerGroup_Validate(t *testing.T) {
 			wantErr: true,
 		},
 		{
-			name: "invalid no pod namespace",
-			ctx:  context.Background(),
+			name: "valid delivery - timeout feature enabled",
+			ctx:  feature.ToContext(context.Background(), feature.Flags{feature.DeliveryTimeout: feature.Enabled}),
 			given: &ConsumerGroup{
 				Spec: ConsumerGroupSpec{
 					Replicas: pointer.Int32Ptr(1),
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
-							},
-							Subscriber: duckv1.Destination{
-								URI: &apis.URL{
-									Scheme: "http",
-									Host:   "127.0.0.1",
-								},
-							},
-							PodBind: &PodBind{
-								PodName: "p-0",
-							},
-						},
-					},
-				},
-			},
-			wantErr: true,
-		},
-		{
-			name: "valid - no updates",
-			ctx: apis.WithinUpdate(context.Background(), &ConsumerGroup{
-				Spec: ConsumerGroupSpec{
-					Replicas: pointer.Int32Ptr(1),
-					Selector: map[string]string{"app": "app"},
-					Template: ConsumerTemplateSpec{
-						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
+								DeliverySpec: &eventingduck.DeliverySpec{
+									Timeout: pointer.String("PT600S"),
 								},
-							},
-							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
-							},
-							Subscriber: duckv1.Destination{
-								URI: &apis.URL{
-									Scheme: "http",
-									Host:   "127.0.0.1",
-								},
-							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
-						},
-					},
-				},
-			}),
-			given: &ConsumerGroup{
-				Spec: ConsumerGroupSpec{
-					Replicas: pointer.Int32Ptr(1),
-					Selector: map[string]string{"app": "app"},
-					Template: ConsumerTemplateSpec{
-						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
-							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
+								Ordering: DefaultDeliveryOrder,
 							},
 							Subscriber: duckv1.Destination{
 								URI: &apis.URL{
@@ -280,10 +163,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -291,114 +170,14 @@ func TestConsumerGroup_Validate(t *testing.T) {
 			wantErr: false,
 		},
 		{
-			name: "invalid pod name update",
-			ctx: apis.WithinUpdate(context.Background(), &ConsumerGroup{
-				Spec: ConsumerGroupSpec{
-					Replicas: pointer.Int32Ptr(1),
-					Selector: map[string]string{"app": "app"},
-					Template: ConsumerTemplateSpec{
-						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
-							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
-							},
-							Subscriber: duckv1.Destination{
-								URI: &apis.URL{
-									Scheme: "http",
-									Host:   "127.0.0.1",
-								},
-							},
-							PodBind: &PodBind{
-								PodName:      "p-1",
-								PodNamespace: "ns",
-							},
-						},
-					},
-				},
-			}),
-			given: &ConsumerGroup{
-				Spec: ConsumerGroupSpec{
-					Replicas: pointer.Int32Ptr(1),
-					Selector: map[string]string{"app": "app"},
-					Template: ConsumerTemplateSpec{
-						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
-							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
-							},
-							Subscriber: duckv1.Destination{
-								URI: &apis.URL{
-									Scheme: "http",
-									Host:   "127.0.0.1",
-								},
-							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
-						},
-					},
-				},
-			},
-			wantErr: true,
-		},
-		{
-			name: "invalid pod name update",
-			ctx: apis.WithinUpdate(context.Background(), &ConsumerGroup{
-				Spec: ConsumerGroupSpec{
-					Replicas: pointer.Int32Ptr(1),
-					Selector: map[string]string{"app": "app"},
-					Template: ConsumerTemplateSpec{
-						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
-							Delivery: &DeliverySpec{
-								DeliverySpec: &eventingduck.DeliverySpec{},
-							},
-							Subscriber: duckv1.Destination{
-								URI: &apis.URL{
-									Scheme: "http",
-									Host:   "127.0.0.1",
-								},
-							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns-1",
-							},
-						},
-					},
-				},
-			}),
+			name: "valid",
+			ctx:  context.Background(),
 			given: &ConsumerGroup{
 				Spec: ConsumerGroupSpec{
 					Replicas: pointer.Int32Ptr(1),
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
 								DeliverySpec: &eventingduck.DeliverySpec{},
 							},
@@ -408,15 +187,11 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns-2",
-							},
 						},
 					},
 				},
 			},
-			wantErr: true,
+			wantErr: false,
 		},
 		{
 			name: "valid with channel label",
@@ -431,13 +206,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
 								DeliverySpec: &eventingduck.DeliverySpec{},
 							},
@@ -447,10 +215,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -466,13 +230,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
 								DeliverySpec: &eventingduck.DeliverySpec{},
 							},
@@ -482,10 +239,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -505,13 +258,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
 								DeliverySpec: &eventingduck.DeliverySpec{},
 							},
@@ -521,10 +267,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -535,13 +277,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
 								DeliverySpec: &eventingduck.DeliverySpec{},
 							},
@@ -551,10 +286,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -574,13 +305,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
 								DeliverySpec: &eventingduck.DeliverySpec{},
 							},
@@ -590,10 +314,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
@@ -609,13 +329,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 					Selector: map[string]string{"app": "app"},
 					Template: ConsumerTemplateSpec{
 						Spec: ConsumerSpec{
-							Topics: []string{"t1"},
-							Configs: ConsumerConfigs{
-								Configs: map[string]string{
-									"group.id":          "g1",
-									"bootstrap.servers": "kafka:9092",
-								},
-							},
 							Delivery: &DeliverySpec{
 								DeliverySpec: &eventingduck.DeliverySpec{},
 							},
@@ -625,10 +338,6 @@ func TestConsumerGroup_Validate(t *testing.T) {
 									Host:   "127.0.0.1",
 								},
 							},
-							PodBind: &PodBind{
-								PodName:      "p-0",
-								PodNamespace: "ns",
-							},
 						},
 					},
 				},
diff --git a/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_validation_test.go b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_validation_test.go
new file mode 100644
index 000000000..87f10a9b0
--- /dev/null
+++ b/control-plane/pkg/apis/internals/kafka/eventing/v1alpha1/consumer_validation_test.go
@@ -0,0 +1,342 @@
+/*
+ * Copyright 2021 The Knative Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     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 v1alpha1
+
+import (
+	"context"
+	"testing"
+
+	eventingduck "knative.dev/eventing/pkg/apis/duck/v1"
+	"knative.dev/pkg/apis"
+	duckv1 "knative.dev/pkg/apis/duck/v1"
+)
+
+func TestConsumer_Validate(t *testing.T) {
+	tests := []struct {
+		name    string
+		ctx     context.Context
+		given   *Consumer
+		wantErr bool
+	}{
+		{
+			name:    "no topics",
+			ctx:     context.Background(),
+			given:   &Consumer{},
+			wantErr: true,
+		},
+		{
+			name: "missing group.id",
+			ctx:  context.Background(),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+				},
+			},
+			wantErr: true,
+		},
+		{
+			name: "valid",
+			ctx:  context.Background(),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-0",
+						PodNamespace: "ns",
+					},
+				},
+			},
+			wantErr: false,
+		},
+		{
+			name: "invalid multiple reply strategies (topic, destination)",
+			ctx:  context.Background(),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Reply: &ReplyStrategy{
+						TopicReply: &TopicReply{Enabled: true},
+						URLReply:   &DestinationReply{Enabled: true},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-0",
+						PodNamespace: "ns",
+					},
+				},
+			},
+			wantErr: true,
+		},
+		{
+			name: "invalid no pod name",
+			ctx:  context.Background(),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodNamespace: "ns",
+					},
+				},
+			},
+			wantErr: true,
+		},
+		{
+			name: "invalid no pod namespace",
+			ctx:  context.Background(),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName: "p-0",
+					},
+				},
+			},
+			wantErr: true,
+		},
+		{
+			name: "valid - no updates",
+			ctx: apis.WithinUpdate(context.Background(), &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-0",
+						PodNamespace: "ns",
+					},
+				},
+			},
+			),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-0",
+						PodNamespace: "ns",
+					},
+				},
+			},
+			wantErr: false,
+		},
+		{
+			name: "invalid pod name update",
+			ctx: apis.WithinUpdate(context.Background(), &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-1",
+						PodNamespace: "ns",
+					},
+				},
+			},
+			),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-0",
+						PodNamespace: "ns",
+					},
+				},
+			},
+			wantErr: true,
+		},
+		{
+			name: "invalid pod name update",
+			ctx: apis.WithinUpdate(context.Background(), &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-0",
+						PodNamespace: "ns-1",
+					},
+				},
+			},
+			),
+			given: &Consumer{
+				Spec: ConsumerSpec{
+					Topics: []string{"t1"},
+					Configs: ConsumerConfigs{
+						Configs: map[string]string{
+							"group.id":          "g1",
+							"bootstrap.servers": "kafka:9092",
+						},
+					},
+					Delivery: &DeliverySpec{
+						DeliverySpec: &eventingduck.DeliverySpec{},
+					},
+					Subscriber: duckv1.Destination{
+						URI: &apis.URL{
+							Scheme: "http",
+							Host:   "127.0.0.1",
+						},
+					},
+					PodBind: &PodBind{
+						PodName:      "p-0",
+						PodNamespace: "ns-2",
+					},
+				},
+			},
+			wantErr: true,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			if err := tt.given.Validate(tt.ctx); (err != nil) != tt.wantErr {
+				t.Errorf("want err = %v, got err %v", tt.wantErr, err)
+			}
+		})
+	}
+}