Repository: knative-sandbox/eventing-kafka
Pull request #430 (2021-03-03 22:29:16)

move eventing/pkg/apis/duck/v1alpha1 here
Addresses #426 

<!-- Please include the 'why' behind your changes if no issue exists -->

## Proposed Changes

- This moves the ducks from knative.dev/eventing/pkg/apis/duck/v1alpha1 here

<!--
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
 * Note that after the upstream PR: https://github.com/knative/eventing/pull/5005 goes in, old v1alpha1 channels will not be reconciled.

```

**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 assign **vaikas** after the PR has been reviewed.
You can assign the PR to them by writing `/assign @vaikas` in a comment when ready.

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

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

- **[OWNERS](https://github.com/knative-sandbox/eventing-kafka/blob/master/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":["vaikas"]} -->
knative-metrics-robot: The following is the coverage report on the affected files.
Say `/test pull-knative-sandbox-eventing-kafka-go-coverage` to re-run this coverage report

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/apis/duck/v1alpha1/channelable_combined_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367240698243321856/artifacts/line-cov.html#file0) | Do not exist | 90.9% | 
[pkg/apis/duck/v1alpha1/channelable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367240698243321856/artifacts/line-cov.html#file1) | Do not exist | 87.5% | 
[pkg/apis/duck/v1alpha1/subscribable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367240698243321856/artifacts/line-cov.html#file2) | Do not exist | 100.0% | 
[pkg/apis/duck/v1alpha1/subscribable_types_conversion.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367240698243321856/artifacts/line-cov.html#file3) | Do not exist | 86.4% | 

codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430?src=pr&el=h1) Report
> Merging [#430](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430?src=pr&el=desc) (1f04b37) into [master](https://codecov.io/gh/knative-sandbox/eventing-kafka/commit/960ddd1e6603188550fb6714a7bdc04637c477b8?el=desc) (960ddd1) will **increase** coverage by `0.60%`.
> The diff coverage is `n/a`.

[![Impacted file tree graph](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/graphs/tree.svg?width=650&height=150&src=pr&token=W765CT93QC)](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430?src=pr&el=tree)

```diff
@@            Coverage Diff             @@
##           master     #430      +/-   ##
==========================================
+ Coverage   73.44%   74.04%   +0.60%     
==========================================
  Files         129      135       +6     
  Lines        5008     5328     +320     
==========================================
+ Hits         3678     3945     +267     
- Misses       1094     1131      +37     
- Partials      236      252      +16     
```


| [Impacted Files](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [...g/apis/duck/v1alpha1/channelable\_combined\_types.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2FwaXMvZHVjay92MWFscGhhMS9jaGFubmVsYWJsZV9jb21iaW5lZF90eXBlcy5nbw==) | `98.55% <ø> (ø)` | |
| [pkg/apis/duck/v1alpha1/channelable\_types.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2FwaXMvZHVjay92MWFscGhhMS9jaGFubmVsYWJsZV90eXBlcy5nbw==) | `98.14% <ø> (ø)` | |
| [pkg/apis/duck/v1alpha1/subscribable\_types.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2FwaXMvZHVjay92MWFscGhhMS9zdWJzY3JpYmFibGVfdHlwZXMuZ28=) | `100.00% <ø> (ø)` | |
| [...pis/duck/v1alpha1/subscribable\_types\_conversion.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2FwaXMvZHVjay92MWFscGhhMS9zdWJzY3JpYmFibGVfdHlwZXNfY29udmVyc2lvbi5nbw==) | `79.48% <ø> (ø)` | |
| [...pis/messaging/v1alpha1/kafka\_channel\_conversion.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2FwaXMvbWVzc2FnaW5nL3YxYWxwaGExL2thZmthX2NoYW5uZWxfY29udmVyc2lvbi5nbw==) | `92.15% <ø> (ø)` | |
| [pkg/apis/messaging/v1alpha1/kafka\_channel\_types.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2FwaXMvbWVzc2FnaW5nL3YxYWxwaGExL2thZmthX2NoYW5uZWxfdHlwZXMuZ28=) | `100.00% <ø> (ø)` | |
| [...el/distributed/dispatcher/dispatcher/dispatcher.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvZGlzdHJpYnV0ZWQvZGlzcGF0Y2hlci9kaXNwYXRjaGVyL2Rpc3BhdGNoZXIuZ28=) | `71.20% <0.00%> (-5.60%)` | :arrow_down: |
| [pkg/apis/duck/v1alpha1/placement\_types.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree#diff-cGtnL2FwaXMvZHVjay92MWFscGhhMS9wbGFjZW1lbnRfdHlwZXMuZ28=) | `0.00% <0.00%> (ø)` | |
| ... and [3 more](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430/diff?src=pr&el=tree-more) | |

------

[Continue to review full report at Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430?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/430?src=pr&el=footer). Last update [960ddd1...9c6075c](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/430?src=pr&el=lastupdated). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments).

knative-metrics-robot: The following is the coverage report on the affected files.
Say `/test pull-knative-sandbox-eventing-kafka-go-coverage` to re-run this coverage report

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/apis/duck/v1alpha1/channelable_combined_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367246642440310784/artifacts/line-cov.html#file0) | Do not exist | 90.9% | 
[pkg/apis/duck/v1alpha1/channelable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367246642440310784/artifacts/line-cov.html#file1) | Do not exist | 87.5% | 
[pkg/apis/duck/v1alpha1/subscribable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367246642440310784/artifacts/line-cov.html#file2) | Do not exist | 100.0% | 
[pkg/apis/duck/v1alpha1/subscribable_types_conversion.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367246642440310784/artifacts/line-cov.html#file3) | Do not exist | 86.4% | 

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367511501086134272) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

<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: @vaikas: PR needs rebase.

<details>

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367511501086134272) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367511501086134272) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367511505926361088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367511501086134272) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367511505926361088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367511501086134272) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367511505926361088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367511501086134272) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367511505926361088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367511501060968448) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367511501086134272) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367511505926361088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367511501060968448) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-prow-robot: [APPROVALNOTIFIER] This PR is **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 assign **vaikas** after the PR has been reviewed.
You can assign the PR to them by writing `/assign @vaikas` in a comment when ready.

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

<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":["vaikas"]} -->
knative-prow-robot: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367511505926361088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367511501060968448) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367511501060968448) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367554905602002944) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367511501027414016) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367554905602002944) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367554905471979520) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-build-tests | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367511504252833792) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367554905602002944) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367554905471979520) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367554905455202304) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-go-coverage | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367511506765221888) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367554905602002944) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367554905471979520) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367554905455202304) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367554905576837120) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

<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: @vaikas: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367511502570917888) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367554905602002944) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367554905471979520) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367554905455202304) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367554905576837120) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367554905631363072) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

<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: @vaikas: 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 | 05abca05ddcb8c10c489d51145e9bf09af9542ef | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367511501111300096) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367554905602002944) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367554905471979520) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367554905455202304) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367554905576837120) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367554905631363072) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367554905547476992) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`

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

<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: @vaikas: 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 | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1367554905501339648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-unit-tests/1367554905602002944) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1367554905471979520) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367554905455202304) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-build-tests/1367554905576837120) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367554905631363072) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-mt-source | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-mt-source/1367554905547476992) | `/test pull-knative-sandbox-eventing-kafka-integration-test-mt-source`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 4c92ead27332a56b59fab7be8d0cc1e35fe4ac23 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1367554905526505472) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

<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-metrics-robot: The following is the coverage report on the affected files.
Say `/test pull-knative-sandbox-eventing-kafka-go-coverage` to re-run this coverage report

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/apis/duck/v1alpha1/channelable_combined_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367561062710251520/artifacts/line-cov.html#file0) | Do not exist | 90.9% | 
[pkg/apis/duck/v1alpha1/channelable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367561062710251520/artifacts/line-cov.html#file1) | Do not exist | 87.5% | 
[pkg/apis/duck/v1alpha1/subscribable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367561062710251520/artifacts/line-cov.html#file2) | Do not exist | 100.0% | 
[pkg/apis/duck/v1alpha1/subscribable_types_conversion.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367561062710251520/artifacts/line-cov.html#file3) | Do not exist | 86.4% | 

knative-prow-robot: @vaikas: 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-consolidated | 79fc52f33eab41f5beef441f45315267ae013df4 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1367561062534090752) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<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 -->
vaikas: So, as expected the v1alpha1 tests are now failing.
pierDipi: I can't think of any other solution.

I guess during a "pre-upgrade step" we have to:
- change the stored version to v1beta1 
- stop serving v1alpha1

_and there no way to downgrade_

Such pre-upgrade has to happen before upgrading eventing.

/cc @matzew @travis-minke-sap 
pierDipi: In this PR we should remove v1alpha1.
vaikas: @pierDipi would you like me to make the PR that removes the v1alpha1 as part of this PR? If that's the case, upgrade will not be easily done (not even sure how) since the storage upgrade scripts reads them in at v1alpha1 and converts. I could stop serving v1alpha1 if that's what you'd like. But I think I personally would split the PRs into this, then the next and upgrade separate ones for smaller chunks. Thoughts?
pierDipi: If you can make tests work in smaller chunks, I prefer smaller chunks, but at this point I guess v1alpha1 with the latest eventing just doesn't work, that's the reason I was suggesting to remove it, or am I wrong?

For the upgrade part, I'm thinking to a multi step pre-upgrade with multiple jobs, or do you a better solution to give users an upgrade path?
knative-metrics-robot: The following is the coverage report on the affected files.
Say `/test pull-knative-sandbox-eventing-kafka-go-coverage` to re-run this coverage report

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/apis/duck/v1alpha1/channelable_combined_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367887570276454400/artifacts/line-cov.html#file0) | Do not exist | 90.9% | 
[pkg/apis/duck/v1alpha1/channelable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367887570276454400/artifacts/line-cov.html#file1) | Do not exist | 87.5% | 
[pkg/apis/duck/v1alpha1/subscribable_types.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367887570276454400/artifacts/line-cov.html#file2) | Do not exist | 100.0% | 
[pkg/apis/duck/v1alpha1/subscribable_types_conversion.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/430/pull-knative-sandbox-eventing-kafka-go-coverage/1367887570276454400/artifacts/line-cov.html#file3) | Do not exist | 86.4% | 

vaikas: @pierDipi ok, I disabled tests with v1alpha1 and everything passes. So, I think we should get this in, and start working on the upgrade path, thoughts?
knative-prow-robot: [APPROVALNOTIFIER] This PR is **APPROVED**

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka/pull/430#pullrequestreview-605534979" title="Approved">travis-minke-sap</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).

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/blob/main/OWNERS)~~ [travis-minke-sap]

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/go.mod b/go.mod
index e8cf80887..e7556c63d 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.20210303233916-d6d48a74ff55
+	knative.dev/eventing v0.21.1-0.20210304171816-dbf18599e2ef
 	knative.dev/hack v0.0.0-20210203173706-8368e1f6eacf
 	knative.dev/pkg v0.0.0-20210303192215-8fbab7ebb77b
 )
diff --git a/go.sum b/go.sum
index 725944b28..505b644f4 100644
--- a/go.sum
+++ b/go.sum
@@ -267,7 +267,6 @@ github.com/go-kit/kit v0.10.0/go.mod h1:xUsJbQ/Fp4kEt7AFgCuvyX4a71u8h9jB8tj/ORgO
 github.com/go-logfmt/logfmt v0.3.0/go.mod h1:Qt1PoO58o5twSAckw1HlFXLmHsOX5/0LbT9GBnD5lWE=
 github.com/go-logfmt/logfmt v0.4.0/go.mod h1:3RMwSq7FuexP4Kalkev3ejPJsZTpXXBr9+V4qmtdjCk=
 github.com/go-logfmt/logfmt v0.5.0/go.mod h1:wCYkCAKZfumFQihp8CzCvQ3paCTfi41vtzG1KdI/P7A=
-github.com/go-logr/logr v0.1.0 h1:M1Tv3VzNlEHg6uyACnRdtrploV2P7wZqH8BoQMtz0cg=
 github.com/go-logr/logr v0.1.0/go.mod h1:ixOQHD9gLJUVQQ2ZOR7zLEifBX6tGkNJF4QyIY7sIas=
 github.com/go-logr/logr v0.2.0 h1:QvGt2nLcHH0WK9orKa+ppBPAxREcH364nPUedEpK0TY=
 github.com/go-logr/logr v0.2.0/go.mod h1:z6/tIYblkpsD+a4lm/fGIIU9mZ+XfAiaFtq7xTgseGU=
@@ -412,7 +411,6 @@ github.com/google/pprof v0.0.0-20201023163331-3e6fc7fc9c4c/go.mod h1:kpwsk12EmLe
 github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.0.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.1.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/google/uuid v1.1.2 h1:EVhdT+1Kseyi1/pUmXKaFxYsDNy9RQYkMWRH68J/W7Y=
 github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.2.0 h1:qJYtXnJRWmpe7m/3XlyhrsLrEURqHRM2kxzoxXqyUDs=
 github.com/google/uuid v1.2.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
@@ -548,7 +546,6 @@ github.com/mattn/go-isatty v0.0.3/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNx
 github.com/mattn/go-isatty v0.0.4/go.mod h1:M+lRXTBqGeGNdLjl/ufCoiOlB5xdOkqRJdNxMWT7Zi4=
 github.com/mattn/go-runewidth v0.0.2/go.mod h1:LwmH8dsx7+W8Uxz3IHJYH5QSwggIsqBzpuz5H//U1FU=
 github.com/mattn/goveralls v0.0.2/go.mod h1:8d1ZMHsd7fW6IRPKQh46F2WRpyib5/X4FOpevwGNQEw=
-github.com/matttproud/golang_protobuf_extensions v1.0.1 h1:4hp9jkHxhMHkqkrB3Ix0jegS5sx/RkqARlsWZ6pIwiU=
 github.com/matttproud/golang_protobuf_extensions v1.0.1/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0=
 github.com/matttproud/golang_protobuf_extensions v1.0.2-0.20181231171920-c182affec369 h1:I0XW9+e1XWDxdcEniV4rQAIOPUGDq67JSCiRCgGCZLI=
 github.com/matttproud/golang_protobuf_extensions v1.0.2-0.20181231171920-c182affec369/go.mod h1:BSXmuO+STAnVfrANrmjBb36TMTDstsz7MSK+HVaYKv4=
@@ -774,7 +771,6 @@ go.opencensus.io v0.22.2/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
 go.opencensus.io v0.22.3/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
 go.opencensus.io v0.22.4-0.20200608061201-1901b56b9515/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
 go.opencensus.io v0.22.4/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=
-go.opencensus.io v0.22.5 h1:dntmOdLpSpHlVqbW5Eay97DelsZHe+55D+xC6i0dDS0=
 go.opencensus.io v0.22.5/go.mod h1:5pWMHQbX5EPX2/62yrJeAkowc+lfs/XD7Uxpq3pI6kk=
 go.opencensus.io v0.22.6 h1:BdkrbWrzDlV9dnbzoP7sfN+dHheJ4J9JOaYxcUDL+ok=
 go.opencensus.io v0.22.6/go.mod h1:XItmlyltB5F7CS4xOC1DcqMoFqwtC6OG2xF7mCv7P7E=
@@ -968,7 +964,6 @@ golang.org/x/sys v0.0.0-20200905004654-be1d3432aa8f/go.mod h1:h1NjWce9XRLGQEsW7w
 golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201112073958-5cba982894dd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20201201145000-ef89a241ccb3 h1:kzM6+9dur93BcC2kVlYl34cHU+TYZLanmpSJHVMmL64=
 golang.org/x/sys v0.0.0-20201201145000-ef89a241ccb3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201214210602-f9fddec55a1e h1:AyodaIpKjppX+cBfTASF2E1US3H2JFBj920Ot3rtDjs=
 golang.org/x/sys v0.0.0-20201214210602-f9fddec55a1e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -1236,7 +1231,6 @@ k8s.io/gengo v0.0.0-20200428234225-8167cfdcfc14 h1:t4L10Qfx/p7ASH3gXCdIUtPbbIueg
 k8s.io/gengo v0.0.0-20200428234225-8167cfdcfc14/go.mod h1:ezvh/TsK7cY6rbqRK0oQQ8IAqLxYwwyPxAX1Pzy0ii0=
 k8s.io/klog v1.0.0 h1:Pt+yjF5aB1xDSVbau4VsWe+dQNzA0qv1LlXdC2dF6Q8=
 k8s.io/klog v1.0.0/go.mod h1:4Bi6QPql/J/LkTDqv7R/cd3hPo4k2DG6Ptcz060Ez5I=
-k8s.io/klog/v2 v2.0.0 h1:Foj74zO6RbjjP4hBEKjnYtjjAhGg4jNynUdYF6fJrok=
 k8s.io/klog/v2 v2.0.0/go.mod h1:PBfzABfn139FHAV07az/IF9Wp1bkk3vpT2XSJ76fSDE=
 k8s.io/klog/v2 v2.2.0 h1:XRvcwJozkgZ1UQJmfMGpvRthQHOvihEhYtDfAaxMz/A=
 k8s.io/klog/v2 v2.2.0/go.mod h1:Od+F08eJP+W3HUb4pSrPpgp9DGU4GzlpG/TmITuYh/Y=
@@ -1244,11 +1238,10 @@ 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.20210303233916-d6d48a74ff55 h1:PvYbC2jLW1tJyhuZmNWAs1oRbE186NRfeRutHIxrpcY=
-knative.dev/eventing v0.21.1-0.20210303233916-d6d48a74ff55/go.mod h1:xx42mnYqB+iEMYny6/M3vbe58BZAo+uLrWbOQF5Qrm0=
+knative.dev/eventing v0.21.1-0.20210304171816-dbf18599e2ef h1:q7svzvw7LwQf7pMAuEYK/eXehS3pCUJadH6uzH4rDDk=
+knative.dev/eventing v0.21.1-0.20210304171816-dbf18599e2ef/go.mod h1:xx42mnYqB+iEMYny6/M3vbe58BZAo+uLrWbOQF5Qrm0=
 knative.dev/hack v0.0.0-20210203173706-8368e1f6eacf h1:u4cY4jr2LYvhoz/1HBWEPsMiLkm0HMdDTfmmw1RE8zE=
 knative.dev/hack v0.0.0-20210203173706-8368e1f6eacf/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
-knative.dev/pkg v0.0.0-20210226182947-9039dc189ced h1:OCtTbXsJhiR35qCDxFj9Xc8sU3i87ePbc7YlHCt0al4=
 knative.dev/pkg v0.0.0-20210226182947-9039dc189ced/go.mod h1:TJSdebQOWX5N2bszohOYVi0H1QtXbtlYLuMghAFBMhY=
 knative.dev/pkg v0.0.0-20210303192215-8fbab7ebb77b h1:AynUh7MBUe44E60vh0vIyF2Bes4AOoTT2ejy9xrF0FU=
 knative.dev/pkg v0.0.0-20210303192215-8fbab7ebb77b/go.mod h1:TJSdebQOWX5N2bszohOYVi0H1QtXbtlYLuMghAFBMhY=
diff --git a/pkg/apis/duck/v1alpha1/zz_generated.deepcopy.go b/pkg/apis/duck/v1alpha1/zz_generated.deepcopy.go
index a5b89327d..448a490ad 100644
--- a/pkg/apis/duck/v1alpha1/zz_generated.deepcopy.go
+++ b/pkg/apis/duck/v1alpha1/zz_generated.deepcopy.go
@@ -21,9 +21,228 @@ limitations under the License.
 package v1alpha1
 
 import (
+	v1 "k8s.io/api/core/v1"
 	runtime "k8s.io/apimachinery/pkg/runtime"
+	v1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
+	apis "knative.dev/pkg/apis"
 )
 
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *Channelable) DeepCopyInto(out *Channelable) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
+	in.Spec.DeepCopyInto(&out.Spec)
+	in.Status.DeepCopyInto(&out.Status)
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Channelable.
+func (in *Channelable) DeepCopy() *Channelable {
+	if in == nil {
+		return nil
+	}
+	out := new(Channelable)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *Channelable) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *ChannelableCombined) DeepCopyInto(out *ChannelableCombined) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
+	in.Spec.DeepCopyInto(&out.Spec)
+	in.Status.DeepCopyInto(&out.Status)
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombined.
+func (in *ChannelableCombined) DeepCopy() *ChannelableCombined {
+	if in == nil {
+		return nil
+	}
+	out := new(ChannelableCombined)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *ChannelableCombined) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *ChannelableCombinedList) DeepCopyInto(out *ChannelableCombinedList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ListMeta.DeepCopyInto(&out.ListMeta)
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]ChannelableCombined, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombinedList.
+func (in *ChannelableCombinedList) DeepCopy() *ChannelableCombinedList {
+	if in == nil {
+		return nil
+	}
+	out := new(ChannelableCombinedList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *ChannelableCombinedList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *ChannelableCombinedSpec) DeepCopyInto(out *ChannelableCombinedSpec) {
+	*out = *in
+	in.SubscribableTypeSpec.DeepCopyInto(&out.SubscribableTypeSpec)
+	in.SubscribableSpec.DeepCopyInto(&out.SubscribableSpec)
+	if in.Delivery != nil {
+		in, out := &in.Delivery, &out.Delivery
+		*out = new(v1beta1.DeliverySpec)
+		(*in).DeepCopyInto(*out)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombinedSpec.
+func (in *ChannelableCombinedSpec) DeepCopy() *ChannelableCombinedSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(ChannelableCombinedSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *ChannelableCombinedStatus) DeepCopyInto(out *ChannelableCombinedStatus) {
+	*out = *in
+	in.Status.DeepCopyInto(&out.Status)
+	in.AddressStatus.DeepCopyInto(&out.AddressStatus)
+	in.SubscribableTypeStatus.DeepCopyInto(&out.SubscribableTypeStatus)
+	in.SubscribableStatus.DeepCopyInto(&out.SubscribableStatus)
+	if in.ErrorChannel != nil {
+		in, out := &in.ErrorChannel, &out.ErrorChannel
+		*out = new(v1.ObjectReference)
+		**out = **in
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombinedStatus.
+func (in *ChannelableCombinedStatus) DeepCopy() *ChannelableCombinedStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(ChannelableCombinedStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *ChannelableList) DeepCopyInto(out *ChannelableList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ListMeta.DeepCopyInto(&out.ListMeta)
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]Channelable, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableList.
+func (in *ChannelableList) DeepCopy() *ChannelableList {
+	if in == nil {
+		return nil
+	}
+	out := new(ChannelableList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *ChannelableList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *ChannelableSpec) DeepCopyInto(out *ChannelableSpec) {
+	*out = *in
+	in.SubscribableTypeSpec.DeepCopyInto(&out.SubscribableTypeSpec)
+	if in.Delivery != nil {
+		in, out := &in.Delivery, &out.Delivery
+		*out = new(v1beta1.DeliverySpec)
+		(*in).DeepCopyInto(*out)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableSpec.
+func (in *ChannelableSpec) DeepCopy() *ChannelableSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(ChannelableSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *ChannelableStatus) DeepCopyInto(out *ChannelableStatus) {
+	*out = *in
+	in.Status.DeepCopyInto(&out.Status)
+	in.AddressStatus.DeepCopyInto(&out.AddressStatus)
+	in.SubscribableTypeStatus.DeepCopyInto(&out.SubscribableTypeStatus)
+	if in.ErrorChannel != nil {
+		in, out := &in.ErrorChannel, &out.ErrorChannel
+		*out = new(v1.ObjectReference)
+		**out = **in
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableStatus.
+func (in *ChannelableStatus) DeepCopy() *ChannelableStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(ChannelableStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
 func (in *Placeable) DeepCopyInto(out *Placeable) {
 	*out = *in
@@ -137,3 +356,186 @@ func (in *Placement) DeepCopy() *Placement {
 	in.DeepCopyInto(out)
 	return out
 }
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *Subscribable) DeepCopyInto(out *Subscribable) {
+	*out = *in
+	if in.Subscribers != nil {
+		in, out := &in.Subscribers, &out.Subscribers
+		*out = make([]SubscriberSpec, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Subscribable.
+func (in *Subscribable) DeepCopy() *Subscribable {
+	if in == nil {
+		return nil
+	}
+	out := new(Subscribable)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *SubscribableStatus) DeepCopyInto(out *SubscribableStatus) {
+	*out = *in
+	if in.Subscribers != nil {
+		in, out := &in.Subscribers, &out.Subscribers
+		*out = make([]v1beta1.SubscriberStatus, len(*in))
+		copy(*out, *in)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableStatus.
+func (in *SubscribableStatus) DeepCopy() *SubscribableStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(SubscribableStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *SubscribableType) DeepCopyInto(out *SubscribableType) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
+	in.Spec.DeepCopyInto(&out.Spec)
+	in.Status.DeepCopyInto(&out.Status)
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableType.
+func (in *SubscribableType) DeepCopy() *SubscribableType {
+	if in == nil {
+		return nil
+	}
+	out := new(SubscribableType)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *SubscribableType) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *SubscribableTypeList) DeepCopyInto(out *SubscribableTypeList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ListMeta.DeepCopyInto(&out.ListMeta)
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]SubscribableType, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableTypeList.
+func (in *SubscribableTypeList) DeepCopy() *SubscribableTypeList {
+	if in == nil {
+		return nil
+	}
+	out := new(SubscribableTypeList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
+func (in *SubscribableTypeList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *SubscribableTypeSpec) DeepCopyInto(out *SubscribableTypeSpec) {
+	*out = *in
+	if in.Subscribable != nil {
+		in, out := &in.Subscribable, &out.Subscribable
+		*out = new(Subscribable)
+		(*in).DeepCopyInto(*out)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableTypeSpec.
+func (in *SubscribableTypeSpec) DeepCopy() *SubscribableTypeSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(SubscribableTypeSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *SubscribableTypeStatus) DeepCopyInto(out *SubscribableTypeStatus) {
+	*out = *in
+	if in.SubscribableStatus != nil {
+		in, out := &in.SubscribableStatus, &out.SubscribableStatus
+		*out = new(SubscribableStatus)
+		(*in).DeepCopyInto(*out)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableTypeStatus.
+func (in *SubscribableTypeStatus) DeepCopy() *SubscribableTypeStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(SubscribableTypeStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
+func (in *SubscriberSpec) DeepCopyInto(out *SubscriberSpec) {
+	*out = *in
+	if in.SubscriberURI != nil {
+		in, out := &in.SubscriberURI, &out.SubscriberURI
+		*out = new(apis.URL)
+		(*in).DeepCopyInto(*out)
+	}
+	if in.ReplyURI != nil {
+		in, out := &in.ReplyURI, &out.ReplyURI
+		*out = new(apis.URL)
+		(*in).DeepCopyInto(*out)
+	}
+	if in.DeadLetterSinkURI != nil {
+		in, out := &in.DeadLetterSinkURI, &out.DeadLetterSinkURI
+		*out = new(apis.URL)
+		(*in).DeepCopyInto(*out)
+	}
+	if in.Delivery != nil {
+		in, out := &in.Delivery, &out.Delivery
+		*out = new(v1beta1.DeliverySpec)
+		(*in).DeepCopyInto(*out)
+	}
+	return
+}
+
+// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriberSpec.
+func (in *SubscriberSpec) DeepCopy() *SubscriberSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(SubscriberSpec)
+	in.DeepCopyInto(out)
+	return out
+}
diff --git a/pkg/apis/messaging/v1alpha1/kafka_channel_conversion.go b/pkg/apis/messaging/v1alpha1/kafka_channel_conversion.go
index b1d43035d..a61f3d3cc 100644
--- a/pkg/apis/messaging/v1alpha1/kafka_channel_conversion.go
+++ b/pkg/apis/messaging/v1alpha1/kafka_channel_conversion.go
@@ -20,9 +20,9 @@ import (
 	"context"
 	"fmt"
 
+	eventingduckv1alpha1 "knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
 	"knative.dev/eventing-kafka/pkg/apis/messaging/v1beta1"
 	eventingduckv1 "knative.dev/eventing/pkg/apis/duck/v1"
-	eventingduckv1alpha1 "knative.dev/eventing/pkg/apis/duck/v1alpha1"
 	eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
 	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
diff --git a/pkg/apis/messaging/v1alpha1/kafka_channel_types.go b/pkg/apis/messaging/v1alpha1/kafka_channel_types.go
index aad7dc62f..d38adf303 100644
--- a/pkg/apis/messaging/v1alpha1/kafka_channel_types.go
+++ b/pkg/apis/messaging/v1alpha1/kafka_channel_types.go
@@ -20,7 +20,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
-	eventingduck "knative.dev/eventing/pkg/apis/duck/v1alpha1"
+	eventingduck "knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
 	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 	duckv1alpha1 "knative.dev/pkg/apis/duck/v1alpha1"
diff --git a/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go b/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go
index fc3e2e04b..530d57c99 100644
--- a/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go
+++ b/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go
@@ -22,7 +22,7 @@ package v1alpha1
 
 import (
 	runtime "k8s.io/apimachinery/pkg/runtime"
-	duckv1alpha1 "knative.dev/eventing/pkg/apis/duck/v1alpha1"
+	duckv1alpha1 "knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
 )
 
 // DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/doc.go b/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/doc.go
deleted file mode 100644
index 5019094b1..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/doc.go
+++ /dev/null
@@ -1,24 +0,0 @@
-/*
-Copyright 2019 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.
-*/
-
-// Api versions allow the api contract for a resource to be changed while keeping
-// backward compatibility by support multiple concurrent versions
-// of the same resource
-
-// Package v1alpha1 is the v1alpha1 version of the API.
-// +k8s:deepcopy-gen=package
-// +groupName=duck.knative.dev
-package v1alpha1
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/register.go b/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/register.go
deleted file mode 100644
index ecd0879b3..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/register.go
+++ /dev/null
@@ -1,46 +0,0 @@
-/*
-Copyright 2020 The Knative Authors
-
-Licensed under the Apache License, Version 2.0 (the "License");
-you may not use this file except in compliance with the License.
-You may obtain a copy of the License at
-
-    http://www.apache.org/licenses/LICENSE-2.0
-
-Unless required by applicable law or agreed to in writing, software
-distributed under the License is distributed on an "AS IS" BASIS,
-WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-See the License for the specific language governing permissions and
-limitations under the License.
-*/
-
-package v1alpha1
-
-import (
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
-	"k8s.io/apimachinery/pkg/runtime/schema"
-)
-
-// SchemeGroupVersion is group version used to register these objects
-var SchemeGroupVersion = schema.GroupVersion{Group: "duck.knative.dev", Version: "v1alpha1"}
-
-// Kind takes an unqualified kind and returns back a Group qualified GroupKind
-func Kind(kind string) schema.GroupKind {
-	return SchemeGroupVersion.WithKind(kind).GroupKind()
-}
-
-var (
-	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
-	AddToScheme   = SchemeBuilder.AddToScheme
-)
-
-// Adds the list of known types to Scheme.
-func addKnownTypes(scheme *runtime.Scheme) error {
-	scheme.AddKnownTypes(SchemeGroupVersion,
-		&Channelable{},
-		&ChannelableList{},
-	)
-	metav1.AddToGroupVersion(scheme, SchemeGroupVersion)
-	return nil
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/resource_types.go b/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/resource_types.go
deleted file mode 100644
index 10f232d49..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/resource_types.go
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
-Copyright 2019 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 (
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/apimachinery/pkg/runtime"
-	"knative.dev/pkg/apis"
-)
-
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-
-// Resource is a skeleton type wrapping all Kubernetes resources. It is typically used to watch
-// arbitrary other resources (such as any Source or Addressable). This is not a real resource.
-type Resource struct {
-	metav1.TypeMeta   `json:",inline"`
-	metav1.ObjectMeta `json:"metadata,omitempty"`
-}
-
-// Ensure Resource satisfies apis.Listable
-var _ apis.Listable = (*Resource)(nil)
-
-// GetListType implements apis.Listable.
-func (*Resource) GetListType() runtime.Object {
-	return &ResourceList{}
-}
-
-// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
-
-// ResourceList is a list of KResource resources
-type ResourceList struct {
-	metav1.TypeMeta `json:",inline"`
-	metav1.ListMeta `json:"metadata"`
-
-	Items []Resource `json:"items"`
-}
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/zz_generated.deepcopy.go b/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/zz_generated.deepcopy.go
deleted file mode 100644
index a584b2140..000000000
--- a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/zz_generated.deepcopy.go
+++ /dev/null
@@ -1,486 +0,0 @@
-// +build !ignore_autogenerated
-
-/*
-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.
-*/
-
-// Code generated by deepcopy-gen. DO NOT EDIT.
-
-package v1alpha1
-
-import (
-	v1 "k8s.io/api/core/v1"
-	runtime "k8s.io/apimachinery/pkg/runtime"
-	v1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
-	apis "knative.dev/pkg/apis"
-)
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *Channelable) DeepCopyInto(out *Channelable) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
-	in.Spec.DeepCopyInto(&out.Spec)
-	in.Status.DeepCopyInto(&out.Status)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Channelable.
-func (in *Channelable) DeepCopy() *Channelable {
-	if in == nil {
-		return nil
-	}
-	out := new(Channelable)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *Channelable) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ChannelableCombined) DeepCopyInto(out *ChannelableCombined) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
-	in.Spec.DeepCopyInto(&out.Spec)
-	in.Status.DeepCopyInto(&out.Status)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombined.
-func (in *ChannelableCombined) DeepCopy() *ChannelableCombined {
-	if in == nil {
-		return nil
-	}
-	out := new(ChannelableCombined)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ChannelableCombined) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ChannelableCombinedList) DeepCopyInto(out *ChannelableCombinedList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]ChannelableCombined, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombinedList.
-func (in *ChannelableCombinedList) DeepCopy() *ChannelableCombinedList {
-	if in == nil {
-		return nil
-	}
-	out := new(ChannelableCombinedList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ChannelableCombinedList) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ChannelableCombinedSpec) DeepCopyInto(out *ChannelableCombinedSpec) {
-	*out = *in
-	in.SubscribableTypeSpec.DeepCopyInto(&out.SubscribableTypeSpec)
-	in.SubscribableSpec.DeepCopyInto(&out.SubscribableSpec)
-	if in.Delivery != nil {
-		in, out := &in.Delivery, &out.Delivery
-		*out = new(v1beta1.DeliverySpec)
-		(*in).DeepCopyInto(*out)
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombinedSpec.
-func (in *ChannelableCombinedSpec) DeepCopy() *ChannelableCombinedSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(ChannelableCombinedSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ChannelableCombinedStatus) DeepCopyInto(out *ChannelableCombinedStatus) {
-	*out = *in
-	in.Status.DeepCopyInto(&out.Status)
-	in.AddressStatus.DeepCopyInto(&out.AddressStatus)
-	in.SubscribableTypeStatus.DeepCopyInto(&out.SubscribableTypeStatus)
-	in.SubscribableStatus.DeepCopyInto(&out.SubscribableStatus)
-	if in.ErrorChannel != nil {
-		in, out := &in.ErrorChannel, &out.ErrorChannel
-		*out = new(v1.ObjectReference)
-		**out = **in
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableCombinedStatus.
-func (in *ChannelableCombinedStatus) DeepCopy() *ChannelableCombinedStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(ChannelableCombinedStatus)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ChannelableList) DeepCopyInto(out *ChannelableList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]Channelable, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableList.
-func (in *ChannelableList) DeepCopy() *ChannelableList {
-	if in == nil {
-		return nil
-	}
-	out := new(ChannelableList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ChannelableList) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ChannelableSpec) DeepCopyInto(out *ChannelableSpec) {
-	*out = *in
-	in.SubscribableTypeSpec.DeepCopyInto(&out.SubscribableTypeSpec)
-	if in.Delivery != nil {
-		in, out := &in.Delivery, &out.Delivery
-		*out = new(v1beta1.DeliverySpec)
-		(*in).DeepCopyInto(*out)
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableSpec.
-func (in *ChannelableSpec) DeepCopy() *ChannelableSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(ChannelableSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ChannelableStatus) DeepCopyInto(out *ChannelableStatus) {
-	*out = *in
-	in.Status.DeepCopyInto(&out.Status)
-	in.AddressStatus.DeepCopyInto(&out.AddressStatus)
-	in.SubscribableTypeStatus.DeepCopyInto(&out.SubscribableTypeStatus)
-	if in.ErrorChannel != nil {
-		in, out := &in.ErrorChannel, &out.ErrorChannel
-		*out = new(v1.ObjectReference)
-		**out = **in
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ChannelableStatus.
-func (in *ChannelableStatus) DeepCopy() *ChannelableStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(ChannelableStatus)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *Resource) DeepCopyInto(out *Resource) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Resource.
-func (in *Resource) DeepCopy() *Resource {
-	if in == nil {
-		return nil
-	}
-	out := new(Resource)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *Resource) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *ResourceList) DeepCopyInto(out *ResourceList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]Resource, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceList.
-func (in *ResourceList) DeepCopy() *ResourceList {
-	if in == nil {
-		return nil
-	}
-	out := new(ResourceList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *ResourceList) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *Subscribable) DeepCopyInto(out *Subscribable) {
-	*out = *in
-	if in.Subscribers != nil {
-		in, out := &in.Subscribers, &out.Subscribers
-		*out = make([]SubscriberSpec, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Subscribable.
-func (in *Subscribable) DeepCopy() *Subscribable {
-	if in == nil {
-		return nil
-	}
-	out := new(Subscribable)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *SubscribableStatus) DeepCopyInto(out *SubscribableStatus) {
-	*out = *in
-	if in.Subscribers != nil {
-		in, out := &in.Subscribers, &out.Subscribers
-		*out = make([]v1beta1.SubscriberStatus, len(*in))
-		copy(*out, *in)
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableStatus.
-func (in *SubscribableStatus) DeepCopy() *SubscribableStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(SubscribableStatus)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *SubscribableType) DeepCopyInto(out *SubscribableType) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
-	in.Spec.DeepCopyInto(&out.Spec)
-	in.Status.DeepCopyInto(&out.Status)
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableType.
-func (in *SubscribableType) DeepCopy() *SubscribableType {
-	if in == nil {
-		return nil
-	}
-	out := new(SubscribableType)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *SubscribableType) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *SubscribableTypeList) DeepCopyInto(out *SubscribableTypeList) {
-	*out = *in
-	out.TypeMeta = in.TypeMeta
-	in.ListMeta.DeepCopyInto(&out.ListMeta)
-	if in.Items != nil {
-		in, out := &in.Items, &out.Items
-		*out = make([]SubscribableType, len(*in))
-		for i := range *in {
-			(*in)[i].DeepCopyInto(&(*out)[i])
-		}
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableTypeList.
-func (in *SubscribableTypeList) DeepCopy() *SubscribableTypeList {
-	if in == nil {
-		return nil
-	}
-	out := new(SubscribableTypeList)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
-func (in *SubscribableTypeList) DeepCopyObject() runtime.Object {
-	if c := in.DeepCopy(); c != nil {
-		return c
-	}
-	return nil
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *SubscribableTypeSpec) DeepCopyInto(out *SubscribableTypeSpec) {
-	*out = *in
-	if in.Subscribable != nil {
-		in, out := &in.Subscribable, &out.Subscribable
-		*out = new(Subscribable)
-		(*in).DeepCopyInto(*out)
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableTypeSpec.
-func (in *SubscribableTypeSpec) DeepCopy() *SubscribableTypeSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(SubscribableTypeSpec)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *SubscribableTypeStatus) DeepCopyInto(out *SubscribableTypeStatus) {
-	*out = *in
-	if in.SubscribableStatus != nil {
-		in, out := &in.SubscribableStatus, &out.SubscribableStatus
-		*out = new(SubscribableStatus)
-		(*in).DeepCopyInto(*out)
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscribableTypeStatus.
-func (in *SubscribableTypeStatus) DeepCopy() *SubscribableTypeStatus {
-	if in == nil {
-		return nil
-	}
-	out := new(SubscribableTypeStatus)
-	in.DeepCopyInto(out)
-	return out
-}
-
-// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
-func (in *SubscriberSpec) DeepCopyInto(out *SubscriberSpec) {
-	*out = *in
-	if in.SubscriberURI != nil {
-		in, out := &in.SubscriberURI, &out.SubscriberURI
-		*out = new(apis.URL)
-		(*in).DeepCopyInto(*out)
-	}
-	if in.ReplyURI != nil {
-		in, out := &in.ReplyURI, &out.ReplyURI
-		*out = new(apis.URL)
-		(*in).DeepCopyInto(*out)
-	}
-	if in.DeadLetterSinkURI != nil {
-		in, out := &in.DeadLetterSinkURI, &out.DeadLetterSinkURI
-		*out = new(apis.URL)
-		(*in).DeepCopyInto(*out)
-	}
-	if in.Delivery != nil {
-		in, out := &in.Delivery, &out.Delivery
-		*out = new(v1beta1.DeliverySpec)
-		(*in).DeepCopyInto(*out)
-	}
-	return
-}
-
-// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SubscriberSpec.
-func (in *SubscriberSpec) DeepCopy() *SubscriberSpec {
-	if in == nil {
-		return nil
-	}
-	out := new(SubscriberSpec)
-	in.DeepCopyInto(out)
-	return out
-}
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 0408d6f34..0e8ae9a58 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -1080,7 +1080,7 @@ k8s.io/utils/buffer
 k8s.io/utils/integer
 k8s.io/utils/pointer
 k8s.io/utils/trace
-# knative.dev/eventing v0.21.1-0.20210303233916-d6d48a74ff55
+# knative.dev/eventing v0.21.1-0.20210304171816-dbf18599e2ef
 ## explicit
 knative.dev/eventing/pkg/adapter/v2
 knative.dev/eventing/pkg/adapter/v2/test
@@ -1090,7 +1090,6 @@ knative.dev/eventing/pkg/apis/configs
 knative.dev/eventing/pkg/apis/configs/v1alpha1
 knative.dev/eventing/pkg/apis/duck
 knative.dev/eventing/pkg/apis/duck/v1
-knative.dev/eventing/pkg/apis/duck/v1alpha1
 knative.dev/eventing/pkg/apis/duck/v1beta1
 knative.dev/eventing/pkg/apis/eventing
 knative.dev/eventing/pkg/apis/eventing/v1


Test patch:
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/channelable_combined_types.go b/pkg/apis/duck/v1alpha1/channelable_combined_types.go
similarity index 100%
rename from vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/channelable_combined_types.go
rename to pkg/apis/duck/v1alpha1/channelable_combined_types.go
diff --git a/pkg/apis/duck/v1alpha1/channelable_combined_types_test.go b/pkg/apis/duck/v1alpha1/channelable_combined_types_test.go
new file mode 100644
index 000000000..e74dd26d1
--- /dev/null
+++ b/pkg/apis/duck/v1alpha1/channelable_combined_types_test.go
@@ -0,0 +1,145 @@
+/*
+Copyright 2020 The Knative Authors
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	"testing"
+
+	corev1 "k8s.io/api/core/v1"
+	eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
+	"knative.dev/pkg/apis"
+	duckv1 "knative.dev/pkg/apis/duck/v1"
+	"knative.dev/pkg/apis/duck/v1alpha1"
+	duckv1beta1 "knative.dev/pkg/apis/duck/v1beta1"
+
+	"github.com/google/go-cmp/cmp"
+)
+
+func TestChannelableCombinedGetListType(t *testing.T) {
+	c := &ChannelableCombined{}
+	switch c.GetListType().(type) {
+	case *ChannelableCombinedList:
+		// expected
+	default:
+		t.Errorf("expected GetListType to return *ChannelableCombinedList, got %T", c.GetListType())
+	}
+}
+
+func TestChannelableCombinedPopulate(t *testing.T) {
+	got := &ChannelableCombined{}
+
+	retry := int32(5)
+	linear := eventingduckv1beta1.BackoffPolicyLinear
+	delay := "5s"
+	want := &ChannelableCombined{
+		Spec: ChannelableCombinedSpec{
+			SubscribableSpec: eventingduckv1beta1.SubscribableSpec{
+				// Populate ALL fields
+				Subscribers: []eventingduckv1beta1.SubscriberSpec{{
+					UID:           "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+					Generation:    1,
+					SubscriberURI: apis.HTTP("call1"),
+					ReplyURI:      apis.HTTP("sink2"),
+				}, {
+					UID:           "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+					Generation:    2,
+					SubscriberURI: apis.HTTP("call2"),
+					ReplyURI:      apis.HTTP("sink2"),
+				}},
+			},
+			SubscribableTypeSpec: SubscribableTypeSpec{
+				Subscribable: &Subscribable{
+					Subscribers: []SubscriberSpec{{
+						UID:           "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+						Generation:    1,
+						SubscriberURI: apis.HTTP("call1"),
+						ReplyURI:      apis.HTTP("sink2"),
+					}, {
+						UID:           "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+						Generation:    2,
+						SubscriberURI: apis.HTTP("call2"),
+						ReplyURI:      apis.HTTP("sink2"),
+					}},
+				},
+			},
+			Delivery: &eventingduckv1beta1.DeliverySpec{
+				DeadLetterSink: &duckv1.Destination{
+					Ref: &duckv1.KReference{
+						Name: "aname",
+					},
+					URI: &apis.URL{
+						Scheme: "http",
+						Host:   "test-error-domain",
+					},
+				},
+				Retry:         &retry,
+				BackoffPolicy: &linear,
+				BackoffDelay:  &delay,
+			},
+		},
+
+		Status: ChannelableCombinedStatus{
+			AddressStatus: v1alpha1.AddressStatus{
+				Address: &v1alpha1.Addressable{
+					// Populate ALL fields
+					Addressable: duckv1beta1.Addressable{
+						URL: &apis.URL{
+							Scheme: "http",
+							Host:   "test-domain",
+						},
+					},
+					Hostname: "test-domain",
+				},
+			},
+			SubscribableStatus: eventingduckv1beta1.SubscribableStatus{
+				Subscribers: []eventingduckv1beta1.SubscriberStatus{{
+					UID:                "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+					ObservedGeneration: 1,
+					Ready:              corev1.ConditionTrue,
+					Message:            "Some message",
+				}, {
+					UID:                "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+					ObservedGeneration: 2,
+					Ready:              corev1.ConditionFalse,
+					Message:            "Some message",
+				}},
+			},
+			SubscribableTypeStatus: SubscribableTypeStatus{
+				SubscribableStatus: &SubscribableStatus{
+					Subscribers: []eventingduckv1beta1.SubscriberStatus{{
+						UID:                "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+						ObservedGeneration: 1,
+						Ready:              corev1.ConditionTrue,
+						Message:            "Some message",
+					}, {
+						UID:                "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+						ObservedGeneration: 2,
+						Ready:              corev1.ConditionFalse,
+						Message:            "Some message",
+					}},
+				},
+			},
+		},
+	}
+
+	got.Populate()
+
+	if diff := cmp.Diff(want, got); diff != "" {
+		t.Error("Unexpected difference (-want, +got):", diff)
+	}
+
+}
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/channelable_types.go b/pkg/apis/duck/v1alpha1/channelable_types.go
similarity index 100%
rename from vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/channelable_types.go
rename to pkg/apis/duck/v1alpha1/channelable_types.go
diff --git a/pkg/apis/duck/v1alpha1/channelable_types_test.go b/pkg/apis/duck/v1alpha1/channelable_types_test.go
new file mode 100644
index 000000000..fd781c16f
--- /dev/null
+++ b/pkg/apis/duck/v1alpha1/channelable_types_test.go
@@ -0,0 +1,118 @@
+/*
+Copyright 2019 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 (
+	"testing"
+
+	corev1 "k8s.io/api/core/v1"
+	eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
+	"knative.dev/pkg/apis"
+	duckv1 "knative.dev/pkg/apis/duck/v1"
+	"knative.dev/pkg/apis/duck/v1alpha1"
+	duckv1beta1 "knative.dev/pkg/apis/duck/v1beta1"
+
+	"github.com/google/go-cmp/cmp"
+)
+
+func TestChannelableGetListType(t *testing.T) {
+	c := &Channelable{}
+	switch c.GetListType().(type) {
+	case *ChannelableList:
+		// expected
+	default:
+		t.Errorf("expected GetListType to return *ChannelableList, got %T", c.GetListType())
+	}
+}
+
+func TestChannelablePopulate(t *testing.T) {
+	got := &Channelable{}
+
+	retry := int32(5)
+	linear := eventingduckv1beta1.BackoffPolicyLinear
+	delay := "5s"
+	want := &Channelable{
+		Spec: ChannelableSpec{
+			SubscribableTypeSpec: SubscribableTypeSpec{
+				Subscribable: &Subscribable{
+					Subscribers: []SubscriberSpec{{
+						UID:           "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+						Generation:    1,
+						SubscriberURI: apis.HTTP("call1"),
+						ReplyURI:      apis.HTTP("sink2"),
+					}, {
+						UID:           "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+						Generation:    2,
+						SubscriberURI: apis.HTTP("call2"),
+						ReplyURI:      apis.HTTP("sink2"),
+					}},
+				},
+			},
+			Delivery: &eventingduckv1beta1.DeliverySpec{
+				DeadLetterSink: &duckv1.Destination{
+					Ref: &duckv1.KReference{
+						Name: "aname",
+					},
+					URI: &apis.URL{
+						Scheme: "http",
+						Host:   "test-error-domain",
+					},
+				},
+				Retry:         &retry,
+				BackoffPolicy: &linear,
+				BackoffDelay:  &delay,
+			},
+		},
+
+		Status: ChannelableStatus{
+			AddressStatus: v1alpha1.AddressStatus{
+				Address: &v1alpha1.Addressable{
+					// Populate ALL fields
+					Addressable: duckv1beta1.Addressable{
+						URL: &apis.URL{
+							Scheme: "http",
+							Host:   "test-domain",
+						},
+					},
+					Hostname: "test-domain",
+				},
+			},
+			SubscribableTypeStatus: SubscribableTypeStatus{
+				SubscribableStatus: &SubscribableStatus{
+					Subscribers: []eventingduckv1beta1.SubscriberStatus{{
+						UID:                "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+						ObservedGeneration: 1,
+						Ready:              corev1.ConditionTrue,
+						Message:            "Some message",
+					}, {
+						UID:                "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+						ObservedGeneration: 2,
+						Ready:              corev1.ConditionFalse,
+						Message:            "Some message",
+					}},
+				},
+			},
+		},
+	}
+
+	got.Populate()
+
+	if diff := cmp.Diff(want, got); diff != "" {
+		t.Error("Unexpected difference (-want, +got):", diff)
+	}
+
+}
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/subscribable_types.go b/pkg/apis/duck/v1alpha1/subscribable_types.go
similarity index 100%
rename from vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/subscribable_types.go
rename to pkg/apis/duck/v1alpha1/subscribable_types.go
diff --git a/vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/subscribable_types_conversion.go b/pkg/apis/duck/v1alpha1/subscribable_types_conversion.go
similarity index 100%
rename from vendor/knative.dev/eventing/pkg/apis/duck/v1alpha1/subscribable_types_conversion.go
rename to pkg/apis/duck/v1alpha1/subscribable_types_conversion.go
diff --git a/pkg/apis/duck/v1alpha1/subscribable_types_conversion_test.go b/pkg/apis/duck/v1alpha1/subscribable_types_conversion_test.go
new file mode 100644
index 000000000..883f12a79
--- /dev/null
+++ b/pkg/apis/duck/v1alpha1/subscribable_types_conversion_test.go
@@ -0,0 +1,463 @@
+/*
+Copyright 2020 The Knative Authors
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	"context"
+	"testing"
+
+	"github.com/google/go-cmp/cmp"
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/utils/pointer"
+	"knative.dev/pkg/apis"
+	pkgduckv1 "knative.dev/pkg/apis/duck/v1"
+
+	v1 "knative.dev/eventing/pkg/apis/duck/v1"
+	"knative.dev/eventing/pkg/apis/duck/v1beta1"
+)
+
+func TestSubscribableTypeConversionBadType(t *testing.T) {
+	good, bad := &SubscribableType{}, &pkgduckv1.Addressable{}
+
+	if err := good.ConvertTo(context.Background(), bad); err == nil {
+		t.Errorf("ConvertTo() = %#v, wanted error", bad)
+	}
+
+	if err := good.ConvertFrom(context.Background(), bad); err == nil {
+		t.Errorf("ConvertFrom() = %#v, wanted error", good)
+	}
+}
+
+// Test v1alpha1 -> v1beta1 -> v1alpha1
+func TestSubscribableTypeConversionV1alphaV1beta1(t *testing.T) {
+	// Just one for now, just adding the for loop for ease of future changes.
+	versions := []apis.Convertible{&v1beta1.Subscribable{}}
+
+	linear := v1beta1.BackoffPolicyLinear
+
+	tests := []struct {
+		name string
+		in   *SubscribableType
+	}{{
+		name: "min configuration",
+		in: &SubscribableType{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec:   SubscribableTypeSpec{},
+			Status: SubscribableTypeStatus{},
+		},
+	}, {
+		name: "full configuration",
+		in: &SubscribableType{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec: SubscribableTypeSpec{
+				Subscribable: &Subscribable{
+					Subscribers: []SubscriberSpec{
+						{
+							UID:               "uid-1",
+							Generation:        7,
+							SubscriberURI:     apis.HTTP("subscriber.example.com"),
+							ReplyURI:          apis.HTTP("reply.example.com"),
+							DeadLetterSinkURI: apis.HTTP("subscriber.dls.example.com"),
+							Delivery: &v1beta1.DeliverySpec{
+								DeadLetterSink: &pkgduckv1.Destination{
+									Ref: &pkgduckv1.KReference{
+										Kind:       "dlKind",
+										Namespace:  "dlNamespace",
+										Name:       "dlName",
+										APIVersion: "dlAPIVersion",
+									},
+									URI: apis.HTTP("subscriber.dls.example.com"),
+								},
+								Retry:         pointer.Int32Ptr(5),
+								BackoffPolicy: &linear,
+								BackoffDelay:  pointer.StringPtr("5s"),
+							},
+						},
+						{
+							UID:               "uid-2",
+							Generation:        8,
+							SubscriberURI:     apis.HTTP("subscriber2.example.com"),
+							ReplyURI:          apis.HTTP("reply2.example.com"),
+							DeadLetterSinkURI: apis.HTTP("subscriber2.dls.example.com"),
+							Delivery:          nil,
+						},
+					},
+				},
+			},
+			Status: SubscribableTypeStatus{
+				SubscribableStatus: &SubscribableStatus{
+					Subscribers: []v1beta1.SubscriberStatus{
+						{
+							UID:                "status-uid-1",
+							ObservedGeneration: 99,
+							Ready:              corev1.ConditionTrue,
+							Message:            "msg",
+						},
+					},
+				},
+			},
+		},
+	}}
+	for _, test := range tests {
+		for _, version := range versions {
+			t.Run(test.name, func(t *testing.T) {
+				ver := version
+				if err := test.in.ConvertTo(context.Background(), ver); err != nil {
+					t.Error("ConvertTo() =", err)
+				}
+				got := &SubscribableType{}
+				if err := got.ConvertFrom(context.Background(), ver); err != nil {
+					t.Error("ConvertFrom() =", err)
+				}
+
+				fixed := fixSubscribableTypeDeprecated(test.in)
+				if diff := cmp.Diff(fixed, got); diff != "" {
+					t.Error("roundtrip (-want, +got) =", diff)
+				}
+			})
+		}
+	}
+}
+
+// Test v1alpha1 -> v1 -> v1alpha1
+func TestSubscribableTypeConversionV1alphaV1(t *testing.T) {
+	// Just one for now, just adding the for loop for ease of future changes.
+	versions := []apis.Convertible{&v1.Subscribable{}}
+
+	linear := v1beta1.BackoffPolicyLinear
+
+	tests := []struct {
+		name string
+		in   *SubscribableType
+	}{{
+		name: "min configuration",
+		in: &SubscribableType{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec:   SubscribableTypeSpec{},
+			Status: SubscribableTypeStatus{},
+		},
+	}, {
+		name: "full configuration",
+		in: &SubscribableType{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec: SubscribableTypeSpec{
+				Subscribable: &Subscribable{
+					Subscribers: []SubscriberSpec{
+						{
+							UID:               "uid-1",
+							Generation:        7,
+							SubscriberURI:     apis.HTTP("subscriber.example.com"),
+							ReplyURI:          apis.HTTP("reply.example.com"),
+							DeadLetterSinkURI: apis.HTTP("subscriber.dls.example.com"),
+							Delivery: &v1beta1.DeliverySpec{
+								DeadLetterSink: &pkgduckv1.Destination{
+									Ref: &pkgduckv1.KReference{
+										Kind:       "dlKind",
+										Namespace:  "dlNamespace",
+										Name:       "dlName",
+										APIVersion: "dlAPIVersion",
+									},
+									URI: apis.HTTP("subscriber.dls.example.com"),
+								},
+								Retry:         pointer.Int32Ptr(5),
+								BackoffPolicy: &linear,
+								BackoffDelay:  pointer.StringPtr("5s"),
+							},
+						},
+						{
+							UID:               "uid-2",
+							Generation:        8,
+							SubscriberURI:     apis.HTTP("subscriber2.example.com"),
+							ReplyURI:          apis.HTTP("reply2.example.com"),
+							DeadLetterSinkURI: apis.HTTP("subscriber2.dls.example.com"),
+							Delivery:          nil,
+						},
+					},
+				},
+			},
+			Status: SubscribableTypeStatus{
+				SubscribableStatus: &SubscribableStatus{
+					Subscribers: []v1beta1.SubscriberStatus{
+						{
+							UID:                "status-uid-1",
+							ObservedGeneration: 99,
+							Ready:              corev1.ConditionTrue,
+							Message:            "msg",
+						},
+					},
+				},
+			},
+		},
+	}}
+	for _, test := range tests {
+		for _, version := range versions {
+			t.Run(test.name, func(t *testing.T) {
+				ver := version
+				if err := test.in.ConvertTo(context.Background(), ver); err != nil {
+					t.Error("ConvertTo() =", err)
+				}
+				got := &SubscribableType{}
+				if err := got.ConvertFrom(context.Background(), ver); err != nil {
+					t.Error("ConvertFrom() =", err)
+				}
+
+				fixed := fixSubscribableTypeDeprecated(test.in)
+				if diff := cmp.Diff(fixed, got); diff != "" {
+					t.Error("roundtrip (-want, +got) =", diff)
+				}
+			})
+		}
+	}
+}
+
+// Test v1beta1 -> v1alpha1 -> v1beta1
+func TestSubscribableTypeConversionWithV1beta1V1alpha1(t *testing.T) {
+	// Just one for now, just adding the for loop for ease of future changes.
+	versions := []apis.Convertible{&SubscribableType{}}
+
+	linear := v1beta1.BackoffPolicyLinear
+
+	tests := []struct {
+		name string
+		in   *v1beta1.Subscribable
+	}{{
+		name: "min",
+		in: &v1beta1.Subscribable{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec:   v1beta1.SubscribableSpec{},
+			Status: v1beta1.SubscribableStatus{},
+		},
+	}, {
+		name: "full configuration",
+		in: &v1beta1.Subscribable{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec: v1beta1.SubscribableSpec{
+				Subscribers: []v1beta1.SubscriberSpec{
+					{
+						UID:           "uid-1",
+						Generation:    7,
+						SubscriberURI: apis.HTTP("subscriber.example.com"),
+						ReplyURI:      apis.HTTP("reply.example.com"),
+						Delivery: &v1beta1.DeliverySpec{
+							DeadLetterSink: &pkgduckv1.Destination{
+								Ref: &pkgduckv1.KReference{
+									Kind:       "dlKind",
+									Namespace:  "dlNamespace",
+									Name:       "dlName",
+									APIVersion: "dlAPIVersion",
+								},
+								URI: apis.HTTP("subscriber.dls.example.com"),
+							},
+							Retry:         pointer.Int32Ptr(5),
+							BackoffPolicy: &linear,
+							BackoffDelay:  pointer.StringPtr("5s"),
+						},
+					},
+				},
+			},
+			Status: v1beta1.SubscribableStatus{
+				Subscribers: []v1beta1.SubscriberStatus{
+					{
+						UID:                "status-uid-1",
+						ObservedGeneration: 99,
+						Ready:              corev1.ConditionTrue,
+						Message:            "msg",
+					},
+				},
+			},
+		},
+	}}
+	for _, test := range tests {
+		for _, version := range versions {
+			t.Run(test.name, func(t *testing.T) {
+				ver := version
+				if err := version.ConvertFrom(context.Background(), test.in); err != nil {
+					t.Error("ConvertTo() =", err)
+				}
+				got := &v1beta1.Subscribable{}
+				if err := ver.ConvertTo(context.Background(), got); err != nil {
+					t.Error("ConvertFrom() =", err)
+				}
+				if diff := cmp.Diff(test.in, got); diff != "" {
+					t.Error("roundtrip (-want, +got) =", diff)
+				}
+			})
+		}
+	}
+}
+
+// Test v1 -> v1alpha1 -> v1
+func TestSubscribableTypeConversionWithV1V1alpha1(t *testing.T) {
+	// Just one for now, just adding the for loop for ease of future changes.
+	versions := []apis.Convertible{&SubscribableType{}}
+
+	linear := v1.BackoffPolicyLinear
+
+	tests := []struct {
+		name string
+		in   *v1.Subscribable
+	}{{
+		name: "min",
+		in: &v1.Subscribable{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec:   v1.SubscribableSpec{},
+			Status: v1.SubscribableStatus{},
+		},
+	}, {
+		name: "full configuration",
+		in: &v1.Subscribable{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:       "subscribable-name",
+				Namespace:  "subscribable-ns",
+				Generation: 17,
+			},
+			Spec: v1.SubscribableSpec{
+				Subscribers: []v1.SubscriberSpec{
+					{
+						UID:           "uid-1",
+						Generation:    7,
+						SubscriberURI: apis.HTTP("subscriber.example.com"),
+						ReplyURI:      apis.HTTP("reply.example.com"),
+						Delivery: &v1.DeliverySpec{
+							DeadLetterSink: &pkgduckv1.Destination{
+								Ref: &pkgduckv1.KReference{
+									Kind:       "dlKind",
+									Namespace:  "dlNamespace",
+									Name:       "dlName",
+									APIVersion: "dlAPIVersion",
+								},
+								URI: apis.HTTP("subscriber.dls.example.com"),
+							},
+							Retry:         pointer.Int32Ptr(5),
+							BackoffPolicy: &linear,
+							BackoffDelay:  pointer.StringPtr("5s"),
+						},
+					},
+				},
+			},
+			Status: v1.SubscribableStatus{
+				Subscribers: []v1.SubscriberStatus{
+					{
+						UID:                "status-uid-1",
+						ObservedGeneration: 99,
+						Ready:              corev1.ConditionTrue,
+						Message:            "msg",
+					},
+				},
+			},
+		},
+	}}
+	for _, test := range tests {
+		for _, version := range versions {
+			t.Run(test.name, func(t *testing.T) {
+				ver := version
+				if err := version.ConvertFrom(context.Background(), test.in); err != nil {
+					t.Error("ConvertTo() =", err)
+				}
+				got := &v1.Subscribable{}
+				if err := ver.ConvertTo(context.Background(), got); err != nil {
+					t.Error("ConvertFrom() =", err)
+				}
+				if diff := cmp.Diff(test.in, got); diff != "" {
+					t.Error("roundtrip (-want, +got) =", diff)
+				}
+			})
+		}
+	}
+}
+
+func TestSubscribableTypeSpecConversionBadType(t *testing.T) {
+	good, bad := &SubscribableTypeSpec{}, &SubscribableTypeSpec{}
+
+	if err := good.ConvertTo(context.Background(), bad); err == nil {
+		t.Errorf("ConvertTo() = %#v, wanted error", bad)
+	}
+
+	if err := good.ConvertFrom(context.Background(), bad); err == nil {
+		t.Errorf("ConvertFrom() = %#v, wanted error", good)
+	}
+}
+
+func TestSubscribableTypeStatusConversionBadType(t *testing.T) {
+	good, bad := &SubscribableTypeStatus{}, &SubscribableTypeStatus{}
+
+	if err := good.ConvertTo(context.Background(), bad); err == nil {
+		t.Errorf("ConvertTo() = %#v, wanted error", bad)
+	}
+
+	if err := good.ConvertFrom(context.Background(), bad); err == nil {
+		t.Errorf("ConvertFrom() = %#v, wanted error", good)
+	}
+}
+
+func TestSubscriberSpecConversionBadType(t *testing.T) {
+	good, bad := &SubscriberSpec{}, &SubscriberSpec{}
+
+	if err := good.ConvertTo(context.Background(), bad); err == nil {
+		t.Errorf("ConvertTo() = %#v, wanted error", bad)
+	}
+
+	if err := good.ConvertFrom(context.Background(), bad); err == nil {
+		t.Errorf("ConvertFrom() = %#v, wanted error", good)
+	}
+}
+
+// Since v1beta1 to v1alpha1 is lossy.
+func fixSubscribableTypeDeprecated(in *SubscribableType) *SubscribableType {
+	if in.Spec.Subscribable != nil && len(in.Spec.Subscribable.Subscribers) > 0 {
+		for i := range in.Spec.Subscribable.Subscribers {
+			if in.Spec.Subscribable.Subscribers[i].Delivery == nil {
+				in.Spec.Subscribable.Subscribers[i].Delivery = &v1beta1.DeliverySpec{
+					DeadLetterSink: &pkgduckv1.Destination{
+						URI: in.Spec.Subscribable.Subscribers[i].DeadLetterSinkURI,
+					},
+				}
+			}
+		}
+	}
+
+	return in
+}
diff --git a/pkg/apis/duck/v1alpha1/subscribable_types_test.go b/pkg/apis/duck/v1alpha1/subscribable_types_test.go
new file mode 100644
index 000000000..078f80bfb
--- /dev/null
+++ b/pkg/apis/duck/v1alpha1/subscribable_types_test.go
@@ -0,0 +1,141 @@
+/*
+Copyright 2019 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 (
+	"testing"
+
+	"github.com/google/go-cmp/cmp"
+	corev1 "k8s.io/api/core/v1"
+	eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
+	"knative.dev/pkg/apis"
+)
+
+func TestSubscribableGetFullType(t *testing.T) {
+	s := &Subscribable{}
+	switch s.GetFullType().(type) {
+	case *SubscribableType:
+		// expected
+	default:
+		t.Errorf("expected GetFullType to return *SubscribableType, got %T", s.GetFullType())
+	}
+}
+
+func TestSubscribableGetListType(t *testing.T) {
+	c := &SubscribableType{}
+	switch c.GetListType().(type) {
+	case *SubscribableTypeList:
+		// expected
+	default:
+		t.Errorf("expected GetListType to return *SubscribableTypeList, got %T", c.GetListType())
+	}
+}
+
+func TestSubscribablePopulate(t *testing.T) {
+	got := &SubscribableType{}
+
+	want := &SubscribableType{
+		Spec: SubscribableTypeSpec{
+			Subscribable: &Subscribable{
+				Subscribers: []SubscriberSpec{{
+					UID:           "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+					Generation:    1,
+					SubscriberURI: apis.HTTP("call1"),
+					ReplyURI:      apis.HTTP("sink2"),
+				}, {
+					UID:           "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+					Generation:    2,
+					SubscriberURI: apis.HTTP("call2"),
+					ReplyURI:      apis.HTTP("sink2"),
+				}},
+			},
+		},
+		Status: SubscribableTypeStatus{
+			SubscribableStatus: &SubscribableStatus{
+				// Populate ALL fields
+				Subscribers: []eventingduckv1beta1.SubscriberStatus{{
+					UID:                "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+					ObservedGeneration: 1,
+					Ready:              corev1.ConditionTrue,
+					Message:            "Some message",
+				}, {
+					UID:                "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+					ObservedGeneration: 2,
+					Ready:              corev1.ConditionFalse,
+					Message:            "Some message",
+				}},
+			},
+		},
+	}
+
+	got.Populate()
+
+	if diff := cmp.Diff(want, got); diff != "" {
+		t.Error("Unexpected difference (-want, +got):", diff)
+	}
+
+}
+
+func TestSubscribableTypeStatusHelperMethods(t *testing.T) {
+	s := &SubscribableStatus{
+		// Populate ALL fields
+		Subscribers: []eventingduckv1beta1.SubscriberStatus{{
+			UID:                "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+			ObservedGeneration: 1,
+			Ready:              corev1.ConditionTrue,
+			Message:            "This is new field",
+		}, {
+			UID:                "34c5aec8-deb6-11e8-9f32-f2801f1b9fd1",
+			ObservedGeneration: 2,
+			Ready:              corev1.ConditionFalse,
+			Message:            "This is new field",
+		}},
+	}
+
+	subscribableTypeStatus := SubscribableTypeStatus{
+		SubscribableStatus: s,
+	}
+
+	/* Test GetSubscribableTypeStatus */
+
+	// Should return SubscribableTypeStatus#SubscribableStatus
+	subscribableStatus := subscribableTypeStatus.GetSubscribableTypeStatus()
+	if subscribableStatus.Subscribers[0].Message != "This is new field" {
+		t.Error("Testing of GetSubscribableTypeStatus failed as the function returned something unexpected")
+	}
+
+	/* Test SetSubscribableTypeStatus */
+
+	// This should set both the fields to same value
+	subscribableTypeStatus.SetSubscribableTypeStatus(*s)
+	if subscribableTypeStatus.SubscribableStatus.Subscribers[0].Message != "This is new field" {
+		t.Error("SetSubscribableTypeStatus didn't work as expected")
+	}
+
+	/* Test AddSubscriberToSubscribableStatus */
+	subscribableTypeStatus.AddSubscriberToSubscribableStatus(eventingduckv1beta1.SubscriberStatus{
+		UID:                "2f9b5e8e-deb6-11e8-9f32-f2801f1b9fd1",
+		ObservedGeneration: 1,
+		Ready:              corev1.ConditionTrue,
+		Message:            "This is new field",
+	})
+
+	// Check if the subscriber was added to both the fields of SubscribableTypeStatus
+	if len(subscribableTypeStatus.SubscribableStatus.Subscribers) != 3 {
+		t.Error("AddSubscriberToSubscribableStatus didn't add subscriberstatus to both the fields of SubscribableTypeStatus")
+	}
+}
diff --git a/pkg/apis/messaging/v1alpha1/kafka_channel_conversion_test.go b/pkg/apis/messaging/v1alpha1/kafka_channel_conversion_test.go
index b34cad884..a8074838b 100644
--- a/pkg/apis/messaging/v1alpha1/kafka_channel_conversion_test.go
+++ b/pkg/apis/messaging/v1alpha1/kafka_channel_conversion_test.go
@@ -27,9 +27,9 @@ import (
 	"github.com/google/go-cmp/cmp"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/utils/pointer"
+	eventingduckv1alpha1 "knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
 	"knative.dev/eventing-kafka/pkg/apis/messaging/v1beta1"
 	eventingduckv1 "knative.dev/eventing/pkg/apis/duck/v1"
-	eventingduckv1alpha1 "knative.dev/eventing/pkg/apis/duck/v1alpha1"
 	eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
 	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
diff --git a/pkg/apis/messaging/v1alpha1/kafka_channel_validation_test.go b/pkg/apis/messaging/v1alpha1/kafka_channel_validation_test.go
index 36592b5a8..87a1756de 100644
--- a/pkg/apis/messaging/v1alpha1/kafka_channel_validation_test.go
+++ b/pkg/apis/messaging/v1alpha1/kafka_channel_validation_test.go
@@ -24,7 +24,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"knative.dev/pkg/webhook/resourcesemantics"
 
-	eventingduck "knative.dev/eventing/pkg/apis/duck/v1alpha1"
+	eventingduck "knative.dev/eventing-kafka/pkg/apis/duck/v1alpha1"
 	"knative.dev/eventing/pkg/apis/eventing"
 	"knative.dev/pkg/apis"
 )
diff --git a/test/e2e-common.sh b/test/e2e-common.sh
index 0f0d5719a..1e4678167 100755
--- a/test/e2e-common.sh
+++ b/test/e2e-common.sh
@@ -400,7 +400,7 @@ function test_consolidated_channel_plain() {
   install_consolidated_channel_crds || return 1
   install_consolidated_sources_crds || return 1
 
-  go_test_e2e -tags=e2e,source -timeout=40m -test.parallel=${TEST_PARALLEL} ./test/e2e -channels=messaging.knative.dev/v1alpha1:KafkaChannel,messaging.knative.dev/v1beta1:KafkaChannel  || fail_test
+  go_test_e2e -tags=e2e,source -timeout=40m -test.parallel=${TEST_PARALLEL} ./test/e2e -channels=messaging.knative.dev/v1beta1:KafkaChannel  || fail_test
   go_test_e2e -tags=e2e,source -timeout=5m -test.parallel=${TEST_PARALLEL} ./test/conformance -channels=messaging.knative.dev/v1beta1:KafkaChannel -sources=sources.knative.dev/v1beta1:KafkaSource || fail_test
 
   uninstall_sources_crds || return 1
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go
index 973e0641a..232ab632a 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/listers.go
@@ -20,7 +20,9 @@ import (
 	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
 	rbacv1 "k8s.io/api/rbac/v1"
+	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	fakeapiextensionsclientset "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake"
+	apiextensionsv1listers "k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
@@ -189,3 +191,7 @@ func (l *Listers) GetEndpointsLister() corev1listers.EndpointsLister {
 func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister {
 	return corev1listers.NewConfigMapLister(l.indexerFor(&corev1.ConfigMap{}))
 }
+
+func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1listers.CustomResourceDefinitionLister {
+	return apiextensionsv1listers.NewCustomResourceDefinitionLister(l.indexerFor(&apiextensionsv1.CustomResourceDefinition{}))
+}
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/channelable.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/channelable.go
index 3eda0f675..e4e1858e8 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/channelable.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/channelable.go
@@ -20,28 +20,25 @@ import (
 
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"knative.dev/eventing/pkg/apis/duck/v1alpha1"
-	duckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
+	duckv1 "knative.dev/eventing/pkg/apis/duck/v1"
 	"knative.dev/eventing/pkg/apis/messaging"
 	"knative.dev/pkg/apis"
-	pkgduckv1alpha1 "knative.dev/pkg/apis/duck/v1alpha1"
-	pkgduckv1beta1 "knative.dev/pkg/apis/duck/v1beta1"
 )
 
 // Channelable allows us to have a fake channel for testing that implements a v1alpha1.Channelable type.
 
 // ChannelableOption enables further configuration of a v1alpha1.Channelable.
-type ChannelableOption func(*v1alpha1.Channelable)
+type ChannelableOption func(*duckv1.Channelable)
 
 // NewChannelable creates an Channelable with ChannelableOptions.
-func NewChannelable(name, namespace string, imcopt ...ChannelableOption) *v1alpha1.Channelable {
-	c := &v1alpha1.Channelable{
+func NewChannelable(name, namespace string, imcopt ...ChannelableOption) *duckv1.Channelable {
+	c := &duckv1.Channelable{
 		ObjectMeta: metav1.ObjectMeta{
 			Name:        name,
 			Namespace:   namespace,
 			Annotations: map[string]string{messaging.SubscribableDuckVersionAnnotation: "v1alpha1"},
 		},
-		Spec: v1alpha1.ChannelableSpec{},
+		Spec: duckv1.ChannelableSpec{},
 	}
 	for _, opt := range imcopt {
 		opt(c)
@@ -50,25 +47,25 @@ func NewChannelable(name, namespace string, imcopt ...ChannelableOption) *v1alph
 }
 
 func WithChannelableGeneration(gen int64) ChannelableOption {
-	return func(s *v1alpha1.Channelable) {
+	return func(s *duckv1.Channelable) {
 		s.Generation = gen
 	}
 }
 
 func WithChannelableStatusObservedGeneration(gen int64) ChannelableOption {
-	return func(s *v1alpha1.Channelable) {
+	return func(s *duckv1.Channelable) {
 		s.Status.ObservedGeneration = gen
 	}
 }
 
-func WithChannelableDeleted(imc *v1alpha1.Channelable) {
+func WithChannelableDeleted(imc *duckv1.Channelable) {
 	deleteTime := metav1.NewTime(time.Unix(1e9, 0))
 	imc.ObjectMeta.SetDeletionTimestamp(&deleteTime)
 }
 
-func WithChannelableSubscribers(subscribers []v1alpha1.SubscriberSpec) ChannelableOption {
-	return func(c *v1alpha1.Channelable) {
-		c.Spec.Subscribable = &v1alpha1.Subscribable{Subscribers: subscribers}
+func WithChannelableSubscribers(subscribers []duckv1.SubscriberSpec) ChannelableOption {
+	return func(c *duckv1.Channelable) {
+		c.Spec.Subscribers = append(c.Spec.Subscribers, subscribers...)
 	}
 }
 
@@ -77,11 +74,8 @@ func WithChannelableReadySubscriber(uid string) ChannelableOption {
 }
 
 func WithChannelableReadySubscriberAndGeneration(uid string, observedGeneration int64) ChannelableOption {
-	return func(c *v1alpha1.Channelable) {
-		if c.Status.GetSubscribableTypeStatus() == nil { // Both the SubscribableStatus fields are nil
-			c.Status.SetSubscribableTypeStatus(v1alpha1.SubscribableStatus{})
-		}
-		c.Status.SubscribableTypeStatus.AddSubscriberToSubscribableStatus(duckv1beta1.SubscriberStatus{
+	return func(c *duckv1.Channelable) {
+		c.Status.SubscribableStatus.Subscribers = append(c.Status.SubscribableStatus.Subscribers, duckv1.SubscriberStatus{
 			UID:                types.UID(uid),
 			ObservedGeneration: observedGeneration,
 			Ready:              corev1.ConditionTrue,
@@ -89,25 +83,20 @@ func WithChannelableReadySubscriberAndGeneration(uid string, observedGeneration
 	}
 }
 
-func WithChannelableStatusSubscribers(subscriberStatuses []duckv1beta1.SubscriberStatus) ChannelableOption {
-	return func(c *v1alpha1.Channelable) {
-		c.Status.SetSubscribableTypeStatus(v1alpha1.SubscribableStatus{
-			Subscribers: subscriberStatuses})
+func WithChannelableStatusSubscribers(subscriberStatuses []duckv1.SubscriberStatus) ChannelableOption {
+	return func(c *duckv1.Channelable) {
+		c.Status.Subscribers = append(c.Status.Subscribers, subscriberStatuses...)
 	}
 }
 
 func WithChannelableReady() ChannelableOption {
-	return func(c *v1alpha1.Channelable) {
+	return func(c *duckv1.Channelable) {
 		c.Status.Conditions = []apis.Condition{{Type: apis.ConditionReady, Status: corev1.ConditionTrue}}
 	}
 }
 
 func WithChannelableAddress(a string) ChannelableOption {
-	return func(c *v1alpha1.Channelable) {
-		c.Status.Address = &pkgduckv1alpha1.Addressable{
-			Addressable: pkgduckv1beta1.Addressable{
-				URL: apis.HTTP(a),
-			},
-		}
+	return func(c *duckv1.Channelable) {
+		c.Status.AddressStatus.Address.URL = apis.HTTP(a)
 	}
 }
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/factory.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/factory.go
index 679ca6567..b88958f22 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/factory.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/factory.go
@@ -36,6 +36,7 @@ import (
 	"knative.dev/pkg/controller"
 
 	fakeeventingclient "knative.dev/eventing/pkg/client/injection/client/fake"
+	fakeapiextensionsclient "knative.dev/pkg/client/injection/apiextensions/client/fake"
 	fakekubeclient "knative.dev/pkg/client/injection/kube/client/fake"
 	fakedynamicclient "knative.dev/pkg/injection/clients/dynamicclient/fake"
 
@@ -62,6 +63,7 @@ func MakeFactory(ctor Ctor, unstructured bool, logger *zap.SugaredLogger) Factor
 
 		ctx, kubeClient := fakekubeclient.With(ctx, ls.GetKubeObjects()...)
 		ctx, client := fakeeventingclient.With(ctx, ls.GetEventingObjects()...)
+		ctx, extClient := fakeapiextensionsclient.With(ctx, ls.GetAPIExtensionObjects()...)
 		ctx, dynamicClient := fakedynamicclient.With(ctx,
 			NewScheme(), ToUnstructured(t, r.Objects)...)
 
@@ -93,6 +95,7 @@ func MakeFactory(ctor Ctor, unstructured bool, logger *zap.SugaredLogger) Factor
 			kubeClient.PrependReactor("*", "*", reactor)
 			client.PrependReactor("*", "*", reactor)
 			dynamicClient.PrependReactor("*", "*", reactor)
+			extClient.PrependReactor("*", "*", reactor)
 		}
 
 		// Validate all Create operations through the eventing client.
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go
index da0b0cea4..91b2121b9 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1beta1/listers.go
@@ -20,9 +20,9 @@ import (
 	appsv1 "k8s.io/api/apps/v1"
 	corev1 "k8s.io/api/core/v1"
 	rbacv1 "k8s.io/api/rbac/v1"
-	apiextensionsv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
+	apiextensionsv1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1"
 	fakeapiextensionsclientset "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake"
-	apiextensionsv1beta1listers "k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1beta1"
+	apiextensionsv1listers "k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
@@ -32,7 +32,6 @@ import (
 	rbacv1listers "k8s.io/client-go/listers/rbac/v1"
 	"k8s.io/client-go/tools/cache"
 	configsv1alpha1 "knative.dev/eventing/pkg/apis/configs/v1alpha1"
-	eventingduckv1alpha1 "knative.dev/eventing/pkg/apis/duck/v1alpha1"
 	eventingv1beta1 "knative.dev/eventing/pkg/apis/eventing/v1beta1"
 	flowsv1beta1 "knative.dev/eventing/pkg/apis/flows/v1beta1"
 	messagingv1beta1 "knative.dev/eventing/pkg/apis/messaging/v1beta1"
@@ -67,7 +66,6 @@ var clientSetSchemes = []func(*runtime.Scheme) error{
 	fakeapiextensionsclientset.AddToScheme,
 	subscriberAddToScheme,
 	sourceAddToScheme,
-	eventingduckv1alpha1.AddToScheme,
 }
 
 type Listers struct {
@@ -107,6 +105,10 @@ func (l *Listers) GetKubeObjects() []runtime.Object {
 	return l.sorter.ObjectsForSchemeFunc(fakekubeclientset.AddToScheme)
 }
 
+func (l *Listers) GetAPIExtensionObjects() []runtime.Object {
+	return l.sorter.ObjectsForSchemeFunc(fakeapiextensionsclientset.AddToScheme)
+}
+
 func (l *Listers) GetEventingObjects() []runtime.Object {
 	return l.sorter.ObjectsForSchemeFunc(fakeeventingclientset.AddToScheme)
 }
@@ -119,6 +121,8 @@ func (l *Listers) GetAllObjects() []runtime.Object {
 	all := l.GetSubscriberObjects()
 	all = append(all, l.GetEventingObjects()...)
 	all = append(all, l.GetKubeObjects()...)
+	all = append(all, l.GetAPIExtensionObjects()...)
+
 	return all
 }
 
@@ -214,8 +218,8 @@ func (l *Listers) GetConfigMapLister() corev1listers.ConfigMapLister {
 	return corev1listers.NewConfigMapLister(l.indexerFor(&corev1.ConfigMap{}))
 }
 
-func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1beta1listers.CustomResourceDefinitionLister {
-	return apiextensionsv1beta1listers.NewCustomResourceDefinitionLister(l.indexerFor(&apiextensionsv1beta1.CustomResourceDefinition{}))
+func (l *Listers) GetCustomResourceDefinitionLister() apiextensionsv1listers.CustomResourceDefinitionLister {
+	return apiextensionsv1listers.NewCustomResourceDefinitionLister(l.indexerFor(&apiextensionsv1.CustomResourceDefinition{}))
 }
 
 func (l *Listers) GetConfigMapPropagationLister() configslisters.ConfigMapPropagationLister {
diff --git a/vendor/knative.dev/eventing/test/conformance/helpers/channel.go b/vendor/knative.dev/eventing/test/conformance/helpers/channel.go
index ec1166a86..2f0be5eb6 100644
--- a/vendor/knative.dev/eventing/test/conformance/helpers/channel.go
+++ b/vendor/knative.dev/eventing/test/conformance/helpers/channel.go
@@ -24,7 +24,6 @@ import (
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	eventingduckv1 "knative.dev/eventing/pkg/apis/duck/v1"
-	eventingduckv1alpha1 "knative.dev/eventing/pkg/apis/duck/v1alpha1"
 	eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
 
 	"knative.dev/eventing/pkg/apis/messaging"
@@ -50,11 +49,11 @@ var (
 
 func getChannelDuckTypeSupportVersion(channelName string, client *testlib.Client, channel *metav1.TypeMeta) (string, error) {
 	metaResource := resources.NewMetaResource(channelName, client.Namespace, channel)
-	obj, err := duck.GetGenericObject(client.Dynamic, metaResource, &eventingduckv1beta1.Channelable{})
+	obj, err := duck.GetGenericObject(client.Dynamic, metaResource, &eventingduckv1.Channelable{})
 	if err != nil {
 		return "", errors.Wrapf(err, "Unable to GET the channel %v", metaResource)
 	}
-	channelable, ok := obj.(*eventingduckv1beta1.Channelable)
+	channelable, ok := obj.(*eventingduckv1.Channelable)
 	if !ok {
 		return "", errors.Wrapf(err, "Unable to cast the channel %v", metaResource)
 	}
@@ -88,17 +87,3 @@ func getChannelAsV1Beta1Channelable(channelName string, client *testlib.Client,
 
 	return channelable, nil
 }
-
-func getChannelAsV1Alpha1Channelable(channelName string, client *testlib.Client, channel metav1.TypeMeta) (*eventingduckv1alpha1.Channelable, error) {
-	metaResource := resources.NewMetaResource(channelName, client.Namespace, &channel)
-	obj, err := duck.GetGenericObject(client.Dynamic, metaResource, &eventingduckv1alpha1.Channelable{})
-	if err != nil {
-		return nil, errors.Wrapf(err, "Unable to get the channel as v1alpha1 Channel duck type: %q", channel)
-	}
-	channelable, ok := obj.(*eventingduckv1alpha1.Channelable)
-	if !ok {
-		return nil, errors.Errorf("Unable to cast channel %q to v1alpha1 duck type", channel)
-	}
-
-	return channelable, nil
-}
diff --git a/vendor/knative.dev/eventing/test/conformance/helpers/channel_spec_test_helper.go b/vendor/knative.dev/eventing/test/conformance/helpers/channel_spec_test_helper.go
index 2c13d15ea..f7e19c69a 100644
--- a/vendor/knative.dev/eventing/test/conformance/helpers/channel_spec_test_helper.go
+++ b/vendor/knative.dev/eventing/test/conformance/helpers/channel_spec_test_helper.go
@@ -28,7 +28,6 @@ import (
 	"k8s.io/apiserver/pkg/storage/names"
 	"k8s.io/client-go/util/retry"
 
-	eventingduckv1alpha1 "knative.dev/eventing/pkg/apis/duck/v1alpha1"
 	eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
 	testlib "knative.dev/eventing/test/lib"
 	"knative.dev/pkg/apis"
@@ -61,7 +60,9 @@ func channelSpecAllowsSubscribersArray(st *testing.T, client *testlib.Client, ch
 		if err != nil {
 			st.Fatalf("Unable to check Channel duck type support version for %s: %s", channel, err)
 		}
-
+		if dtsv != "v1" && dtsv != "v1beta1" {
+			st.Fatalf("Unexpected duck type version, wanted [v1, v1beta] got: %s", dtsv)
+		}
 		channelName := names.SimpleNameGenerator.GenerateName("channel-spec-subscribers-")
 		client.T.Logf("Creating channel %+v-%s", channel, channelName)
 		client.CreateChannelOrFail(channelName, &channel)
@@ -72,44 +73,21 @@ func channelSpecAllowsSubscribersArray(st *testing.T, client *testlib.Client, ch
 
 		var ch interface{}
 
-		if dtsv == "" || dtsv == "v1alpha1" {
-			// treat missing annotation value as v1alpha1, as written in the spec
-			channelable, err := getChannelAsV1Alpha1Channelable(channelName, client, channel)
-			if err != nil {
-				st.Fatalf("Unable to get channel %s to v1alpha1 duck type: %s", channel, err)
-			}
-
-			// SPEC: each channel CRD MUST contain an array of subscribers: spec.subscribable.subscribers
-			channelable.Spec.Subscribable = &eventingduckv1alpha1.Subscribable{
-				Subscribers: []eventingduckv1alpha1.SubscriberSpec{
-					{
-						UID:      "1234",
-						ReplyURI: sampleUrl,
-					},
-				},
-			}
-
-			ch = channelable
-
-		} else if dtsv == "v1beta1" || dtsv == "v1" {
-			channelable, err := getChannelAsV1Beta1Channelable(channelName, client, channel)
-			if err != nil {
-				st.Fatalf("Unable to get channel %s to v1beta1 duck type: %s", channel, err)
-			}
-
-			// SPEC: each channel CRD MUST contain an array of subscribers: spec.subscribers
-			channelable.Spec.Subscribers = []eventingduckv1beta1.SubscriberSpec{
-				{
-					UID:      "1234",
-					ReplyURI: sampleUrl,
-				},
-			}
+		channelable, err := getChannelAsV1Beta1Channelable(channelName, client, channel)
+		if err != nil {
+			st.Fatalf("Unable to get channel %s to v1beta1 duck type: %s", channel, err)
+		}
 
-			ch = channelable
-		} else {
-			st.Fatalf("Channel doesn't support v1alpha1 nor v1beta1 Channel duck types: %s", channel)
+		// SPEC: each channel CRD MUST contain an array of subscribers: spec.subscribers
+		channelable.Spec.Subscribers = []eventingduckv1beta1.SubscriberSpec{
+			{
+				UID:      "1234",
+				ReplyURI: sampleUrl,
+			},
 		}
 
+		ch = channelable
+
 		raw, err := json.Marshal(ch)
 		if err != nil {
 			st.Fatalf("Error marshaling %s: %s", channel, err)
diff --git a/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_subscriber_test_helper.go b/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_subscriber_test_helper.go
index 4a0c2e798..db1f34670 100644
--- a/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_subscriber_test_helper.go
+++ b/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_subscriber_test_helper.go
@@ -21,7 +21,6 @@ import (
 	"testing"
 
 	duckv1 "knative.dev/eventing/pkg/apis/duck/v1"
-	duckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
 	eventingv1beta1 "knative.dev/eventing/pkg/apis/messaging/v1beta1"
 	testlib "knative.dev/eventing/test/lib"
 	"knative.dev/eventing/test/lib/recordevents"
@@ -76,77 +75,28 @@ func channelHasRequiredSubscriberStatus(ctx context.Context, st *testing.T, clie
 	if err != nil {
 		st.Fatalf("Unable to check Channel duck type support version for %q: %q", channel, err)
 	}
+	if dtsv != "v1" && dtsv != "v1beta1" {
+		st.Fatalf("Unexpected duck type version, wanted [v1, v1beta] got: %s", dtsv)
+	}
 
-	if dtsv == "" || dtsv == "v1alpha1" {
-		// treat missing annotation value as v1alpha1, as written in the spec
-		channelable, err := getChannelAsV1Alpha1Channelable(channelName, client, channel)
-		if err != nil {
-			st.Fatalf("Unable to get channel %q to v1alpha1 duck type: %q", channel, err)
-		}
-
-		// SPEC:  Each subscription to a channel is added to the channel status.subscribableStatus.subscribers automatically.
-		if channelable.Status.SubscribableStatus == nil || channelable.Status.SubscribableStatus.Subscribers == nil {
-			st.Fatalf("%q does not have status.subscribers", channel)
-		}
-		ss := findSubscriberStatusV1Beta1(channelable.Status.SubscribableStatus.Subscribers, subscription)
-		if ss == nil {
-			st.Fatalf("No subscription status found for channel %q and subscription %v", channel, subscription)
-		}
-
-		// SPEC: The ready field of the subscriber identified by its uid MUST be set to True when the subscription is ready to be processed.
-		if ss.Ready != corev1.ConditionTrue {
-			st.Fatalf("Subscription not ready found for channel %q and subscription %v", channel, subscription)
-		}
-	} else if dtsv == "v1beta1" {
-		channelable, err := getChannelAsV1Beta1Channelable(channelName, client, channel)
-		if err != nil {
-			st.Fatalf("Unable to get channel %q to v1beta1 duck type: %q", channel, err)
-		}
-
-		// SPEC: Each subscription to a channel is added to the channel status.subscribers automatically.
-		if channelable.Status.Subscribers == nil {
-			st.Fatalf("%q does not have status.subscribers", channel)
-		}
-		ss := findSubscriberStatusV1Beta1(channelable.Status.Subscribers, subscription)
-		if ss == nil {
-			st.Fatalf("No subscription status found for channel %q and subscription %v", channel, subscription)
-		}
-
-		// SPEC: The ready field of the subscriber identified by its uid MUST be set to True when the subscription is ready to be processed.
-		if ss.Ready != corev1.ConditionTrue {
-			st.Fatalf("Subscription not ready found for channel %q and subscription %v", channel, subscription)
-		}
-	} else if dtsv == "v1" {
-		channelable, err := getChannelAsV1Channelable(channelName, client, channel)
-		if err != nil {
-			st.Fatalf("Unable to get channel %q to v1 duck type: %q", channel, err)
-		}
-
-		// SPEC: Each subscription to a channel is added to the channel status.subscribers automatically.
-		if channelable.Status.Subscribers == nil {
-			st.Fatalf("%q does not have status.subscribers", channel)
-		}
-		ss := findSubscriberStatusV1(channelable.Status.Subscribers, subscription)
-		if ss == nil {
-			st.Fatalf("No subscription status found for channel %q and subscription %v", channel, subscription)
-		}
+	channelable, err := getChannelAsV1Channelable(channelName, client, channel)
+	if err != nil {
+		st.Fatalf("Unable to get channel %q to v1 duck type: %q", channel, err)
+	}
 
-		// SPEC: The ready field of the subscriber identified by its uid MUST be set to True when the subscription is ready to be processed.
-		if ss.Ready != corev1.ConditionTrue {
-			st.Fatalf("Subscription not ready found for channel %q and subscription %v", channel, subscription)
-		}
-	} else {
-		st.Fatalf("Channel doesn't support v1alpha1, v1beta1 or v1 Channel duck types: %v", channel)
+	// SPEC: Each subscription to a channel is added to the channel status.subscribers automatically.
+	if channelable.Status.Subscribers == nil {
+		st.Fatalf("%q does not have status.subscribers", channel)
+	}
+	ss := findSubscriberStatusV1(channelable.Status.Subscribers, subscription)
+	if ss == nil {
+		st.Fatalf("No subscription status found for channel %q and subscription %v", channel, subscription)
 	}
-}
 
-func findSubscriberStatusV1Beta1(statusArr []duckv1beta1.SubscriberStatus, subscription *eventingv1beta1.Subscription) *duckv1beta1.SubscriberStatus {
-	for _, v := range statusArr {
-		if v.UID == subscription.UID {
-			return &v
-		}
+	// SPEC: The ready field of the subscriber identified by its uid MUST be set to True when the subscription is ready to be processed.
+	if ss.Ready != corev1.ConditionTrue {
+		st.Fatalf("Subscription not ready found for channel %q and subscription %v", channel, subscription)
 	}
-	return nil
 }
 
 func findSubscriberStatusV1(statusArr []duckv1.SubscriberStatus, subscription *eventingv1beta1.Subscription) *duckv1.SubscriberStatus {
diff --git a/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_test_helper.go b/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_test_helper.go
index d3d0bea11..fe293d828 100644
--- a/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_test_helper.go
+++ b/vendor/knative.dev/eventing/test/conformance/helpers/channel_status_test_helper.go
@@ -55,44 +55,23 @@ func channelHasRequiredStatus(st *testing.T, client *testlib.Client, channel met
 	if err != nil {
 		st.Fatalf("Unable to check Channel duck type support version for %q: %q", channel, err)
 	}
+	if dtsv != "v1" && dtsv != "v1beta1" {
+		st.Fatalf("Unexpected duck type version, wanted [v1, v1beta] got: %s", dtsv)
+	}
+
+	channelable, err := getChannelAsV1Beta1Channelable(channelName, client, channel)
+	if err != nil {
+		st.Fatalf("Unable to get channel %q to v1beta1 duck type: %q", channel, err)
+	}
+
+	// SPEC: Channel CRD MUST have a status subresource which contains address
+	if channelable.Status.AddressStatus.Address == nil {
+		st.Fatalf("%q does not have status.address", channel)
+	}
 
-	if dtsv == "" || dtsv == "v1alpha1" {
-		// treat missing annotation value as v1alpha1, as written in the spec
-		channelable, err := getChannelAsV1Alpha1Channelable(channelName, client, channel)
-		if err != nil {
-			st.Fatalf("Unable to get channel %q to v1alpha1 duck type: %q", channel, err)
-		}
-
-		// SPEC: Channel CRD MUST have a status subresource which contains address
-		if channelable.Status.AddressStatus.Address == nil {
-			st.Fatalf("%q does not have status.address", channel)
-		}
-
-		// SPEC: When the channel instance is ready to receive events status.address.hostname and
-		// status.address.url MUST be populated
-		if channelable.Status.AddressStatus.Address.Hostname == "" {
-			st.Fatalf("No hostname found for %q", channel)
-		}
-		if channelable.Status.AddressStatus.Address.URL.IsEmpty() {
-			st.Fatalf("No hostname found for %q", channel)
-		}
-	} else if dtsv == "v1beta1" || dtsv == "v1" {
-		channelable, err := getChannelAsV1Beta1Channelable(channelName, client, channel)
-		if err != nil {
-			st.Fatalf("Unable to get channel %q to v1beta1 duck type: %q", channel, err)
-		}
-
-		// SPEC: Channel CRD MUST have a status subresource which contains address
-		if channelable.Status.AddressStatus.Address == nil {
-			st.Fatalf("%q does not have status.address", channel)
-		}
-
-		// SPEC: When the channel instance is ready to receive events status.address.hostname and
-		// status.address.url MUST be populated
-		if channelable.Status.Address.URL.IsEmpty() {
-			st.Fatalf("No hostname found for %q", channel)
-		}
-	} else {
-		st.Fatalf("Channel doesn't support v1alpha1 nor v1beta1 Channel duck types: %q", channel)
+	// SPEC: When the channel instance is ready to receive events status.address.hostname and
+	// status.address.url MUST be populated
+	if channelable.Status.Address.URL.IsEmpty() {
+		st.Fatalf("No hostname found for %q", channel)
 	}
 }
diff --git a/vendor/knative.dev/eventing/test/e2e/helpers/channel_defaulter_test_helper.go b/vendor/knative.dev/eventing/test/e2e/helpers/channel_defaulter_test_helper.go
index 2be4870b3..abc51b21f 100644
--- a/vendor/knative.dev/eventing/test/e2e/helpers/channel_defaulter_test_helper.go
+++ b/vendor/knative.dev/eventing/test/e2e/helpers/channel_defaulter_test_helper.go
@@ -33,7 +33,7 @@ import (
 
 	reconciler "knative.dev/pkg/reconciler"
 
-	eventingduck "knative.dev/eventing/pkg/apis/duck/v1alpha1"
+	eventingduckv1 "knative.dev/eventing/pkg/apis/duck/v1"
 	"knative.dev/eventing/pkg/apis/messaging/config"
 	eventingtesting "knative.dev/eventing/pkg/reconciler/testing/v1beta1"
 	testlib "knative.dev/eventing/test/lib"
@@ -119,7 +119,7 @@ func defaultChannelTestHelper(ctx context.Context, t *testing.T, client *testlib
 
 	// check if the defaultchannel creates exactly one underlying channel given the spec
 	metaResourceList := resources.NewMetaResourceList(client.Namespace, &expectedChannel)
-	objs, err := duck.GetGenericObjectList(client.Dynamic, metaResourceList, &eventingduck.SubscribableType{})
+	objs, err := duck.GetGenericObjectList(client.Dynamic, metaResourceList, &eventingduckv1.Subscribable{})
 	if err != nil {
 		t.Fatal("Failed to list the underlying channels:", err)
 	}
@@ -130,7 +130,7 @@ func defaultChannelTestHelper(ctx context.Context, t *testing.T, client *testlib
 	// So, filter out the broker channel from the list before checking that there's only one.
 	filteredObjs := make([]runtime.Object, 0)
 	for _, o := range objs {
-		if o.(*eventingduck.SubscribableType).Name != "default-kne-trigger" {
+		if o.(*eventingduckv1.Subscribable).Name != "default-kne-trigger" {
 			filteredObjs = append(filteredObjs, o)
 		}
 	}