Repository: knative-sandbox/eventing-kafka
Pull request #345 (2021-01-29 16:34:37)

No retry on 400 response
## Proposed Changes

- 🧽 Removed 400 ("Bad Request") from the list of responses in the distributed channel dispatcher's handler that indicate retries.

**Reasoning**

Retrying on a 400 response was a legacy behavior that was required due to the way the filter handler was consuming 5xx responses and returning 400 in their place.  This is no longer the case and "Bad Request" responses are not generally conditions that warrant retries, so that code has been removed.

Note that there are still several 4xx responses that do cause checkRetry to return true (namely 404, 409, and 429).  409 is required unless the e2e tests are changed, and 404/429 are left for their original reasons (noted in the comments for the checkRetry function).


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

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka/pull/345#" title="Author self-approved">eric-sap</a>*
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please assign **slinkydeveloper** after the PR has been reviewed.
You can assign the PR to them by writing `/assign @slinkydeveloper` 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":["slinkydeveloper"]} -->
knative-prow-robot: Hi @eric-sap. Thanks for your PR.

I'm waiting for a [knative-sandbox](https://github.com/orgs/knative-sandbox/people) member to verify that this patch is reasonable to test. If it is, they should reply with `/ok-to-test` on its own line. Until that is done, I will not automatically test new commits in this PR, but the usual testing commands by org members will still work. Regular contributors should [join the org](https://github.com/orgs/knative-sandbox/people) to skip this step.

Once the patch is verified, the new status will be reflected by the `ok-to-test` label.

I understand the commands that are listed [here](https://go.k8s.io/bot-commands?repo=knative-sandbox%2Feventing-kafka).

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

codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/345?src=pr&el=h1) Report
> Merging [#345](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/345?src=pr&el=desc) (296ba9f) into [master](https://codecov.io/gh/knative-sandbox/eventing-kafka/commit/ce667951d74dc6a6adf0e766ed21bf0fcb4a6032?el=desc) (ce66795) will **increase** coverage by `0.15%`.
> The diff coverage is `100.00%`.

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

```diff
@@            Coverage Diff             @@
##           master     #345      +/-   ##
==========================================
+ Coverage   76.06%   76.22%   +0.15%     
==========================================
  Files         114      114              
  Lines        4425     4425              
==========================================
+ Hits         3366     3373       +7     
+ Misses        860      853       -7     
  Partials      199      199              
```


| [Impacted Files](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/345?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [...annel/distributed/dispatcher/dispatcher/handler.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/345/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvZGlzdHJpYnV0ZWQvZGlzcGF0Y2hlci9kaXNwYXRjaGVyL2hhbmRsZXIuZ28=) | `90.76% <100.00%> (ø)` | |
| [...el/distributed/dispatcher/dispatcher/dispatcher.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/345/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvZGlzdHJpYnV0ZWQvZGlzcGF0Y2hlci9kaXNwYXRjaGVyL2Rpc3BhdGNoZXIuZ28=) | `71.81% <0.00%> (+6.36%)` | :arrow_up: |

------

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

travis-minke-sap: /ok-to-test
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/channel/distributed/dispatcher/dispatcher/handler.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/345/pull-knative-sandbox-eventing-kafka-go-coverage/1355203734270906368/artifacts/line-cov.html#file0) | 92.5% | 94.3% | 1.9

travis-minke-sap: /approve
/lgtm
/hold

*holding briefly for other reviewers to have a chance ; )
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/345#" title="Author self-approved">eric-sap</a>*, *<a href="https://github.com/knative-sandbox/eventing-kafka/pull/345#issuecomment-769938399" title="LGTM">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/master/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/hack/boilerplate.go.txt b/hack/boilerplate.go.txt
index 6f818683b..4b6f5853d 100644
--- a/hack/boilerplate.go.txt
+++ b/hack/boilerplate.go.txt
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/apis/bindings/v1alpha1/zz_generated.deepcopy.go b/pkg/apis/bindings/v1alpha1/zz_generated.deepcopy.go
index 956bc5909..e4a9a6a4f 100644
--- a/pkg/apis/bindings/v1alpha1/zz_generated.deepcopy.go
+++ b/pkg/apis/bindings/v1alpha1/zz_generated.deepcopy.go
@@ -1,7 +1,7 @@
 // +build !ignore_autogenerated
 
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/apis/bindings/v1beta1/zz_generated.deepcopy.go b/pkg/apis/bindings/v1beta1/zz_generated.deepcopy.go
index bbc7a0195..97ccf09ff 100644
--- a/pkg/apis/bindings/v1beta1/zz_generated.deepcopy.go
+++ b/pkg/apis/bindings/v1beta1/zz_generated.deepcopy.go
@@ -1,7 +1,7 @@
 // +build !ignore_autogenerated
 
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go b/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go
index 143799048..fc3e2e04b 100644
--- a/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go
+++ b/pkg/apis/messaging/v1alpha1/zz_generated.deepcopy.go
@@ -1,7 +1,7 @@
 // +build !ignore_autogenerated
 
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/apis/messaging/v1beta1/zz_generated.deepcopy.go b/pkg/apis/messaging/v1beta1/zz_generated.deepcopy.go
index 644f31cae..1a36f8324 100644
--- a/pkg/apis/messaging/v1beta1/zz_generated.deepcopy.go
+++ b/pkg/apis/messaging/v1beta1/zz_generated.deepcopy.go
@@ -1,7 +1,7 @@
 // +build !ignore_autogenerated
 
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go b/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go
index 929315302..e57ddec9e 100644
--- a/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go
+++ b/pkg/apis/sources/v1alpha1/zz_generated.deepcopy.go
@@ -1,7 +1,7 @@
 // +build !ignore_autogenerated
 
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/apis/sources/v1beta1/zz_generated.deepcopy.go b/pkg/apis/sources/v1beta1/zz_generated.deepcopy.go
index 9bf4b7085..025c8e7de 100644
--- a/pkg/apis/sources/v1beta1/zz_generated.deepcopy.go
+++ b/pkg/apis/sources/v1beta1/zz_generated.deepcopy.go
@@ -1,7 +1,7 @@
 // +build !ignore_autogenerated
 
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/channel/distributed/dispatcher/dispatcher/handler.go b/pkg/channel/distributed/dispatcher/dispatcher/handler.go
index fb10097a8..9c68f6adb 100644
--- a/pkg/channel/distributed/dispatcher/dispatcher/handler.go
+++ b/pkg/channel/distributed/dispatcher/dispatcher/handler.go
@@ -172,13 +172,19 @@ func (h *Handler) checkRetry(_ context.Context, response *http.Response, err err
 	statusCode := response.StatusCode
 	logger := h.Logger.With(zap.Int("StatusCode", statusCode))
 
+	// Note - Normally we would NOT want to retry 4xx responses, BUT there are a few
+	//        known areas of knative-eventing that return codes in this range which
+	//        require retries.  Reasons for particular codes are as follows:
 	//
-	// Note - Normally we would NOT want to retry 400 responses, BUT the knative-eventing
-	//        filter handler (due to CloudEvents SDK V1 usage) is swallowing the actual
-	//        status codes from the subscriber and returning 400s instead.  Once this has,
-	//        been resolved we can remove 400 from the list of codes to retry.
-	//
-	if statusCode >= 500 || statusCode == 400 || statusCode == 404 || statusCode == 429 || statusCode == 409 {
+	// 404  Although we would ideally not want to retry a permanent "Not Found"
+	//      response, a 404 can be returned when a pod is in the process of becoming
+	//      ready, so a retry can be a useful thing in this situation.
+	// 409  Returned by the E2E tests, so we must retry when "Conflict" is received, or the
+	//      tests will fail (see knative.dev/eventing/test/lib/recordevents/receiver/receiver.go)
+	// 429  Since retry typically involves a delay (usually an exponential backoff),
+	//      retrying after receiving a "Too Many Requests" response is useful.
+
+	if statusCode >= 500 || statusCode == 404 || statusCode == 429 || statusCode == 409 {
 		logger.Warn("Failed To Send Message To Subscriber Service - Retrying")
 		return true, nil
 	} else if statusCode >= 300 && statusCode <= 399 {
diff --git a/pkg/client/clientset/versioned/clientset.go b/pkg/client/clientset/versioned/clientset.go
index c4e04e701..60d0b253c 100644
--- a/pkg/client/clientset/versioned/clientset.go
+++ b/pkg/client/clientset/versioned/clientset.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/doc.go b/pkg/client/clientset/versioned/doc.go
index e48c2aa44..20dbc6ffb 100644
--- a/pkg/client/clientset/versioned/doc.go
+++ b/pkg/client/clientset/versioned/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/fake/clientset_generated.go b/pkg/client/clientset/versioned/fake/clientset_generated.go
index 76dff90dc..7644f23f4 100644
--- a/pkg/client/clientset/versioned/fake/clientset_generated.go
+++ b/pkg/client/clientset/versioned/fake/clientset_generated.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/fake/doc.go b/pkg/client/clientset/versioned/fake/doc.go
index 2c4903250..3b00d536c 100644
--- a/pkg/client/clientset/versioned/fake/doc.go
+++ b/pkg/client/clientset/versioned/fake/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/fake/register.go b/pkg/client/clientset/versioned/fake/register.go
index a93aca296..70d887a34 100644
--- a/pkg/client/clientset/versioned/fake/register.go
+++ b/pkg/client/clientset/versioned/fake/register.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/scheme/doc.go b/pkg/client/clientset/versioned/scheme/doc.go
index 7acc2dcf2..5597166be 100644
--- a/pkg/client/clientset/versioned/scheme/doc.go
+++ b/pkg/client/clientset/versioned/scheme/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/scheme/register.go b/pkg/client/clientset/versioned/scheme/register.go
index cc8e824cf..dd20a52f5 100644
--- a/pkg/client/clientset/versioned/scheme/register.go
+++ b/pkg/client/clientset/versioned/scheme/register.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/bindings_client.go b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/bindings_client.go
index d4ce85357..195c58a4b 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/bindings_client.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/bindings_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/doc.go b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/doc.go
index 41e872fe9..f905d3a21 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/doc.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/doc.go b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/doc.go
index c7f6e65ca..d5a46ef55 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/doc.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_bindings_client.go b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_bindings_client.go
index 01b829177..677ecf367 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_bindings_client.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_bindings_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_kafkabinding.go b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_kafkabinding.go
index c307b7a6f..f4482084e 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_kafkabinding.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/fake/fake_kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/generated_expansion.go b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/generated_expansion.go
index 6773bbb9c..b61d70a3a 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/generated_expansion.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/generated_expansion.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/kafkabinding.go b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/kafkabinding.go
index 0ebfb0c34..4bd2cd79e 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1alpha1/kafkabinding.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1alpha1/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1beta1/bindings_client.go b/pkg/client/clientset/versioned/typed/bindings/v1beta1/bindings_client.go
index f0a3ece29..0f0651af1 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1beta1/bindings_client.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1beta1/bindings_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1beta1/doc.go b/pkg/client/clientset/versioned/typed/bindings/v1beta1/doc.go
index b641cb373..8d5037f07 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1beta1/doc.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1beta1/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/doc.go b/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/doc.go
index c7f6e65ca..d5a46ef55 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/doc.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_bindings_client.go b/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_bindings_client.go
index 8d1e5f848..2237e7bfa 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_bindings_client.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_bindings_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_kafkabinding.go b/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_kafkabinding.go
index 65eaf0c65..609547ae2 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_kafkabinding.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1beta1/fake/fake_kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1beta1/generated_expansion.go b/pkg/client/clientset/versioned/typed/bindings/v1beta1/generated_expansion.go
index a2832240f..3838e0ed6 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1beta1/generated_expansion.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1beta1/generated_expansion.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/bindings/v1beta1/kafkabinding.go b/pkg/client/clientset/versioned/typed/bindings/v1beta1/kafkabinding.go
index 3e0a9422e..b616f8e30 100644
--- a/pkg/client/clientset/versioned/typed/bindings/v1beta1/kafkabinding.go
+++ b/pkg/client/clientset/versioned/typed/bindings/v1beta1/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/doc.go b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/doc.go
index 41e872fe9..f905d3a21 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/doc.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/doc.go b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/doc.go
index c7f6e65ca..d5a46ef55 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/doc.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_kafkachannel.go b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_kafkachannel.go
index af2a3a436..79c89db3a 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_kafkachannel.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_messaging_client.go b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_messaging_client.go
index 2ba2ffc16..e6661a75e 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_messaging_client.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/fake/fake_messaging_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/generated_expansion.go b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/generated_expansion.go
index cf6b1cf17..456d4e29e 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/generated_expansion.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/generated_expansion.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/kafkachannel.go b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/kafkachannel.go
index 233566ca1..a06cf6fa7 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/kafkachannel.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/messaging_client.go b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/messaging_client.go
index 7ec065837..8f7b07417 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1alpha1/messaging_client.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1alpha1/messaging_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1beta1/doc.go b/pkg/client/clientset/versioned/typed/messaging/v1beta1/doc.go
index b641cb373..8d5037f07 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1beta1/doc.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1beta1/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/doc.go b/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/doc.go
index c7f6e65ca..d5a46ef55 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/doc.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_kafkachannel.go b/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_kafkachannel.go
index a8e348e71..5ab4e5a86 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_kafkachannel.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_messaging_client.go b/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_messaging_client.go
index 14e48d925..9befbac81 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_messaging_client.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1beta1/fake/fake_messaging_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1beta1/generated_expansion.go b/pkg/client/clientset/versioned/typed/messaging/v1beta1/generated_expansion.go
index 882316a99..f4c8b2116 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1beta1/generated_expansion.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1beta1/generated_expansion.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1beta1/kafkachannel.go b/pkg/client/clientset/versioned/typed/messaging/v1beta1/kafkachannel.go
index fd117dfb8..32e84ea4b 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1beta1/kafkachannel.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1beta1/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/messaging/v1beta1/messaging_client.go b/pkg/client/clientset/versioned/typed/messaging/v1beta1/messaging_client.go
index 7ab38acdf..709dee3d3 100644
--- a/pkg/client/clientset/versioned/typed/messaging/v1beta1/messaging_client.go
+++ b/pkg/client/clientset/versioned/typed/messaging/v1beta1/messaging_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1alpha1/doc.go b/pkg/client/clientset/versioned/typed/sources/v1alpha1/doc.go
index 41e872fe9..f905d3a21 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1alpha1/doc.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1alpha1/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/doc.go b/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/doc.go
index c7f6e65ca..d5a46ef55 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/doc.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_kafkasource.go b/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_kafkasource.go
index 05dd885ba..27a5bdd6b 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_kafkasource.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go b/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go
index 8ea667bbd..033902724 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1alpha1/fake/fake_sources_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go b/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go
index fe596ced8..7e22bf6ae 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1alpha1/generated_expansion.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1alpha1/kafkasource.go b/pkg/client/clientset/versioned/typed/sources/v1alpha1/kafkasource.go
index d8b818add..d256eaf3a 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1alpha1/kafkasource.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1alpha1/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go b/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go
index 88f1cdd72..baad07b15 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1alpha1/sources_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1beta1/doc.go b/pkg/client/clientset/versioned/typed/sources/v1beta1/doc.go
index b641cb373..8d5037f07 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1beta1/doc.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1beta1/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/doc.go b/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/doc.go
index c7f6e65ca..d5a46ef55 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/doc.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/doc.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_kafkasource.go b/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_kafkasource.go
index 94595ff0a..978466a6c 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_kafkasource.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sources_client.go b/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sources_client.go
index 788df9734..e3876454b 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sources_client.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1beta1/fake/fake_sources_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1beta1/generated_expansion.go b/pkg/client/clientset/versioned/typed/sources/v1beta1/generated_expansion.go
index ff787ff4f..0d52c6ea7 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1beta1/generated_expansion.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1beta1/generated_expansion.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1beta1/kafkasource.go b/pkg/client/clientset/versioned/typed/sources/v1beta1/kafkasource.go
index fab286c4e..94c619d6c 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1beta1/kafkasource.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1beta1/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/clientset/versioned/typed/sources/v1beta1/sources_client.go b/pkg/client/clientset/versioned/typed/sources/v1beta1/sources_client.go
index 747454353..55ff9788d 100644
--- a/pkg/client/clientset/versioned/typed/sources/v1beta1/sources_client.go
+++ b/pkg/client/clientset/versioned/typed/sources/v1beta1/sources_client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/bindings/interface.go b/pkg/client/informers/externalversions/bindings/interface.go
index 33b216646..e7127091b 100644
--- a/pkg/client/informers/externalversions/bindings/interface.go
+++ b/pkg/client/informers/externalversions/bindings/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/bindings/v1alpha1/interface.go b/pkg/client/informers/externalversions/bindings/v1alpha1/interface.go
index 7b5682420..c9a25339c 100644
--- a/pkg/client/informers/externalversions/bindings/v1alpha1/interface.go
+++ b/pkg/client/informers/externalversions/bindings/v1alpha1/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/bindings/v1alpha1/kafkabinding.go b/pkg/client/informers/externalversions/bindings/v1alpha1/kafkabinding.go
index ffbb8be5b..9d7318dc4 100644
--- a/pkg/client/informers/externalversions/bindings/v1alpha1/kafkabinding.go
+++ b/pkg/client/informers/externalversions/bindings/v1alpha1/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/bindings/v1beta1/interface.go b/pkg/client/informers/externalversions/bindings/v1beta1/interface.go
index 98b317f5b..265aa789d 100644
--- a/pkg/client/informers/externalversions/bindings/v1beta1/interface.go
+++ b/pkg/client/informers/externalversions/bindings/v1beta1/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/bindings/v1beta1/kafkabinding.go b/pkg/client/informers/externalversions/bindings/v1beta1/kafkabinding.go
index 593a5e3c6..faa1d70bf 100644
--- a/pkg/client/informers/externalversions/bindings/v1beta1/kafkabinding.go
+++ b/pkg/client/informers/externalversions/bindings/v1beta1/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/factory.go b/pkg/client/informers/externalversions/factory.go
index b0808b7d7..98e20f1a4 100644
--- a/pkg/client/informers/externalversions/factory.go
+++ b/pkg/client/informers/externalversions/factory.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/generic.go b/pkg/client/informers/externalversions/generic.go
index 9e8e2e750..ed3501f29 100644
--- a/pkg/client/informers/externalversions/generic.go
+++ b/pkg/client/informers/externalversions/generic.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go b/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go
index 27f259dd6..33c112940 100644
--- a/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go
+++ b/pkg/client/informers/externalversions/internalinterfaces/factory_interfaces.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/messaging/interface.go b/pkg/client/informers/externalversions/messaging/interface.go
index a55ba3521..fbae6dce4 100644
--- a/pkg/client/informers/externalversions/messaging/interface.go
+++ b/pkg/client/informers/externalversions/messaging/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/messaging/v1alpha1/interface.go b/pkg/client/informers/externalversions/messaging/v1alpha1/interface.go
index cf6814437..0c8d616b8 100644
--- a/pkg/client/informers/externalversions/messaging/v1alpha1/interface.go
+++ b/pkg/client/informers/externalversions/messaging/v1alpha1/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/messaging/v1alpha1/kafkachannel.go b/pkg/client/informers/externalversions/messaging/v1alpha1/kafkachannel.go
index 101cf69fe..ef18220bb 100644
--- a/pkg/client/informers/externalversions/messaging/v1alpha1/kafkachannel.go
+++ b/pkg/client/informers/externalversions/messaging/v1alpha1/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/messaging/v1beta1/interface.go b/pkg/client/informers/externalversions/messaging/v1beta1/interface.go
index deaba6ade..6c29bfe8c 100644
--- a/pkg/client/informers/externalversions/messaging/v1beta1/interface.go
+++ b/pkg/client/informers/externalversions/messaging/v1beta1/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/messaging/v1beta1/kafkachannel.go b/pkg/client/informers/externalversions/messaging/v1beta1/kafkachannel.go
index 660d52a5d..40e812461 100644
--- a/pkg/client/informers/externalversions/messaging/v1beta1/kafkachannel.go
+++ b/pkg/client/informers/externalversions/messaging/v1beta1/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/sources/interface.go b/pkg/client/informers/externalversions/sources/interface.go
index 7484202b2..81281b95b 100644
--- a/pkg/client/informers/externalversions/sources/interface.go
+++ b/pkg/client/informers/externalversions/sources/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/sources/v1alpha1/interface.go b/pkg/client/informers/externalversions/sources/v1alpha1/interface.go
index 90797b3f1..44704101e 100644
--- a/pkg/client/informers/externalversions/sources/v1alpha1/interface.go
+++ b/pkg/client/informers/externalversions/sources/v1alpha1/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/sources/v1alpha1/kafkasource.go b/pkg/client/informers/externalversions/sources/v1alpha1/kafkasource.go
index b8cf64919..598e193a9 100644
--- a/pkg/client/informers/externalversions/sources/v1alpha1/kafkasource.go
+++ b/pkg/client/informers/externalversions/sources/v1alpha1/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/sources/v1beta1/interface.go b/pkg/client/informers/externalversions/sources/v1beta1/interface.go
index 186d05648..3b257ebd2 100644
--- a/pkg/client/informers/externalversions/sources/v1beta1/interface.go
+++ b/pkg/client/informers/externalversions/sources/v1beta1/interface.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/informers/externalversions/sources/v1beta1/kafkasource.go b/pkg/client/informers/externalversions/sources/v1beta1/kafkasource.go
index 18d54fd24..b5a1594ba 100644
--- a/pkg/client/informers/externalversions/sources/v1beta1/kafkasource.go
+++ b/pkg/client/informers/externalversions/sources/v1beta1/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/client/client.go b/pkg/client/injection/client/client.go
index 5bca62656..9700efeec 100644
--- a/pkg/client/injection/client/client.go
+++ b/pkg/client/injection/client/client.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/client/fake/fake.go b/pkg/client/injection/client/fake/fake.go
index 78e86ed2c..4f7a5b688 100644
--- a/pkg/client/injection/client/fake/fake.go
+++ b/pkg/client/injection/client/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/fake/fake.go b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/fake/fake.go
index 9a6765a6e..13e5aad04 100644
--- a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/fake/fake.go
+++ b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/fake/fake.go b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/fake/fake.go
index a5f553e7b..ef7edadbc 100644
--- a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/fake/fake.go
+++ b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/kafkabinding.go b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/kafkabinding.go
index 7971f68b4..7f892f372 100644
--- a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/kafkabinding.go
+++ b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/filtered/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/kafkabinding.go b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/kafkabinding.go
index 1d9e3ba54..5a9392b83 100644
--- a/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/kafkabinding.go
+++ b/pkg/client/injection/informers/bindings/v1alpha1/kafkabinding/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/fake/fake.go b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/fake/fake.go
index 6b51af9c6..1124d8efc 100644
--- a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/fake/fake.go
+++ b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/fake/fake.go b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/fake/fake.go
index 806d684b9..d3c42dcca 100644
--- a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/fake/fake.go
+++ b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/kafkabinding.go b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/kafkabinding.go
index 89791ec60..e03b87627 100644
--- a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/kafkabinding.go
+++ b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/filtered/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/kafkabinding.go b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/kafkabinding.go
index 4da0b5477..8d3b1bc2d 100644
--- a/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/kafkabinding.go
+++ b/pkg/client/injection/informers/bindings/v1beta1/kafkabinding/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/factory/factory.go b/pkg/client/injection/informers/factory/factory.go
index e585ca16a..b753d0f5d 100644
--- a/pkg/client/injection/informers/factory/factory.go
+++ b/pkg/client/injection/informers/factory/factory.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/factory/fake/fake.go b/pkg/client/injection/informers/factory/fake/fake.go
index 7f41ae99b..be34de9ef 100644
--- a/pkg/client/injection/informers/factory/fake/fake.go
+++ b/pkg/client/injection/informers/factory/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/factory/filtered/fake/fake_filtered_factory.go b/pkg/client/injection/informers/factory/filtered/fake/fake_filtered_factory.go
index 5dff766aa..a1c89ee89 100644
--- a/pkg/client/injection/informers/factory/filtered/fake/fake_filtered_factory.go
+++ b/pkg/client/injection/informers/factory/filtered/fake/fake_filtered_factory.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/factory/filtered/filtered_factory.go b/pkg/client/injection/informers/factory/filtered/filtered_factory.go
index 9d3c92063..35e3b8fea 100644
--- a/pkg/client/injection/informers/factory/filtered/filtered_factory.go
+++ b/pkg/client/injection/informers/factory/filtered/filtered_factory.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/fake/fake.go b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/fake/fake.go
index d2a64c5fc..49770e932 100644
--- a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/fake/fake.go
+++ b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/fake/fake.go b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/fake/fake.go
index 7d5fe721b..6971350e4 100644
--- a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/fake/fake.go
+++ b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/kafkachannel.go b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/kafkachannel.go
index 9cc546d7d..28b00b719 100644
--- a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/kafkachannel.go
+++ b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/filtered/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/kafkachannel.go b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/kafkachannel.go
index e8ea7cd39..62d464b3c 100644
--- a/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/kafkachannel.go
+++ b/pkg/client/injection/informers/messaging/v1alpha1/kafkachannel/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake/fake.go b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake/fake.go
index 36334074a..5a1b9c85d 100644
--- a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake/fake.go
+++ b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/fake/fake.go b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/fake/fake.go
index 64164b00a..0b2a589b4 100644
--- a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/fake/fake.go
+++ b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/kafkachannel.go b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/kafkachannel.go
index 7e0893f12..20c3e28e8 100644
--- a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/kafkachannel.go
+++ b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/filtered/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/kafkachannel.go b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/kafkachannel.go
index 8f4fb58d6..d309bf6ba 100644
--- a/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/kafkachannel.go
+++ b/pkg/client/injection/informers/messaging/v1beta1/kafkachannel/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/fake/fake.go b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/fake/fake.go
index 3dc0f8b21..9256e89ed 100644
--- a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/fake/fake.go
+++ b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/fake/fake.go b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/fake/fake.go
index 778c46f01..1c2bcc75c 100644
--- a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/fake/fake.go
+++ b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/kafkasource.go b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/kafkasource.go
index 316eb495a..5f8f1cbaf 100644
--- a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/kafkasource.go
+++ b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/filtered/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/kafkasource.go b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/kafkasource.go
index 3da7bc29c..e58a1623d 100644
--- a/pkg/client/injection/informers/sources/v1alpha1/kafkasource/kafkasource.go
+++ b/pkg/client/injection/informers/sources/v1alpha1/kafkasource/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1beta1/kafkasource/fake/fake.go b/pkg/client/injection/informers/sources/v1beta1/kafkasource/fake/fake.go
index 5b0c335bf..80d1e5b6d 100644
--- a/pkg/client/injection/informers/sources/v1beta1/kafkasource/fake/fake.go
+++ b/pkg/client/injection/informers/sources/v1beta1/kafkasource/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/fake/fake.go b/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/fake/fake.go
index fe4abc3be..02a4f6af9 100644
--- a/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/fake/fake.go
+++ b/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/fake/fake.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/kafkasource.go b/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/kafkasource.go
index a9d3d90d9..98ac43f27 100644
--- a/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/kafkasource.go
+++ b/pkg/client/injection/informers/sources/v1beta1/kafkasource/filtered/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/informers/sources/v1beta1/kafkasource/kafkasource.go b/pkg/client/injection/informers/sources/v1beta1/kafkasource/kafkasource.go
index 7929a3414..443d5055e 100644
--- a/pkg/client/injection/informers/sources/v1beta1/kafkasource/kafkasource.go
+++ b/pkg/client/injection/informers/sources/v1beta1/kafkasource/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/controller.go b/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/controller.go
index c842d03b5..7dbd0b894 100644
--- a/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/controller.go
+++ b/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/controller.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/reconciler.go b/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/reconciler.go
index 1158b010d..9ca9870b3 100644
--- a/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/reconciler.go
+++ b/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/reconciler.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/state.go b/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/state.go
index 4cb54f9e1..d18a572ee 100644
--- a/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/state.go
+++ b/pkg/client/injection/reconciler/bindings/v1alpha1/kafkabinding/state.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/controller.go b/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/controller.go
index 5f8d56992..ce7675ff9 100644
--- a/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/controller.go
+++ b/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/controller.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/reconciler.go b/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/reconciler.go
index 7429c7d9e..40ccc7af6 100644
--- a/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/reconciler.go
+++ b/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/reconciler.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/state.go b/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/state.go
index 0ab1ac508..6f423d037 100644
--- a/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/state.go
+++ b/pkg/client/injection/reconciler/bindings/v1beta1/kafkabinding/state.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/controller.go b/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/controller.go
index d63dacc3c..712a24d9d 100644
--- a/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/controller.go
+++ b/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/controller.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/reconciler.go b/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/reconciler.go
index 08e4a454d..bd435979e 100644
--- a/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/reconciler.go
+++ b/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/reconciler.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/state.go b/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/state.go
index 7e41e2d9d..f0cb7ddbc 100644
--- a/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/state.go
+++ b/pkg/client/injection/reconciler/messaging/v1alpha1/kafkachannel/state.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/controller.go b/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/controller.go
index 9e09a0769..9cffd8d93 100644
--- a/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/controller.go
+++ b/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/controller.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/reconciler.go b/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/reconciler.go
index 95d06c7f0..fbe3f339a 100644
--- a/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/reconciler.go
+++ b/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/reconciler.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/state.go b/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/state.go
index 502ad9fe7..6680c2985 100644
--- a/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/state.go
+++ b/pkg/client/injection/reconciler/messaging/v1beta1/kafkachannel/state.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/controller.go b/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/controller.go
index bf6184d17..7d9b082de 100644
--- a/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/controller.go
+++ b/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/controller.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/reconciler.go b/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/reconciler.go
index ab005968a..087f904d2 100644
--- a/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/reconciler.go
+++ b/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/reconciler.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/state.go b/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/state.go
index f86dcbaba..f0aa64315 100644
--- a/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/state.go
+++ b/pkg/client/injection/reconciler/sources/v1alpha1/kafkasource/state.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/controller.go b/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/controller.go
index d9d60929b..d22f53c31 100644
--- a/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/controller.go
+++ b/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/controller.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/reconciler.go b/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/reconciler.go
index 0fcf01418..89758b9cf 100644
--- a/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/reconciler.go
+++ b/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/reconciler.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/state.go b/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/state.go
index 745b9be46..3a74ea174 100644
--- a/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/state.go
+++ b/pkg/client/injection/reconciler/sources/v1beta1/kafkasource/state.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/bindings/v1alpha1/expansion_generated.go b/pkg/client/listers/bindings/v1alpha1/expansion_generated.go
index 00ad1366e..6f9eed5a2 100644
--- a/pkg/client/listers/bindings/v1alpha1/expansion_generated.go
+++ b/pkg/client/listers/bindings/v1alpha1/expansion_generated.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/bindings/v1alpha1/kafkabinding.go b/pkg/client/listers/bindings/v1alpha1/kafkabinding.go
index c02033203..ecdbe912d 100644
--- a/pkg/client/listers/bindings/v1alpha1/kafkabinding.go
+++ b/pkg/client/listers/bindings/v1alpha1/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/bindings/v1beta1/expansion_generated.go b/pkg/client/listers/bindings/v1beta1/expansion_generated.go
index 1c5db722c..57a2c44ef 100644
--- a/pkg/client/listers/bindings/v1beta1/expansion_generated.go
+++ b/pkg/client/listers/bindings/v1beta1/expansion_generated.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/bindings/v1beta1/kafkabinding.go b/pkg/client/listers/bindings/v1beta1/kafkabinding.go
index b6e449dfe..7a26e6756 100644
--- a/pkg/client/listers/bindings/v1beta1/kafkabinding.go
+++ b/pkg/client/listers/bindings/v1beta1/kafkabinding.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/messaging/v1alpha1/expansion_generated.go b/pkg/client/listers/messaging/v1alpha1/expansion_generated.go
index 3a5886f02..b8ed4adcc 100644
--- a/pkg/client/listers/messaging/v1alpha1/expansion_generated.go
+++ b/pkg/client/listers/messaging/v1alpha1/expansion_generated.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/messaging/v1alpha1/kafkachannel.go b/pkg/client/listers/messaging/v1alpha1/kafkachannel.go
index cebfddf80..73a64c5cd 100644
--- a/pkg/client/listers/messaging/v1alpha1/kafkachannel.go
+++ b/pkg/client/listers/messaging/v1alpha1/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/messaging/v1beta1/expansion_generated.go b/pkg/client/listers/messaging/v1beta1/expansion_generated.go
index 8f4272236..63ae6fb6b 100644
--- a/pkg/client/listers/messaging/v1beta1/expansion_generated.go
+++ b/pkg/client/listers/messaging/v1beta1/expansion_generated.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/messaging/v1beta1/kafkachannel.go b/pkg/client/listers/messaging/v1beta1/kafkachannel.go
index c14736cb6..5f6fbc340 100644
--- a/pkg/client/listers/messaging/v1beta1/kafkachannel.go
+++ b/pkg/client/listers/messaging/v1beta1/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/sources/v1alpha1/expansion_generated.go b/pkg/client/listers/sources/v1alpha1/expansion_generated.go
index 1ccb377e7..160d0d81a 100644
--- a/pkg/client/listers/sources/v1alpha1/expansion_generated.go
+++ b/pkg/client/listers/sources/v1alpha1/expansion_generated.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/sources/v1alpha1/kafkasource.go b/pkg/client/listers/sources/v1alpha1/kafkasource.go
index 9c4113a1a..c663cc0e7 100644
--- a/pkg/client/listers/sources/v1alpha1/kafkasource.go
+++ b/pkg/client/listers/sources/v1alpha1/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/sources/v1beta1/expansion_generated.go b/pkg/client/listers/sources/v1beta1/expansion_generated.go
index 09bd2e734..9a445b2c1 100644
--- a/pkg/client/listers/sources/v1beta1/expansion_generated.go
+++ b/pkg/client/listers/sources/v1beta1/expansion_generated.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.
diff --git a/pkg/client/listers/sources/v1beta1/kafkasource.go b/pkg/client/listers/sources/v1beta1/kafkasource.go
index a7f5e7899..cb622a34a 100644
--- a/pkg/client/listers/sources/v1beta1/kafkasource.go
+++ b/pkg/client/listers/sources/v1beta1/kafkasource.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2020 The Knative Authors
+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.


Test patch:
diff --git a/pkg/channel/distributed/dispatcher/dispatcher/handler_test.go b/pkg/channel/distributed/dispatcher/dispatcher/handler_test.go
index f80d05d8a..9d9b06795 100644
--- a/pkg/channel/distributed/dispatcher/dispatcher/handler_test.go
+++ b/pkg/channel/distributed/dispatcher/dispatcher/handler_test.go
@@ -294,7 +294,7 @@ func TestCheckRetry(t *testing.T) {
 		{
 			name:     "Http StatusCode 400",
 			response: &http.Response{StatusCode: http.StatusBadRequest},
-			result:   true,
+			result:   false,
 		},
 		{
 			name:     "Http StatusCode 401",