Repository: knative-sandbox/eventing-kafka
Pull request #511 (2021-04-07 09:30:59)

[Consolidated] Pass ServiceAccount to use in consolidated channel via an env var
Fixes #

<!-- Please include the 'why' behind your changes if no issue exists -->

## Proposed Changes

- Pass ServiceAccount to use in consolidated channel via an env var
- This is done that way in distributed channel
- Currently, the value of the env var is set to previously hardcoded value

<!--
If this change has user-visible impact, follow the instructions below.
Examples include:

- 🎁 Add new feature
- 🐛 Fix bug
- 🧽 Update or clean up current behavior
- 🗑️ Remove feature or internal logic

Otherwise delete the rest of this template.
-->

**Release Note**

<!--
🗒️ If this change has user-visible impact, write a release note in the block
below. Include the string "action required" if additional action is required of
users switching to the new release, for example in case of a breaking change.

Write as if you are speaking to users, not other Knative contributors. If this
change has no user-visible impact, no release-note is needed.
-->

```release-note

```

**Docs**

<!--
📖 If this change has user-visible impact, link to an issue or PR in
https://github.com/knative/docs.
-->


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

This pull-request has been approved by:
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please ask for approval from **aliok** after the PR has been reviewed.

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

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

- **[OWNERS](https://github.com/knative-sandbox/eventing-kafka/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":["aliok"]} -->
aliok: /hold
Wait for 0.22 cut
knative-prow-robot: @aliok: The following test **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-unit-tests | 396ca3d17b3b2a45f63d56198d03a153269b3a28 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-unit-tests/1379728418643382272) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-unit-tests | 396ca3d17b3b2a45f63d56198d03a153269b3a28 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-unit-tests/1379728418643382272) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 396ca3d17b3b2a45f63d56198d03a153269b3a28 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379728418584662016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511?src=pr&el=h1) Report
> Merging [#511](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511?src=pr&el=desc) (4b553e5) into [main](https://codecov.io/gh/knative-sandbox/eventing-kafka/commit/c4ff783520580953d0ae397708c764815932b6ba?el=desc) (c4ff783) will **increase** coverage by `0.13%`.
> The diff coverage is `66.66%`.

> :exclamation: Current head 4b553e5 differs from pull request most recent head 9c3ecf6. Consider uploading reports for the commit 9c3ecf6 to get more accurate results
[![Impacted file tree graph](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511/graphs/tree.svg?width=650&height=150&src=pr&token=W765CT93QC)](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511?src=pr&el=tree)

```diff
@@            Coverage Diff             @@
##             main     #511      +/-   ##
==========================================
+ Coverage   73.41%   73.55%   +0.13%     
==========================================
  Files         146      146              
  Lines        5741     5741              
==========================================
+ Hits         4215     4223       +8     
+ Misses       1281     1273       -8     
  Partials      245      245              
```


| [Impacted Files](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [...l/consolidated/reconciler/controller/controller.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvY29uc29saWRhdGVkL3JlY29uY2lsZXIvY29udHJvbGxlci9jb250cm9sbGVyLmdv) | `0.00% <0.00%> (ø)` | |
| [...consolidated/reconciler/controller/kafkachannel.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvY29uc29saWRhdGVkL3JlY29uY2lsZXIvY29udHJvbGxlci9rYWZrYWNoYW5uZWwuZ28=) | `47.91% <100.00%> (+0.18%)` | :arrow_up: |
| [...ated/reconciler/controller/resources/dispatcher.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvY29uc29saWRhdGVkL3JlY29uY2lsZXIvY29udHJvbGxlci9yZXNvdXJjZXMvZGlzcGF0Y2hlci5nbw==) | `100.00% <100.00%> (ø)` | |
| [...el/distributed/dispatcher/dispatcher/dispatcher.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvZGlzdHJpYnV0ZWQvZGlzcGF0Y2hlci9kaXNwYXRjaGVyL2Rpc3BhdGNoZXIuZ28=) | `79.28% <0.00%> (+5.00%)` | :arrow_up: |

------

[Continue to review full report at Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511?src=pr&el=continue).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511?src=pr&el=footer). Last update [c4ff783...9c3ecf6](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/511?src=pr&el=lastupdated). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments).

knative-prow-robot: @aliok: The following test **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379734643380588544) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379734643380588544) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379734643338645504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379734643380588544) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379734643338645504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379734643359617024) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379734643380588544) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379734643338645504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379734643359617024) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1379734643317673984) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379734643380588544) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379734643338645504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379734643359617024) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1379734643317673984) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1379734643401560064) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`

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

<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 -->
aliok: /retest

not sure if this is a flake
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379734643338645504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379734643359617024) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1379734643317673984) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1379734643401560064) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379745517478612992) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379734643359617024) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1379734643317673984) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1379734643401560064) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379745517478612992) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379745517432475648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1379734643317673984) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1379734643401560064) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379745517478612992) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379745517432475648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379745517453447168) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: @aliok: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379745517478612992) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379745517432475648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379745517453447168) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1379745517411504128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<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 -->
matzew: Ali: @aliok

the tests fail, b/c the point to main evebting.
Dropping beta1 broke everything

See my dependecy update PR

On Wed 7. Apr 2021 at 13:04, Knative Prow Robot ***@***.***>
wrote:

> @aliok <https://github.com/aliok>: The following tests *failed*, say
> /retest to rerun all failed tests:
> Test name Commit Details Rerun command
> pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated
> 9c3ecf6
> <https://github.com/knative-sandbox/eventing-kafka/commit/9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9>
> link
> <https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1379734643317673984> /test
> pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated
> pull-knative-sandbox-eventing-kafka-integration-test-mt-source 9c3ecf6
> <https://github.com/knative-sandbox/eventing-kafka/commit/9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9>
> link
> <https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1379734643401560064> /test
> pull-knative-sandbox-eventing-kafka-integration-test-mt-source
> pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed
> 9c3ecf6
> <https://github.com/knative-sandbox/eventing-kafka/commit/9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9>
> link
> <https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1379745517478612992> /test
> pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed
>
> pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls
> 9c3ecf6
> <https://github.com/knative-sandbox/eventing-kafka/commit/9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9>
> link
> <https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1379745517432475648> /test
> pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls
>
> pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl
> 9c3ecf6
> <https://github.com/knative-sandbox/eventing-kafka/commit/9c3ecf6f08b50b36b98b76a8f3ffef7b9a6d40b9>
> link
> <https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/511/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1379745517453447168> /test
> pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl
>
> Full PR test history
> <https://gubernator.knative.dev/pr/knative-sandbox_eventing-kafka/511>. Your
> PR dashboard <https://gubernator.knative.dev/pr/aliok>.
>
> 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>.
>
> —
>
>
> You are receiving this because your review was requested.
> Reply to this email directly, view it on GitHub
> <https://github.com/knative-sandbox/eventing-kafka/pull/511#issuecomment-814820627>,
> or unsubscribe
> <https://github.com/notifications/unsubscribe-auth/AABGPTWIEZXP5N4G7EU4FIDTHQ33VANCNFSM42QNH6LQ>
> .
>
-- 
Sent from Gmail Mobile


Patch:
diff --git a/config/channel/consolidated/deployments/controller.yaml b/config/channel/consolidated/deployments/controller.yaml
index fdf8d2ece..823d5cae4 100644
--- a/config/channel/consolidated/deployments/controller.yaml
+++ b/config/channel/consolidated/deployments/controller.yaml
@@ -50,6 +50,9 @@ spec:
           value: config-leader-election
         - name: DISPATCHER_IMAGE
           value: ko://knative.dev/eventing-kafka/cmd/channel/consolidated/dispatcher
+        # service account used in the dispatcher
+        - name: SERVICE_ACCOUNT
+          value: kafka-ch-dispatcher
         ports:
         - containerPort: 9090
           name: metrics
diff --git a/go.mod b/go.mod
index 704af40ba..76d850ba2 100644
--- a/go.mod
+++ b/go.mod
@@ -33,7 +33,7 @@ require (
 	k8s.io/apimachinery v0.19.7
 	k8s.io/client-go v0.19.7
 	k8s.io/utils v0.0.0-20200729134348-d5654de09c73
-	knative.dev/eventing v0.21.1-0.20210330142021-dca8b0acf039
+	knative.dev/eventing v0.22.0
 	knative.dev/hack v0.0.0-20210325223819-b6ab329907d3
 	knative.dev/networking v0.0.0-20210331064822-999a7708876c
 	knative.dev/pkg v0.0.0-20210331065221-952fdd90dbb0
diff --git a/go.sum b/go.sum
index f31d9bc14..eba0152fa 100644
--- a/go.sum
+++ b/go.sum
@@ -1276,20 +1276,19 @@ k8s.io/kube-openapi v0.0.0-20200805222855-6aeccd4b50c6 h1:+WnxoVtG8TMiudHBSEtrVL
 k8s.io/kube-openapi v0.0.0-20200805222855-6aeccd4b50c6/go.mod h1:UuqjUnNftUyPE5H64/qeyjQoUZhGpeFDVdxjTeEVN2o=
 k8s.io/utils v0.0.0-20200729134348-d5654de09c73 h1:uJmqzgNWG7XyClnU/mLPBWwfKKF1K8Hf8whTseBgJcg=
 k8s.io/utils v0.0.0-20200729134348-d5654de09c73/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
-knative.dev/eventing v0.21.1-0.20210330142021-dca8b0acf039 h1:skDjBvseFTDncrI6ZF5Vxu9dP9innYrZictqXgqtsaU=
-knative.dev/eventing v0.21.1-0.20210330142021-dca8b0acf039/go.mod h1:UE4xmtZ/fZWmbFOLL9u1WuBxxnTm9GmGQceuKram4Kg=
-knative.dev/hack v0.0.0-20210317214554-58edbdc42966/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
+knative.dev/eventing v0.22.0 h1:esDaddfSmiVhLKDnUCVVunSdNeHklVEz0fsqs3NupuQ=
+knative.dev/eventing v0.22.0/go.mod h1:LOG7bh0eZQkbYANcnORwke6Yy6aUu62o8GeByaOFfRQ=
 knative.dev/hack v0.0.0-20210325223819-b6ab329907d3 h1:km0Rrh0T9/wA2pivQm1hqSPVwgNgGCHC2WNn3GakZmE=
 knative.dev/hack v0.0.0-20210325223819-b6ab329907d3/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
 knative.dev/hack/schema v0.0.0-20210325223819-b6ab329907d3/go.mod h1:ffjwmdcrH5vN3mPhO8RrF2KfNnbHeCE2C60A+2cv3U0=
 knative.dev/networking v0.0.0-20210331064822-999a7708876c h1:7ggsYXtltPHjbgxi76hg5g2eOtmg8KaBIP40XJsfMyA=
 knative.dev/networking v0.0.0-20210331064822-999a7708876c/go.mod h1:0V6M1AaWPL/MtQLuEx0NxiwDdtb8Y4b4f7P3C8sp0zo=
-knative.dev/pkg v0.0.0-20210318052054-dfeeb1817679/go.mod h1:o1aTlbc+h60DP9P6nd/WmP99Ny9Ls3U/JIjL4xMgqpw=
 knative.dev/pkg v0.0.0-20210329065222-9d92ea16c0d3/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
 knative.dev/pkg v0.0.0-20210330162221-808d62257db6/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
+knative.dev/pkg v0.0.0-20210331062321-6317ec6066f4/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
 knative.dev/pkg v0.0.0-20210331065221-952fdd90dbb0 h1:z05hcB4br0qz7JdwIoUSTXLTF+7ThuJ+R6NFfXd1Y4Q=
 knative.dev/pkg v0.0.0-20210331065221-952fdd90dbb0/go.mod h1:PD5g8hUCXq6iR3tILjmZeJBvQfXGnHMPKryq54qHJhg=
-knative.dev/reconciler-test v0.0.0-20210329193624-ea6f47034b61/go.mod h1:QSd2hWDDwFh+9AHOkiECsj2ZY2DGJBKnj6aT6LITBuw=
+knative.dev/reconciler-test v0.0.0-20210329214021-2a67496462a4/go.mod h1:qLfJMHc0i9ENTSet/SUp/FcQm4QVfNTX8ZC//aVQN0M=
 pgregory.net/rapid v0.3.3 h1:jCjBsY4ln4Atz78QoBWxUEvAHaFyNDQg9+WU62aCn1U=
 pgregory.net/rapid v0.3.3/go.mod h1:UYpPVyjFHzYBGHIxLFoupi8vwk6rXNzRY9OMvVxFIOU=
 rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
diff --git a/pkg/channel/consolidated/reconciler/controller/controller.go b/pkg/channel/consolidated/reconciler/controller/controller.go
index 795a91f86..a91f70b33 100644
--- a/pkg/channel/consolidated/reconciler/controller/controller.go
+++ b/pkg/channel/consolidated/reconciler/controller/controller.go
@@ -89,11 +89,8 @@ func NewController(
 		logger.Panicf("unable to process Kafka channel's required environment variables: %v", err)
 	}
 
-	if env.Image == "" {
-		logger.Panic("unable to process Kafka channel's required environment variables (missing DISPATCHER_IMAGE)")
-	}
-
 	r.dispatcherImage = env.Image
+	r.dispatcherServiceAccount = env.DispatcherServiceAccount
 
 	impl := kafkaChannelReconciler.NewImpl(ctx, r)
 
diff --git a/pkg/channel/consolidated/reconciler/controller/kafkachannel.go b/pkg/channel/consolidated/reconciler/controller/kafkachannel.go
index e914e2c6b..efb6c036b 100644
--- a/pkg/channel/consolidated/reconciler/controller/kafkachannel.go
+++ b/pkg/channel/consolidated/reconciler/controller/kafkachannel.go
@@ -112,8 +112,9 @@ type Reconciler struct {
 
 	EventingClientSet eventingclientset.Interface
 
-	systemNamespace string
-	dispatcherImage string
+	systemNamespace          string
+	dispatcherImage          string
+	dispatcherServiceAccount string
 
 	kafkaConfig      *utils.KafkaConfig
 	kafkaAuthConfig  *client.KafkaAuthConfig
@@ -133,7 +134,8 @@ type Reconciler struct {
 }
 
 type envConfig struct {
-	Image string `envconfig:"DISPATCHER_IMAGE" required:"true"`
+	Image                    string `envconfig:"DISPATCHER_IMAGE" required:"true"`
+	DispatcherServiceAccount string `envconfig:"SERVICE_ACCOUNT" required:"true"`
 }
 
 // Check that our Reconciler implements kafka's injection Interface
@@ -307,6 +309,7 @@ func (r *Reconciler) reconcileDispatcher(ctx context.Context, scope string, disp
 		DispatcherNamespace: dispatcherNamespace,
 		Image:               r.dispatcherImage,
 		Replicas:            1,
+		ServiceAccount:      r.dispatcherServiceAccount,
 	}
 
 	expected := resources.MakeDispatcher(args)
diff --git a/pkg/channel/consolidated/reconciler/controller/resources/dispatcher.go b/pkg/channel/consolidated/reconciler/controller/resources/dispatcher.go
index ac34d20be..ca06a04e8 100644
--- a/pkg/channel/consolidated/reconciler/controller/resources/dispatcher.go
+++ b/pkg/channel/consolidated/reconciler/controller/resources/dispatcher.go
@@ -27,9 +27,8 @@ import (
 const DispatcherContainerName = "dispatcher"
 
 var (
-	serviceAccountName = "kafka-ch-dispatcher"
-	dispatcherName     = "kafka-ch-dispatcher"
-	dispatcherLabels   = map[string]string{
+	dispatcherName   = "kafka-ch-dispatcher"
+	dispatcherLabels = map[string]string{
 		"messaging.knative.dev/channel": "kafka-channel",
 		"messaging.knative.dev/role":    "dispatcher",
 	}
@@ -40,6 +39,7 @@ type DispatcherArgs struct {
 	DispatcherNamespace string
 	Image               string
 	Replicas            int32
+	ServiceAccount      string
 }
 
 // MakeDispatcher generates the dispatcher deployment for the KafKa channel
@@ -65,7 +65,7 @@ func MakeDispatcher(args DispatcherArgs) *v1.Deployment {
 					Labels: dispatcherLabels,
 				},
 				Spec: corev1.PodSpec{
-					ServiceAccountName: serviceAccountName,
+					ServiceAccountName: args.ServiceAccount,
 					Containers: []corev1.Container{
 						{
 							Name:  DispatcherContainerName,
diff --git a/vendor/modules.txt b/vendor/modules.txt
index b4ef58837..bf932ddac 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -1090,7 +1090,7 @@ k8s.io/utils/buffer
 k8s.io/utils/integer
 k8s.io/utils/pointer
 k8s.io/utils/trace
-# knative.dev/eventing v0.21.1-0.20210330142021-dca8b0acf039
+# knative.dev/eventing v0.22.0
 ## explicit
 knative.dev/eventing/pkg/adapter/v2
 knative.dev/eventing/pkg/adapter/v2/test


Test patch:
diff --git a/pkg/channel/consolidated/reconciler/controller/kafkachannel_test.go b/pkg/channel/consolidated/reconciler/controller/kafkachannel_test.go
index 4d4454c1e..a86f1da50 100644
--- a/pkg/channel/consolidated/reconciler/controller/kafkachannel_test.go
+++ b/pkg/channel/consolidated/reconciler/controller/kafkachannel_test.go
@@ -50,15 +50,16 @@ import (
 )
 
 const (
-	testNS                = "test-namespace"
-	kcName                = "test-kc"
-	testDispatcherImage   = "test-image"
-	channelServiceAddress = "test-kc-kn-channel.test-namespace.svc.cluster.local"
-	brokerName            = "test-broker"
-	finalizerName         = "kafkachannels.messaging.knative.dev"
-	sub1UID               = "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1"
-	sub2UID               = "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1"
-	twoSubscribersPatch   = `[{"op":"add","path":"/status/subscribers","value":[{"observedGeneration":1,"ready":"True","uid":"2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1"},{"observedGeneration":2,"ready":"True","uid":"34c5aec8-deb6-11e8-9f32-f2801f1b9fd1"}]}]`
+	testNS                       = "test-namespace"
+	testDispatcherserviceAccount = "kafka-ch-dispatcher"
+	kcName                       = "test-kc"
+	testDispatcherImage          = "test-image"
+	channelServiceAddress        = "test-kc-kn-channel.test-namespace.svc.cluster.local"
+	brokerName                   = "test-broker"
+	finalizerName                = "kafkachannels.messaging.knative.dev"
+	sub1UID                      = "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1"
+	sub2UID                      = "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1"
+	twoSubscribersPatch          = `[{"op":"add","path":"/status/subscribers","value":[{"observedGeneration":1,"ready":"True","uid":"2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1"},{"observedGeneration":2,"ready":"True","uid":"34c5aec8-deb6-11e8-9f32-f2801f1b9fd1"}]}]`
 )
 
 var (
@@ -327,8 +328,9 @@ func TestAllCases(t *testing.T) {
 	table.Test(t, reconcilertesting.MakeFactory(func(ctx context.Context, listers *reconcilertesting.Listers, cmw configmap.Watcher) controller.Reconciler {
 
 		r := &Reconciler{
-			systemNamespace: testNS,
-			dispatcherImage: testDispatcherImage,
+			systemNamespace:          testNS,
+			dispatcherImage:          testDispatcherImage,
+			dispatcherServiceAccount: testDispatcherserviceAccount,
 			kafkaConfig: &KafkaConfig{
 				Brokers: []string{brokerName},
 			},
@@ -390,8 +392,9 @@ func TestTopicExists(t *testing.T) {
 	row.Test(t, reconcilertesting.MakeFactory(func(ctx context.Context, listers *reconcilertesting.Listers, cmw configmap.Watcher) controller.Reconciler {
 
 		r := &Reconciler{
-			systemNamespace: testNS,
-			dispatcherImage: testDispatcherImage,
+			systemNamespace:          testNS,
+			dispatcherImage:          testDispatcherImage,
+			dispatcherServiceAccount: testDispatcherserviceAccount,
 			kafkaConfig: &KafkaConfig{
 				Brokers: []string{brokerName},
 			},
@@ -465,8 +468,9 @@ func TestDeploymentUpdatedOnImageChange(t *testing.T) {
 	row.Test(t, reconcilertesting.MakeFactory(func(ctx context.Context, listers *reconcilertesting.Listers, cmw configmap.Watcher) controller.Reconciler {
 
 		r := &Reconciler{
-			systemNamespace: testNS,
-			dispatcherImage: testDispatcherImage,
+			systemNamespace:          testNS,
+			dispatcherImage:          testDispatcherImage,
+			dispatcherServiceAccount: testDispatcherserviceAccount,
 			kafkaConfig: &KafkaConfig{
 				Brokers: []string{brokerName},
 			},
@@ -540,8 +544,9 @@ func TestDeploymentZeroReplicas(t *testing.T) {
 	row.Test(t, reconcilertesting.MakeFactory(func(ctx context.Context, listers *reconcilertesting.Listers, cmw configmap.Watcher) controller.Reconciler {
 
 		r := &Reconciler{
-			systemNamespace: testNS,
-			dispatcherImage: testDispatcherImage,
+			systemNamespace:          testNS,
+			dispatcherImage:          testDispatcherImage,
+			dispatcherServiceAccount: testDispatcherserviceAccount,
 			kafkaConfig: &KafkaConfig{
 				Brokers: []string{brokerName},
 			},
@@ -612,8 +617,9 @@ func TestDeploymentMoreThanOneReplicas(t *testing.T) {
 	row.Test(t, reconcilertesting.MakeFactory(func(ctx context.Context, listers *reconcilertesting.Listers, cmw configmap.Watcher) controller.Reconciler {
 
 		r := &Reconciler{
-			systemNamespace: testNS,
-			dispatcherImage: testDispatcherImage,
+			systemNamespace:          testNS,
+			dispatcherImage:          testDispatcherImage,
+			dispatcherServiceAccount: testDispatcherserviceAccount,
 			kafkaConfig: &KafkaConfig{
 				Brokers: []string{brokerName},
 			},
@@ -749,6 +755,7 @@ func makeDeploymentWithImageAndReplicas(image string, replicas int32) *appsv1.De
 		DispatcherNamespace: testNS,
 		Image:               image,
 		Replicas:            replicas,
+		ServiceAccount:      testDispatcherserviceAccount,
 	})
 }
 
diff --git a/pkg/channel/consolidated/reconciler/controller/resources/dispatcher_test.go b/pkg/channel/consolidated/reconciler/controller/resources/dispatcher_test.go
index c68cadcbd..8dfd667ed 100644
--- a/pkg/channel/consolidated/reconciler/controller/resources/dispatcher_test.go
+++ b/pkg/channel/consolidated/reconciler/controller/resources/dispatcher_test.go
@@ -28,7 +28,8 @@ import (
 )
 
 const (
-	imageName = "my-test-image"
+	imageName      = "my-test-image"
+	serviceAccount = "kafka-ch-dispatcher"
 )
 
 func TestNewDispatcher(t *testing.T) {
@@ -39,6 +40,7 @@ func TestNewDispatcher(t *testing.T) {
 		DispatcherNamespace: testNS,
 		Image:               imageName,
 		Replicas:            1,
+		ServiceAccount:      serviceAccount,
 	}
 
 	replicas := int32(1)
@@ -61,7 +63,7 @@ func TestNewDispatcher(t *testing.T) {
 					Labels: dispatcherLabels,
 				},
 				Spec: corev1.PodSpec{
-					ServiceAccountName: serviceAccountName,
+					ServiceAccountName: serviceAccount,
 					Containers: []corev1.Container{
 						{
 							Name:  "dispatcher",
@@ -121,6 +123,7 @@ func TestNewNamespaceDispatcher(t *testing.T) {
 		DispatcherNamespace: testNS,
 		Image:               imageName,
 		Replicas:            1,
+		ServiceAccount:      serviceAccount,
 	}
 
 	replicas := int32(1)
@@ -143,7 +146,7 @@ func TestNewNamespaceDispatcher(t *testing.T) {
 					Labels: dispatcherLabels,
 				},
 				Spec: corev1.PodSpec{
-					ServiceAccountName: serviceAccountName,
+					ServiceAccountName: serviceAccount,
 					Containers: []corev1.Container{
 						{
 							Name:  "dispatcher",
diff --git a/pkg/channel/consolidated/reconciler/controller/resources/role_binding_test.go b/pkg/channel/consolidated/reconciler/controller/resources/role_binding_test.go
index 766e4d3e5..792fe9b3c 100644
--- a/pkg/channel/consolidated/reconciler/controller/resources/role_binding_test.go
+++ b/pkg/channel/consolidated/reconciler/controller/resources/role_binding_test.go
@@ -44,12 +44,12 @@ func TestNewRoleBinding(t *testing.T) {
 			{
 				Kind:      "ServiceAccount",
 				Namespace: testNS,
-				Name:      serviceAccountName,
+				Name:      serviceAccount,
 			},
 		},
 	}
 
-	sa := MakeServiceAccount(testNS, serviceAccountName)
+	sa := MakeServiceAccount(testNS, serviceAccount)
 	got := MakeRoleBinding(testNS, rbName, sa, crName)
 
 	if diff := cmp.Diff(want, got); diff != "" {
diff --git a/pkg/channel/consolidated/reconciler/controller/resources/service_account_test.go b/pkg/channel/consolidated/reconciler/controller/resources/service_account_test.go
index fffbac491..84b4968fb 100644
--- a/pkg/channel/consolidated/reconciler/controller/resources/service_account_test.go
+++ b/pkg/channel/consolidated/reconciler/controller/resources/service_account_test.go
@@ -28,11 +28,11 @@ func TestNewServiceAccount(t *testing.T) {
 	want := &corev1.ServiceAccount{
 		ObjectMeta: metav1.ObjectMeta{
 			Namespace: testNS,
-			Name:      serviceAccountName,
+			Name:      serviceAccount,
 		},
 	}
 
-	got := MakeServiceAccount(testNS, serviceAccountName)
+	got := MakeServiceAccount(testNS, serviceAccount)
 
 	if diff := cmp.Diff(want, got); diff != "" {
 		t.Errorf("unexpected condition (-want, +got) = %v", diff)
diff --git a/test/e2e-common.sh b/test/e2e-common.sh
index ab3f78951..326c776a9 100755
--- a/test/e2e-common.sh
+++ b/test/e2e-common.sh
@@ -171,22 +171,22 @@ function knative_setup() {
 }
 
 function install_knative_eventing {
-  if is_release_branch; then
-    echo ">> Install Knative Eventing from ${KNATIVE_EVENTING_RELEASE}"
-    kubectl apply -f ${KNATIVE_EVENTING_RELEASE}
-  else
-    echo ">> Install Knative Eventing from HEAD"
-    pushd .
-    cd ${GOPATH} && mkdir -p src/knative.dev && cd src/knative.dev
-    git clone https://github.com/knative/eventing
-    cd eventing
-    ko apply -f "${EVENTING_CONFIG}"
-    # Install MT Channel Based Broker
-    ko apply -f "${EVENTING_MT_CHANNEL_BROKER_CONFIG}"
-    # Install IMC
-    ko apply -f "${EVENTING_IN_MEMORY_CHANNEL_CONFIG}"
-    popd
-  fi
+  # if is_release_branch; then
+    echo ">> Install Knative Eventing from https://storage.googleapis.com/knative-releases/eventing/previous/v0.22.0/eventing.yaml"
+    kubectl apply -f https://storage.googleapis.com/knative-releases/eventing/previous/v0.22.0/eventing.yaml
+  # else
+  #   echo ">> Install Knative Eventing from HEAD"
+  #   pushd .
+  #   cd ${GOPATH} && mkdir -p src/knative.dev && cd src/knative.dev
+  #   git clone https://github.com/knative/eventing
+  #   cd eventing
+  #   ko apply -f "${EVENTING_CONFIG}"
+  #   # Install MT Channel Based Broker
+  #   ko apply -f "${EVENTING_MT_CHANNEL_BROKER_CONFIG}"
+  #   # Install IMC
+  #   ko apply -f "${EVENTING_IN_MEMORY_CHANNEL_CONFIG}"
+  #   popd
+  # fi
   wait_until_pods_running "${EVENTING_NAMESPACE}" || fail_test "Knative Eventing did not come up"
 
   install_zipkin
@@ -211,21 +211,21 @@ function uninstall_zipkin() {
 
 function knative_teardown() {
   echo ">> Stopping Knative Eventing"
-  if is_release_branch; then
-    echo ">> Uninstalling Knative Eventing from ${KNATIVE_EVENTING_RELEASE}"
-    kubectl delete -f "${KNATIVE_EVENTING_RELEASE}"
-  else
-    echo ">> Uninstalling Knative Eventing from HEAD"
-    pushd .
-    cd ${GOPATH}/src/knative.dev/eventing
-    # Remove IMC
-    ko delete -f "${EVENTING_IN_MEMORY_CHANNEL_CONFIG}"
-    # Remove MT Channel Based Broker
-    ko delete -f "${EVENTING_MT_CHANNEL_BROKER_CONFIG}"
-    # Remove eventing
-    ko delete -f "${EVENTING_CONFIG}"
-    popd
-  fi
+  # if is_release_branch; then
+    echo ">> Uninstalling Knative Eventing from https://storage.googleapis.com/knative-releases/eventing/previous/v0.22.0/eventing.yaml"
+    kubectl delete -f https://storage.googleapis.com/knative-releases/eventing/previous/v0.22.0/eventing.yaml
+  # else
+  #   echo ">> Uninstalling Knative Eventing from HEAD"
+  #   pushd .
+  #   cd ${GOPATH}/src/knative.dev/eventing
+  #   # Remove IMC
+  #   ko delete -f "${EVENTING_IN_MEMORY_CHANNEL_CONFIG}"
+  #   # Remove MT Channel Based Broker
+  #   ko delete -f "${EVENTING_MT_CHANNEL_BROKER_CONFIG}"
+  #   # Remove eventing
+  #   ko delete -f "${EVENTING_CONFIG}"
+  #   popd
+  # fi
   wait_until_object_does_not_exist namespaces "${EVENTING_NAMESPACE}"
 }