Repository: knative-sandbox/eventing-kafka-broker
Pull request #1703 (2022-01-07 11:05:30)

[Automated] Update eventing-kafka-broker-eventing nightly
/assign @knative/delivery-wg-leads
/cc @knative/delivery-wg-leads

Produced via:
```shell
for x in eventing-crds.yaml eventing-core.yaml; do
  curl https://storage.googleapis.com/knative-nightly/eventing/latest/$x > ${GITHUB_WORKSPACE}/./third_party/eventing-latest/$x
done
```

Details:
```

```

knative-prow-robot: @knative-automation: GitHub didn't allow me to request PR reviews from the following users: knative/delivery-wg-leads.

Note that only [knative-sandbox members](https://github.com/orgs/knative-sandbox/people) and repo collaborators can review this PR, and authors cannot review their own PRs.

<details>

In response to [this](https://github.com/knative-sandbox/eventing-kafka-broker/pull/1703):

>/assign @knative/delivery-wg-leads
>/cc @knative/delivery-wg-leads
>
>Produced via:
>```shell
>for x in eventing-crds.yaml eventing-core.yaml; do
>  curl https://storage.googleapis.com/knative-nightly/eventing/latest/$x > ${GITHUB_WORKSPACE}/./third_party/eventing-latest/$x
>done
>```
>
>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: [APPROVALNOTIFIER] This PR is **NOT APPROVED**

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

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

- **[OWNERS](https://github.com/knative-sandbox/eventing-kafka-broker/blob/main/OWNERS)**

Approvers can indicate their approval by writing `/approve` in a comment
Approvers can cancel approval by writing `/approve cancel` in a comment
</details>
<!-- META={"approvers":["devguyio"]} -->
codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) Report
> Merging [#1703](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (3b7227d) into [main](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/commit/3e5d4fd3e6910357df32f23d79bebff6aee29af9?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (3e5d4fd) will **increase** coverage by `9.08%`.
> The diff coverage is `n/a`.

[![Impacted file tree graph](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/graphs/tree.svg?width=650&height=150&src=pr&token=xyPIgGOiwy&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)

```diff
@@             Coverage Diff              @@
##               main    #1703      +/-   ##
============================================
+ Coverage     72.71%   81.80%   +9.08%     
+ Complexity      597      595       -2     
============================================
  Files           120       66      -54     
  Lines          4428     1929    -2499     
  Branches        171      171              
============================================
- Hits           3220     1578    -1642     
+ Misses          944      261     -683     
+ Partials        264       90     -174     
```

| Flag | Coverage Δ | |
|---|---|---|
| java-unittests | `81.80% <ø> (-0.11%)` | :arrow_down: |

Flags with carried forward coverage won't be shown. [Click here](https://docs.codecov.io/docs/carryforward-flags?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#carryforward-flags-in-the-pull-request-comment) to find out more.

| [Impacted Files](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) | Coverage Δ | |
|---|---|---|
| [...dispatcher/impl/consumer/BaseConsumerVerticle.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvaW1wbC9jb25zdW1lci9CYXNlQ29uc3VtZXJWZXJ0aWNsZS5qYXZh) | `87.50% <0.00%> (-6.25%)` | :arrow_down: |
| [...lane/pkg/reconciler/base/receiver\_condition\_set.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9iYXNlL3JlY2VpdmVyX2NvbmRpdGlvbl9zZXQuZ28=) | | |
| [control-plane/pkg/reconciler/channel/channel.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9jaGFubmVsL2NoYW5uZWwuZ28=) | | |
| [control-plane/pkg/reconciler/broker/controller.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9icm9rZXIvY29udHJvbGxlci5nbw==) | | |
| [...lane/pkg/reconciler/consumergroup/consumergroup.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9jb25zdW1lcmdyb3VwL2NvbnN1bWVyZ3JvdXAuZ28=) | | |
| [control-plane/pkg/receiver/path.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjZWl2ZXIvcGF0aC5nbw==) | | |
| [control-plane/pkg/security/secrets\_tracker.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvc2VjdXJpdHkvc2VjcmV0c190cmFja2VyLmdv) | | |
| [control-plane/pkg/reconciler/kafka/broker\_class.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvcmVjb25jaWxlci9rYWZrYS9icm9rZXJfY2xhc3MuZ28=) | | |
| [...kafka/eventing/v1alpha1/consumer\_group\_defaults.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvYXBpcy9pbnRlcm5hbHMva2Fma2EvZXZlbnRpbmcvdjFhbHBoYTEvY29uc3VtZXJfZ3JvdXBfZGVmYXVsdHMuZ28=) | | |
| [...ol-plane/pkg/apis/eventing/v1/broker\_validation.go](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-Y29udHJvbC1wbGFuZS9wa2cvYXBpcy9ldmVudGluZy92MS9icm9rZXJfdmFsaWRhdGlvbi5nbw==) | | |
| ... and [45 more](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703/diff?src=pr&el=tree-more&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) | |

------

[Continue to review full report at Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703?src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Last update [3e5d4fd...3b7227d](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1703?src=pr&el=lastupdated&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox).


Patch:
diff --git a/.gitignore b/.gitignore
index 88cbbf329..2c2295fc7 100644
--- a/.gitignore
+++ b/.gitignore
@@ -31,5 +31,6 @@ data-plane/**/build/
 eventing-kafka-controller.yaml
 eventing-kafka-source.yaml
 eventing-kafka-broker.yaml
+eventing-kafka-channel.yaml
 eventing-kafka-sink.yaml
 
diff --git a/control-plane/pkg/reconciler/broker/broker.go b/control-plane/pkg/reconciler/broker/broker.go
index d5596fc8a..7fcee74bb 100644
--- a/control-plane/pkg/reconciler/broker/broker.go
+++ b/control-plane/pkg/reconciler/broker/broker.go
@@ -380,6 +380,11 @@ func (r *Reconciler) reconcilerBrokerResource(ctx context.Context, topic string,
 			},
 		},
 		BootstrapServers: config.GetBootstrapServers(),
+		Reference: &contract.Reference{
+			Uuid:      string(broker.GetUID()),
+			Namespace: broker.GetNamespace(),
+			Name:      broker.GetName(),
+		},
 	}
 
 	if secret != nil {
diff --git a/control-plane/pkg/reconciler/channel/channel.go b/control-plane/pkg/reconciler/channel/channel.go
index c7068a1eb..428d284f5 100644
--- a/control-plane/pkg/reconciler/channel/channel.go
+++ b/control-plane/pkg/reconciler/channel/channel.go
@@ -535,6 +535,11 @@ func (r *Reconciler) getChannelContractResource(ctx context.Context, topic strin
 			},
 		},
 		BootstrapServers: config.GetBootstrapServers(),
+		Reference: &contract.Reference{
+			Uuid:      string(channel.GetUID()),
+			Namespace: channel.GetNamespace(),
+			Name:      channel.GetName(),
+		},
 	}
 
 	if secret != nil {
diff --git a/control-plane/pkg/reconciler/sink/kafka_sink.go b/control-plane/pkg/reconciler/sink/kafka_sink.go
index 3609b1506..c4f870ae7 100644
--- a/control-plane/pkg/reconciler/sink/kafka_sink.go
+++ b/control-plane/pkg/reconciler/sink/kafka_sink.go
@@ -175,6 +175,11 @@ func (r *Reconciler) reconcileKind(ctx context.Context, ks *eventing.KafkaSink)
 			IngressType: &contract.Ingress_Path{Path: receiver.PathFromObject(ks)},
 		},
 		BootstrapServers: kafka.BootstrapServersCommaSeparated(ks.Spec.BootstrapServers),
+		Reference: &contract.Reference{
+			Uuid:      string(ks.GetUID()),
+			Namespace: ks.GetNamespace(),
+			Name:      ks.GetName(),
+		},
 	}
 	if ks.Spec.HasAuthConfig() {
 		sinkConfig.Auth = &contract.Resource_AuthSecret{


Test patch:
diff --git a/control-plane/pkg/reconciler/broker/broker_test.go b/control-plane/pkg/reconciler/broker/broker_test.go
index 7f4f3f2c3..757685137 100644
--- a/control-plane/pkg/reconciler/broker/broker_test.go
+++ b/control-plane/pkg/reconciler/broker/broker_test.go
@@ -144,6 +144,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -203,6 +204,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -264,6 +266,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -324,6 +327,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
 							EgressConfig:     &contract.EgressConfig{DeadLetter: ServiceURL},
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 2,
@@ -382,6 +386,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
 							EgressConfig:     &contract.EgressConfig{DeadLetter: ServiceURLFrom(BrokerNamespace, ServiceName)},
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 2,
@@ -486,6 +491,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
 							EgressConfig:     &contract.EgressConfig{DeadLetter: ServiceURL},
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -541,6 +547,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -621,6 +628,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -707,6 +715,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
 							EgressConfig:     &contract.EgressConfig{DeadLetter: "http://www.my-sink.com/api"},
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -798,6 +807,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -877,6 +887,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 2,
@@ -929,6 +940,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -1046,6 +1058,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 						},
 					},
 					Generation: 1,
@@ -1117,6 +1130,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							Auth: &contract.Resource_AuthSecret{
 								AuthSecret: &contract.Reference{
 									Uuid:      SecretUUID,
@@ -1335,6 +1349,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							},
 							EgressConfig:     &contract.EgressConfig{DeadLetter: ServiceURL},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 						},
 					},
@@ -1422,6 +1437,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							EgressConfig: &contract.EgressConfig{
 								DeadLetter:    ServiceURL,
 								Retry:         10,
@@ -1487,6 +1503,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							EgressConfig: &contract.EgressConfig{
 								DeadLetter:    ServiceURL,
 								Retry:         10,
@@ -1552,6 +1569,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							EgressConfig: &contract.EgressConfig{
 								DeadLetter: ServiceURL,
 							},
@@ -1614,6 +1632,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							EgressConfig: &contract.EgressConfig{
 								DeadLetter:    ServiceURL,
 								Retry:         10,
@@ -1665,6 +1684,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							EgressConfig:     &contract.EgressConfig{DeadLetter: ServiceURL},
 						},
 					},
@@ -1714,6 +1734,7 @@ func brokerReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{BrokerTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_BINARY, IngressType: &contract.Ingress_Path{Path: receiver.Path(BrokerNamespace, BrokerName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        BrokerReference(),
 							EgressConfig:     &contract.EgressConfig{DeadLetter: ServiceURL},
 						},
 					},
diff --git a/control-plane/pkg/reconciler/channel/channel_test.go b/control-plane/pkg/reconciler/channel/channel_test.go
index 438e1d885..eecb34858 100644
--- a/control-plane/pkg/reconciler/channel/channel_test.go
+++ b/control-plane/pkg/reconciler/channel/channel_test.go
@@ -22,9 +22,10 @@ import (
 	"testing"
 
 	"github.com/Shopify/sarama"
+	"knative.dev/pkg/network"
+
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/kafka"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/security"
-	"knative.dev/pkg/network"
 
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/runtime"
@@ -147,6 +148,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -215,6 +217,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -285,6 +288,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -356,6 +360,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -429,6 +434,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -502,6 +508,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -578,6 +585,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -855,6 +863,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -929,6 +938,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Auth: &contract.Resource_AuthSecret{
 								AuthSecret: &contract.Reference{
 									Uuid:      SecretUUID,
@@ -1009,6 +1019,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
@@ -1078,6 +1089,7 @@ func TestReconcileKind(t *testing.T) {
 							Uid:              ChannelUUID,
 							Topics:           []string{ChannelTopic()},
 							BootstrapServers: ChannelBootstrapServers,
+							Reference:        ChannelReference(),
 							Ingress: &contract.Ingress{
 								IngressType: &contract.Ingress_Path{
 									Path: receiver.Path(ChannelNamespace, ChannelName),
diff --git a/control-plane/pkg/reconciler/sink/kafka_sink_test.go b/control-plane/pkg/reconciler/sink/kafka_sink_test.go
index c62a9001c..524d54a8f 100644
--- a/control-plane/pkg/reconciler/sink/kafka_sink_test.go
+++ b/control-plane/pkg/reconciler/sink/kafka_sink_test.go
@@ -133,6 +133,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -186,6 +187,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Uid:              SinkUUID,
 							Topics:           []string{SinkTopic()},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							Auth: &contract.Resource_AuthSecret{
 								AuthSecret: &contract.Reference{
@@ -252,6 +254,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Uid:              SinkUUID,
 							Topics:           []string{SinkTopic()},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 							Ingress: &contract.Ingress{
 								ContentMode: contract.ContentMode_STRUCTURED,
 								IngressType: &contract.Ingress_Path{
@@ -370,6 +373,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{"my-topic-1"},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: "kafka-broker:10000",
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -476,6 +480,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -525,6 +530,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -597,6 +603,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -642,6 +649,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Uid:              SinkUUID,
 							Topics:           []string{SinkTopic()},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED},
 						},
 					},
@@ -667,6 +675,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -744,6 +753,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -798,6 +808,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -857,6 +868,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
@@ -910,6 +922,7 @@ func sinkReconciliation(t *testing.T, format string, env config.Env) {
 							Topics:           []string{SinkTopic()},
 							Ingress:          &contract.Ingress{ContentMode: contract.ContentMode_STRUCTURED, IngressType: &contract.Ingress_Path{Path: receiver.Path(SinkNamespace, SinkName)}},
 							BootstrapServers: bootstrapServers,
+							Reference:        SinkReference(),
 						},
 					},
 					Generation: 1,
diff --git a/control-plane/pkg/reconciler/testing/objects_broker.go b/control-plane/pkg/reconciler/testing/objects_broker.go
index 4af25d83f..5e1e368bf 100644
--- a/control-plane/pkg/reconciler/testing/objects_broker.go
+++ b/control-plane/pkg/reconciler/testing/objects_broker.go
@@ -33,6 +33,7 @@ import (
 	"knative.dev/pkg/network"
 
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/config"
+	"knative.dev/eventing-kafka-broker/control-plane/pkg/contract"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/prober"
 
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/base"
@@ -231,6 +232,14 @@ func BrokerAddressable(env *config.Env) func(broker *eventing.Broker) {
 	}
 }
 
+func BrokerReference() *contract.Reference {
+	return &contract.Reference{
+		Uuid:      BrokerUUID,
+		Namespace: BrokerNamespace,
+		Name:      BrokerName,
+	}
+}
+
 func BrokerDLSResolved(uri string) func(broker *eventing.Broker) {
 	return func(broker *eventing.Broker) {
 		broker.Status.DeadLetterSinkURI, _ = apis.ParseURL(uri)
diff --git a/control-plane/pkg/reconciler/testing/objects_channel.go b/control-plane/pkg/reconciler/testing/objects_channel.go
index 675b518da..336fc2ece 100644
--- a/control-plane/pkg/reconciler/testing/objects_channel.go
+++ b/control-plane/pkg/reconciler/testing/objects_channel.go
@@ -25,15 +25,17 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	clientgotesting "k8s.io/client-go/testing"
-	"knative.dev/eventing-kafka-broker/control-plane/pkg/config"
-	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/base"
-	. "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/channel"
-	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/kafka"
 	messagingv1beta1 "knative.dev/eventing-kafka/pkg/apis/messaging/v1beta1"
 	eventingduckv1 "knative.dev/eventing/pkg/apis/duck/v1"
 	"knative.dev/pkg/apis"
 	duckv1 "knative.dev/pkg/apis/duck/v1"
 	"knative.dev/pkg/network"
+
+	"knative.dev/eventing-kafka-broker/control-plane/pkg/config"
+	"knative.dev/eventing-kafka-broker/control-plane/pkg/contract"
+	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/base"
+	. "knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/channel"
+	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/kafka"
 )
 
 const (
@@ -174,6 +176,14 @@ func ChannelAddressable(env *config.Env) func(obj duckv1.KRShaped) {
 	}
 }
 
+func ChannelReference() *contract.Reference {
+	return &contract.Reference{
+		Uuid:      ChannelUUID,
+		Namespace: ChannelNamespace,
+		Name:      ChannelName,
+	}
+}
+
 func WithInitKafkaChannelConditions(obj duckv1.KRShaped) {
 	channel := obj.(*messagingv1beta1.KafkaChannel)
 	channel.Status.InitializeConditions()
diff --git a/control-plane/pkg/reconciler/testing/objects_sink.go b/control-plane/pkg/reconciler/testing/objects_sink.go
index bc41426c2..7aaea0294 100644
--- a/control-plane/pkg/reconciler/testing/objects_sink.go
+++ b/control-plane/pkg/reconciler/testing/objects_sink.go
@@ -32,6 +32,7 @@ import (
 
 	eventing "knative.dev/eventing-kafka-broker/control-plane/pkg/apis/eventing/v1alpha1"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/config"
+	"knative.dev/eventing-kafka-broker/control-plane/pkg/contract"
 	"knative.dev/eventing-kafka-broker/control-plane/pkg/reconciler/base"
 )
 
@@ -126,6 +127,14 @@ func SinkAddressable(configs *config.Env) func(obj duckv1.KRShaped) {
 	}
 }
 
+func SinkReference() *contract.Reference {
+	return &contract.Reference{
+		Uuid:      SinkUUID,
+		Namespace: SinkNamespace,
+		Name:      SinkName,
+	}
+}
+
 func SinkReceiverPod(namespace string, annotations map[string]string) runtime.Object {
 	return &corev1.Pod{
 		TypeMeta: metav1.TypeMeta{
diff --git a/third_party/eventing-latest/eventing-core.yaml b/third_party/eventing-latest/eventing-core.yaml
index bce70da4a..15aacae91 100644
--- a/third_party/eventing-latest/eventing-core.yaml
+++ b/third_party/eventing-latest/eventing-core.yaml
@@ -16,8 +16,8 @@ kind: Namespace
 metadata:
   name: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 
 ---
@@ -41,8 +41,8 @@ metadata:
   name: eventing-controller
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -50,8 +50,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -67,8 +67,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -84,8 +84,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-source-observer
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -101,8 +101,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-sources-controller
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -118,8 +118,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-controller-manipulator
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -151,8 +151,8 @@ metadata:
   name: pingsource-mt-adapter
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -160,8 +160,8 @@ kind: ClusterRoleBinding
 metadata:
   name: knative-eventing-pingsource-mt-adapter
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -193,8 +193,8 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 ---
 apiVersion: rbac.authorization.k8s.io/v1
@@ -202,8 +202,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -220,8 +220,8 @@ metadata:
   namespace: knative-eventing
   name: eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -237,8 +237,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -254,8 +254,8 @@ kind: ClusterRoleBinding
 metadata:
   name: eventing-webhook-podspecable-binding
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 subjects:
   - kind: ServiceAccount
@@ -287,8 +287,8 @@ metadata:
   name: config-br-default-channel
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 data:
   channel-template-spec: |
@@ -316,8 +316,8 @@ metadata:
   name: config-br-defaults
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 data:
   # Configures the default for any Broker that does not specify a spec.config or Broker class.
@@ -350,8 +350,8 @@ metadata:
   name: default-ch-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 data:
   # Configuration for defaulting channels that do not specify CRD implementations.
@@ -385,10 +385,10 @@ metadata:
   name: config-ping-defaults
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
   annotations:
     knative.dev/example-checksum: "9185c153"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 data:
   _example: |
@@ -432,10 +432,10 @@ metadata:
   name: config-features
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 data:
   # ALPHA feature: The kreference-group allows you to use the Group field in KReferences.
@@ -479,7 +479,7 @@ metadata:
   name: config-kreference-mapping
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
   annotations:
@@ -528,8 +528,8 @@ metadata:
   name: config-leader-election
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "f7948630"
@@ -590,10 +590,10 @@ metadata:
   name: config-logging
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 data:
   # Common configuration for all Knative codebase
@@ -644,10 +644,10 @@ metadata:
   name: config-observability
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "f46cf09d"
@@ -721,10 +721,10 @@ metadata:
   name: config-tracing
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/config-propagation: original
     knative.dev/config-category: eventing
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   annotations:
     knative.dev/example-checksum: "0492ceb0"
@@ -779,10 +779,10 @@ metadata:
   name: eventing-controller
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/high-availability: "true"
     app.kubernetes.io/component: eventing-controller
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -792,9 +792,9 @@ spec:
     metadata:
       labels:
         app: eventing-controller
-        eventing.knative.dev/release: "v20220105-4348c2923"
+        eventing.knative.dev/release: "v20220106-1ae8a4903"
         app.kubernetes.io/component: eventing-autoscaler
-        app.kubernetes.io/version: "20220105-4348c2923"
+        app.kubernetes.io/version: "20220106-1ae8a4903"
         app.kubernetes.io/name: knative-eventing
     spec:
       # To avoid node becoming SPOF, spread our replicas to different nodes.
@@ -812,7 +812,7 @@ spec:
       containers:
         - name: eventing-controller
           terminationMessagePolicy: FallbackToLogsOnError
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/controller@sha256:42b2026c2e22f24c1c01a7fe79dccfafb50e6e4ae071bc545b03c3fe93d6dd49
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/controller@sha256:9c48a9a9be9c3039b7b7e12b77c1ee2320f619e8556b6dbfd64b322b5261b843
           resources:
             requests:
               cpu: 100m
@@ -830,7 +830,7 @@ spec:
               value: knative.dev/eventing
             # APIServerSource
             - name: APISERVER_RA_IMAGE
-              value: gcr.io/knative-nightly/knative.dev/eventing/cmd/apiserver_receive_adapter@sha256:8a919b11942b283d1713b2b7c8a7efe68771fad3e3fa42c593988a60518d545a
+              value: gcr.io/knative-nightly/knative.dev/eventing/cmd/apiserver_receive_adapter@sha256:3e5177f36911ea889be28b2164d00d2307601e0e9eaf28cb15e73ccd59e0f0c3
             - name: POD_NAME
               valueFrom:
                 fieldRef:
@@ -879,9 +879,9 @@ metadata:
   name: pingsource-mt-adapter
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     app.kubernetes.io/component: pingsource-mt-adapter
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   # when set to 0 (and only 0) will be set to 1 when the first PingSource is created.
@@ -894,9 +894,9 @@ spec:
     metadata:
       labels:
         !!merge <<: *labels
-        eventing.knative.dev/release: "v20220105-4348c2923"
+        eventing.knative.dev/release: "v20220106-1ae8a4903"
         app.kubernetes.io/component: pingsource-mt-adapter
-        app.kubernetes.io/version: "20220105-4348c2923"
+        app.kubernetes.io/version: "20220106-1ae8a4903"
         app.kubernetes.io/name: knative-eventing
     spec:
       affinity:
@@ -910,7 +910,7 @@ spec:
       enableServiceLinks: false
       containers:
         - name: dispatcher
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/mtping@sha256:70f95d48f96152ded8207347055634edffbd212ae29fc4162806061d237f5261
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/mtping@sha256:45f762fd5d7aa8ee183c69942b0e57dfe2244e5b67028f42685d8db5ae04466f
           env:
             - name: SYSTEM_NAMESPACE
               value: ''
@@ -975,9 +975,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   scaleTargetRef:
@@ -1001,9 +1001,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   minAvailable: 80%
@@ -1032,9 +1032,9 @@ metadata:
   name: eventing-webhook
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   selector:
@@ -1045,9 +1045,9 @@ spec:
     metadata:
       labels:
         !!merge <<: *labels
-        eventing.knative.dev/release: "v20220105-4348c2923"
+        eventing.knative.dev/release: "v20220106-1ae8a4903"
         app.kubernetes.io/component: eventing-webhook
-        app.kubernetes.io/version: "20220105-4348c2923"
+        app.kubernetes.io/version: "20220106-1ae8a4903"
         app.kubernetes.io/name: knative-eventing
     spec:
       # To avoid node becoming SPOF, spread our replicas to different nodes.
@@ -1067,7 +1067,7 @@ spec:
           terminationMessagePolicy: FallbackToLogsOnError
           # This is the Go import path for the binary that is containerized
           # and substituted here.
-          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/webhook@sha256:dbf69a815a4676ef5abbe1b6ec64b43848c74f27db527788162c1e2e3ff659da
+          image: gcr.io/knative-nightly/knative.dev/eventing/cmd/webhook@sha256:bcc6f54eb59eecd4e696d57fc7db54a4009f15068f8d2d22cda12151a03504c5
           resources:
             requests:
               # taken from serving.
@@ -1136,10 +1136,10 @@ apiVersion: v1
 kind: Service
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     role: eventing-webhook
     app.kubernetes.io/component: eventing-webhook
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   name: eventing-webhook
   namespace: knative-eventing
@@ -1171,11 +1171,11 @@ kind: CustomResourceDefinition
 metadata:
   creationTimestamp: null
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -1387,10 +1387,10 @@ kind: CustomResourceDefinition
 metadata:
   name: brokers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -1554,11 +1554,11 @@ kind: CustomResourceDefinition
 metadata:
   name: channels.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -1826,11 +1826,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   name: containersources.sources.knative.dev
 spec:
@@ -1980,9 +1980,9 @@ kind: CustomResourceDefinition
 metadata:
   name: eventtypes.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -2109,10 +2109,10 @@ kind: CustomResourceDefinition
 metadata:
   name: parallels.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -2364,11 +2364,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -2555,10 +2555,10 @@ kind: CustomResourceDefinition
 metadata:
   name: sequences.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -2875,12 +2875,12 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   name: sinkbindings.sources.knative.dev
 spec:
@@ -3067,9 +3067,9 @@ kind: CustomResourceDefinition
 metadata:
   name: subscriptions.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -3279,9 +3279,9 @@ kind: CustomResourceDefinition
 metadata:
   name: triggers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -3465,8 +3465,8 @@ kind: ClusterRole
 metadata:
   name: addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -3479,9 +3479,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: service-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3499,9 +3499,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: serving-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3522,9 +3522,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: channel-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3549,9 +3549,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: broker-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3570,9 +3570,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: flows-addressable-resolver
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "addressable-resolver" role.
 rules:
@@ -3608,8 +3608,8 @@ kind: ClusterRole
 metadata:
   name: eventing-broker-filter
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3635,8 +3635,8 @@ kind: ClusterRole
 metadata:
   name: eventing-broker-ingress
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3653,8 +3653,8 @@ kind: ClusterRole
 metadata:
   name: eventing-config-reader
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3687,8 +3687,8 @@ kind: ClusterRole
 metadata:
   name: channelable-manipulator
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -3701,9 +3701,9 @@ kind: ClusterRole
 metadata:
   name: meta-channelable-manipulator
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/channelable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "channelable-manipulator" role.
 rules:
@@ -3741,9 +3741,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-eventing-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev"]
@@ -3755,9 +3755,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-messaging-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["messaging.knative.dev"]
@@ -3769,9 +3769,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-flows-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["flows.knative.dev"]
@@ -3783,9 +3783,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-sources-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["sources.knative.dev"]
@@ -3797,9 +3797,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: knative-bindings-namespaced-admin
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     rbac.authorization.k8s.io/aggregate-to-admin: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["bindings.knative.dev"]
@@ -3812,8 +3812,8 @@ metadata:
   name: knative-eventing-namespaced-edit
   labels:
     rbac.authorization.k8s.io/aggregate-to-edit: "true"
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev", "messaging.knative.dev", "sources.knative.dev", "flows.knative.dev", "bindings.knative.dev"]
@@ -3826,8 +3826,8 @@ metadata:
   name: knative-eventing-namespaced-view
   labels:
     rbac.authorization.k8s.io/aggregate-to-view: "true"
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups: ["eventing.knative.dev", "messaging.knative.dev", "sources.knative.dev", "flows.knative.dev", "bindings.knative.dev"]
@@ -3854,8 +3854,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-controller
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -3990,8 +3990,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-pingsource-mt-adapter
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4058,8 +4058,8 @@ kind: ClusterRole
 metadata:
   name: podspecable-binding
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -4072,9 +4072,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: builtin-podspecable-binding
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/podspecable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "podspecable-binding role.
 rules:
@@ -4120,8 +4120,8 @@ kind: ClusterRole
 metadata:
   name: source-observer
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 aggregationRule:
   clusterRoleSelectors:
@@ -4134,9 +4134,9 @@ apiVersion: rbac.authorization.k8s.io/v1
 metadata:
   name: eventing-sources-source-observer
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     duck.knative.dev/source: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # Do not use this role directly. These rules will be added to the "source-observer" role.
 rules:
@@ -4172,8 +4172,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-sources-controller
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   - apiGroups:
@@ -4259,8 +4259,8 @@ kind: ClusterRole
 metadata:
   name: knative-eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   # For watching logging configuration and getting certs.
@@ -4359,8 +4359,8 @@ metadata:
   namespace: knative-eventing
   name: knative-eventing-webhook
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 rules:
   # For manipulating certs into secrets.
@@ -4396,8 +4396,8 @@ kind: ValidatingWebhookConfiguration
 metadata:
   name: config.webhook.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4434,8 +4434,8 @@ kind: MutatingWebhookConfiguration
 metadata:
   name: webhook.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4468,8 +4468,8 @@ kind: ValidatingWebhookConfiguration
 metadata:
   name: validation.webhook.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
@@ -4503,8 +4503,8 @@ metadata:
   name: eventing-webhook-certs
   namespace: knative-eventing
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 # The data is populated at install time.
 
@@ -4528,8 +4528,8 @@ kind: MutatingWebhookConfiguration
 metadata:
   name: sinkbindings.webhook.sources.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 webhooks:
   - admissionReviewVersions: ["v1", "v1beta1"]
diff --git a/third_party/eventing-latest/eventing-crds.yaml b/third_party/eventing-latest/eventing-crds.yaml
index 03b8709fe..133fd5edb 100644
--- a/third_party/eventing-latest/eventing-crds.yaml
+++ b/third_party/eventing-latest/eventing-crds.yaml
@@ -17,11 +17,11 @@ kind: CustomResourceDefinition
 metadata:
   creationTimestamp: null
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -233,10 +233,10 @@ kind: CustomResourceDefinition
 metadata:
   name: brokers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -400,11 +400,11 @@ kind: CustomResourceDefinition
 metadata:
   name: channels.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     messaging.knative.dev/subscribable: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -672,11 +672,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   name: containersources.sources.knative.dev
 spec:
@@ -826,9 +826,9 @@ kind: CustomResourceDefinition
 metadata:
   name: eventtypes.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev
@@ -955,10 +955,10 @@ kind: CustomResourceDefinition
 metadata:
   name: parallels.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -1210,11 +1210,11 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   annotations:
     # TODO add schemas and descriptions
@@ -1401,10 +1401,10 @@ kind: CustomResourceDefinition
 metadata:
   name: sequences.flows.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
     duck.knative.dev/addressable: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: flows.knative.dev
@@ -1721,12 +1721,12 @@ apiVersion: apiextensions.k8s.io/v1
 kind: CustomResourceDefinition
 metadata:
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     eventing.knative.dev/source: "true"
     duck.knative.dev/source: "true"
     duck.knative.dev/binding: "true"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
   name: sinkbindings.sources.knative.dev
 spec:
@@ -1913,9 +1913,9 @@ kind: CustomResourceDefinition
 metadata:
   name: subscriptions.messaging.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: messaging.knative.dev
@@ -2125,9 +2125,9 @@ kind: CustomResourceDefinition
 metadata:
   name: triggers.eventing.knative.dev
   labels:
-    eventing.knative.dev/release: "v20220105-4348c2923"
+    eventing.knative.dev/release: "v20220106-1ae8a4903"
     knative.dev/crd-install: "true"
-    app.kubernetes.io/version: "20220105-4348c2923"
+    app.kubernetes.io/version: "20220106-1ae8a4903"
     app.kubernetes.io/name: knative-eventing
 spec:
   group: eventing.knative.dev