Repository: knative-sandbox/eventing-kafka-broker
Pull request #1151 (2021-08-19 20:01:54)

[data-plane]: Bump mockito-junit-jupiter from 3.11.1 to 3.12.0 in /data-plane
Bumps [mockito-junit-jupiter](https://github.com/mockito/mockito) from 3.11.1 to 3.12.0.
<details>
<summary>Release notes</summary>
<p><em>Sourced from <a href="https://github.com/mockito/mockito/releases">mockito-junit-jupiter's releases</a>.</em></p>
<blockquote>
<h2>v3.12.0</h2>
<p><!-- raw HTML omitted --><!-- raw HTML omitted --><em>Changelog generated by <a href="https://github.com/shipkit/shipkit-changelog">Shipkit Changelog Gradle Plugin</a></em><!-- raw HTML omitted --><!-- raw HTML omitted --></p>
<h4>3.12.0</h4>
<ul>
<li>2021-08-19 - <a href="https://github.com/mockito/mockito/compare/v3.11.2...v3.12.0">31 commit(s)</a> by EugeneLesnov, Lars Vogel, Logan Rosen, Rafael Winterhalter, Rob Pridham, Tim van der Lippe, dependabot[bot], saurabh7248</li>
<li>Add checks for sealed types [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2392">#2392</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2392">mockito/mockito#2392</a>)</li>
<li>Bump versions.bytebuddy from 1.11.10 to 1.11.12 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2388">#2388</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2388">mockito/mockito#2388</a>)</li>
<li>Bump versions.bytebuddy from 1.11.9 to 1.11.10 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2387">#2387</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2387">mockito/mockito#2387</a>)</li>
<li>Bump versions.errorprone from 2.8.0 to 2.8.1 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2386">#2386</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2386">mockito/mockito#2386</a>)</li>
<li>Update StaticMockTest to use unified verify method [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2385">#2385</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2385">mockito/mockito#2385</a>)</li>
<li>Reorder InjectMock Javadoc to fit the order of injection [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2383">#2383</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2383">mockito/mockito#2383</a>)</li>
<li>Bump core-ktx from 1.5.0 to 1.6.0 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2382">#2382</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2382">mockito/mockito#2382</a>)</li>
<li>Bump google-java-format from 1.10.0 to 1.11.0 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2381">#2381</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2381">mockito/mockito#2381</a>)</li>
<li>Downgrade Android gradle plugin [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2380">#2380</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2380">mockito/mockito#2380</a>)</li>
<li>Applied <a href="https://github.com/CheckReturnValue"><code>@​CheckReturnValue</code></a> to some classes [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2379">#2379</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2379">mockito/mockito#2379</a>)</li>
<li>how to solve gradle sync failed after 'Add basic Android instrumented and unit tests' [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2378">#2378</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2378">mockito/mockito#2378</a>)</li>
<li>Bump junit from 1.1.2 to 1.1.3 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2377">#2377</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2377">mockito/mockito#2377</a>)</li>
<li>Bump appcompat from 1.3.0 to 1.3.1 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2376">#2376</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2376">mockito/mockito#2376</a>)</li>
<li>Bump kotlin-gradle-plugin from 1.5.20 to 1.5.21 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2374">#2374</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2374">mockito/mockito#2374</a>)</li>
<li>Bump material from 1.3.0 to 1.4.0 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2373">#2373</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2373">mockito/mockito#2373</a>)</li>
<li>Bump espresso-core from 3.3.0 to 3.4.0 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2372">#2372</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2372">mockito/mockito#2372</a>)</li>
<li>Fixes <a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2331">#2331</a> [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2369">#2369</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2369">mockito/mockito#2369</a>)</li>
<li>Fix typo in exception [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2368">#2368</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2368">mockito/mockito#2368</a>)</li>
<li>Bump versions.bytebuddy from 1.11.8 to 1.11.9 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2367">#2367</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2367">mockito/mockito#2367</a>)</li>
<li>Bump versions.errorprone from 2.7.1 to 2.8.0 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2365">#2365</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2365">mockito/mockito#2365</a>)</li>
<li>Bump versions.bytebuddy from 1.11.7 to 1.11.8 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2361">#2361</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2361">mockito/mockito#2361</a>)</li>
<li>Basic Android instrumented and unit tests (closes <a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2341">#2341</a>) [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2360">#2360</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2360">mockito/mockito#2360</a>)</li>
<li>Bump versions.bytebuddy from 1.11.6 to 1.11.7 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2359">#2359</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2359">mockito/mockito#2359</a>)</li>
<li>Bump kotlin-stdlib from 1.5.20 to 1.5.21 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2356">#2356</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2356">mockito/mockito#2356</a>)</li>
<li>Bump kotlinx-coroutines-core from 1.5.1 to 1.5.1-native-mt [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2354">#2354</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2354">mockito/mockito#2354</a>)</li>
<li>Bump kotlinx-coroutines-core from 1.5.0-native-mt to 1.5.1 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2353">#2353</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2353">mockito/mockito#2353</a>)</li>
<li>Bump versions.bytebuddy from 1.11.5 to 1.11.6 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2351">#2351</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2351">mockito/mockito#2351</a>)</li>
<li>Bump gradle-errorprone-plugin from 2.0.1 to 2.0.2 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2347">#2347</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2347">mockito/mockito#2347</a>)</li>
<li>Bump kotlin-stdlib from 1.5.10 to 1.5.20 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2343">#2343</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2343">mockito/mockito#2343</a>)</li>
<li>Bump versions.bytebuddy from 1.11.3 to 1.11.5 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2337">#2337</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2337">mockito/mockito#2337</a>)</li>
<li>Bump assertj-core from 3.20.1 to 3.20.2 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2336">#2336</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2336">mockito/mockito#2336</a>)</li>
<li>Spy doesn't forward hashcode/equals to actual object [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2331">#2331</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2331">mockito/mockito#2331</a>)</li>
<li>Fixes mockito#2311 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2320">#2320</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2320">mockito/mockito#2320</a>)</li>
</ul>
<h2>v3.11.2</h2>
<p><!-- raw HTML omitted --><!-- raw HTML omitted --><em>Changelog generated by <a href="https://github.com/shipkit/shipkit-changelog">Shipkit Changelog Gradle Plugin</a></em><!-- raw HTML omitted --><!-- raw HTML omitted --></p>
<h4>3.11.2</h4>
<ul>
<li>2021-06-21 - <a href="https://github.com/mockito/mockito/compare/v3.11.1...v3.11.2">5 commit(s)</a> by dependabot[bot]</li>
<li>Bump versions.bytebuddy from 1.11.2 to 1.11.3 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2333">#2333</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2333">mockito/mockito#2333</a>)</li>
<li>Bump assertj-core from 3.20.0 to 3.20.1 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2332">#2332</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2332">mockito/mockito#2332</a>)</li>
<li>Bump org.eclipse.osgi from 3.16.200 to 3.16.300 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2330">#2330</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2330">mockito/mockito#2330</a>)</li>
<li>Bump assertj-core from 3.19.0 to 3.20.0 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2329">#2329</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2329">mockito/mockito#2329</a>)</li>
<li>Bump shipkit-auto-version from 1.1.17 to 1.1.19 [(<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2328">#2328</a>)](<a href="https://github-redirect.dependabot.com/mockito/mockito/pull/2328">mockito/mockito#2328</a>)</li>
</ul>
</blockquote>
</details>
<details>
<summary>Commits</summary>
<ul>
<li><a href="https://github.com/mockito/mockito/commit/96883a1fa39f29146144f9ccf2e43e9932dca6a1"><code>96883a1</code></a> Add checks for sealed types (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2392">#2392</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/28020c071b5ac9d1c6d88cf271e579a84967fa72"><code>28020c0</code></a> Bump versions.bytebuddy from 1.11.10 to 1.11.12 (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2388">#2388</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/0ceb46e8f5580afcf3d1ceeba5cea77493f134dd"><code>0ceb46e</code></a> Bump versions.bytebuddy from 1.11.9 to 1.11.10 (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2387">#2387</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/f62b196ba1e63e7647bd745d745cea9f47187218"><code>f62b196</code></a> Update StaticMockTest to use unified verify method (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2385">#2385</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/fc7f7e2cad2945e348712ab3910994e4aea61568"><code>fc7f7e2</code></a> Bump versions.errorprone from 2.8.0 to 2.8.1 (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2386">#2386</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/1a8750f816d2dd2cf03b5ab80e141cfc8250910d"><code>1a8750f</code></a> Reorder InjectMock Javadoc to fit the order of injection (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2383">#2383</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/f32973d4e709830a5a9fb19c54f32659023d2b03"><code>f32973d</code></a> Move <a href="https://github.com/CheckReturnValue"><code>@​CheckReturnValue</code></a> from methods to class scope (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2379">#2379</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/5891de126d398ec09a040711b688176ff27b7d7c"><code>5891de1</code></a> Bump espresso-core from 3.3.0 to 3.4.0 (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2372">#2372</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/3635e0e4495bf798af9f985ebaea7c4a74dc567e"><code>3635e0e</code></a> Bump google-java-format from 1.10.0 to 1.11.0 (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2381">#2381</a>)</li>
<li><a href="https://github.com/mockito/mockito/commit/18607948324da9421170190eee01242ec386d27c"><code>1860794</code></a> Bump core-ktx from 1.5.0 to 1.6.0 (<a href="https://github-redirect.dependabot.com/mockito/mockito/issues/2382">#2382</a>)</li>
<li>Additional commits viewable in <a href="https://github.com/mockito/mockito/compare/v3.11.1...v3.12.0">compare view</a></li>
</ul>
</details>
<br />


[![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=org.mockito:mockito-junit-jupiter&package-manager=maven&previous-version=3.11.1&new-version=3.12.0)](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores)

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting `@dependabot rebase`.

[//]: # (dependabot-automerge-start)
[//]: # (dependabot-automerge-end)

---

<details>
<summary>Dependabot commands and options</summary>
<br />

You can trigger Dependabot actions by commenting on this PR:
- `@dependabot rebase` will rebase this PR
- `@dependabot recreate` will recreate this PR, overwriting any edits that have been made to it
- `@dependabot merge` will merge this PR after your CI passes on it
- `@dependabot squash and merge` will squash and merge this PR after your CI passes on it
- `@dependabot cancel merge` will cancel a previously requested merge and block automerging
- `@dependabot reopen` will reopen this PR if it is closed
- `@dependabot close` will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
- `@dependabot ignore this major version` will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this minor version` will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
- `@dependabot ignore this dependency` will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)


</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/1151#" title="Author self-approved">dependabot[bot]</a>*
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please assign **evankanderson** after the PR has been reviewed.
You can assign the PR to them by writing `/assign @evankanderson` 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":["evankanderson"]} -->
knative-prow-robot: Hi @dependabot[bot]. 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-broker).

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

pierDipi: /ok-to-test
codecov[bot]: # [Codecov](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) Report
> Merging [#1151](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (d0d77ad) into [main](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/commit/14448ea6b2d1fa070abfc3e03f0b0049bc424126?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) (14448ea) will **decrease** coverage by `4.98%`.
> The diff coverage is `n/a`.

[![Impacted file tree graph](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/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/1151?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    #1151      +/-   ##
============================================
- Coverage     75.83%   70.84%   -4.99%     
============================================
  Files            87       29      -58     
  Lines          3033     1379    -1654     
  Branches        136        0     -136     
============================================
- Hits           2300      977    -1323     
+ Misses          568      307     -261     
+ Partials        165       95      -70     
```

| Flag | Coverage Δ | |
|---|---|---|
| java-unittests | `?` | |

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/1151?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox) | Coverage Δ | |
|---|---|---|
| [...venting/kafka/broker/core/tracing/TracingSpan.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9jb3JlL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2NvcmUvdHJhY2luZy9UcmFjaW5nU3Bhbi5qYXZh) | | |
| [...roker/dispatcher/impl/filter/BaseStringFilter.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvaW1wbC9maWx0ZXIvQmFzZVN0cmluZ0ZpbHRlci5qYXZh) | | |
| [...ka/broker/dispatcher/impl/filter/SuffixFilter.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvaW1wbC9maWx0ZXIvU3VmZml4RmlsdGVyLmphdmE=) | | |
| [...a/broker/dispatcher/impl/KafkaResponseHandler.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvaW1wbC9LYWZrYVJlc3BvbnNlSGFuZGxlci5qYXZh) | | |
| [...ative/eventing/kafka/broker/dispatcher/Filter.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvRmlsdGVyLmphdmE=) | | |
| [...kafka/broker/dispatcher/impl/filter/SqlFilter.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvaW1wbC9maWx0ZXIvU3FsRmlsdGVyLmphdmE=) | | |
| [...fka/broker/core/eventbus/ContractMessageCodec.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9jb3JlL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2NvcmUvZXZlbnRidXMvQ29udHJhY3RNZXNzYWdlQ29kZWMuamF2YQ==) | | |
| [...enting/kafka/broker/core/OrderedAsyncExecutor.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9jb3JlL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2NvcmUvT3JkZXJlZEFzeW5jRXhlY3V0b3IuamF2YQ==) | | |
| [...venting/kafka/broker/dispatcher/DeliveryOrder.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvRGVsaXZlcnlPcmRlci5qYXZh) | | |
| [...ting/kafka/broker/dispatcher/CloudEventSender.java](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox#diff-ZGF0YS1wbGFuZS9kaXNwYXRjaGVyL3NyYy9tYWluL2phdmEvZGV2L2tuYXRpdmUvZXZlbnRpbmcva2Fma2EvYnJva2VyL2Rpc3BhdGNoZXIvQ2xvdWRFdmVudFNlbmRlci5qYXZh) | | |
| ... and [48 more](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151/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/1151?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/1151?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=knative-sandbox). Last update [14448ea...d0d77ad](https://codecov.io/gh/knative-sandbox/eventing-kafka-broker/pull/1151?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).

knative-prow-robot: @dependabot[bot]: The following test **failed**, say `/retest` to rerun all failed tests or `/retest-required` to rerun all mandatory failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-broker-build-tests | d0d77ad80f378bab1295a30b55994f666d36b79a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka-broker/1151/pull-knative-sandbox-eventing-kafka-broker-build-tests/1428475816206929920) | `/test pull-knative-sandbox-eventing-kafka-broker-build-tests`

[Full PR test history](https://gubernator.knative.dev/pr/knative-sandbox_eventing-kafka-broker/1151). [Your PR dashboard](https://gubernator.knative.dev/pr/dependabot[bot]).

<details>

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

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka-broker/pull/1151#" title="Author self-approved">dependabot[bot]</a>*
To complete the [pull request process](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process), please ask for approval from **pierdipi** after the PR has been reviewed.

The full list of commands accepted by this bot can be found [here](https://go.k8s.io/bot-commands?repo=knative-sandbox%2Feventing-kafka-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":["pierdipi"]} -->

Patch:
diff --git a/OWNERS_ALIASES b/OWNERS_ALIASES
index 60e7653da..483e5ff0b 100644
--- a/OWNERS_ALIASES
+++ b/OWNERS_ALIASES
@@ -132,6 +132,7 @@ aliases:
   - nicolaferraro
   - rhuss
   knative-admin:
+  - ZhiminXiang
   - bsnchan
   - dprotaso
   - evankanderson
@@ -140,14 +141,12 @@ aliases:
   - knative-prow-robot
   - knative-prow-updater-robot
   - knative-test-reporter-robot
-  - lionelvillard
   - markusthoemmes
   - mbehrendt
   - pmorie
   - rhuss
   - thisisnotapril
   - vaikas
-  - yanweiguo
   knative-milestone-maintainers:
   - ZhiminXiang
   - akashrv
@@ -171,8 +170,8 @@ aliases:
   - vagababov
   - vaikas
   knative-release-leads:
-  - lionelvillard
-  - yanweiguo
+  - ZhiminXiang
+  - evankanderson
   knative-robots:
   - knative-prow-releaser-robot
   - knative-prow-robot
diff --git a/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go b/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go
index cd9219708..1071a3786 100644
--- a/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go
+++ b/control-plane/pkg/reconciler/trigger/trigger_lifecycle.go
@@ -133,7 +133,7 @@ func (m *statusConditionManager) subscriberResolved(egress *contract.Egress) {
 	if isDeadLetterSinkConfigured(egress.EgressConfig) {
 		m.Trigger.Status.MarkDeadLetterSinkResolvedSucceeded()
 		uri, _ /* safe to ignore */ := apis.ParseURL(egress.EgressConfig.DeadLetter)
-		m.Trigger.Status.DeadLetterURI = uri
+		m.Trigger.Status.DeadLetterSinkURI = uri
 	} else {
 		m.Trigger.Status.MarkDeadLetterSinkNotConfigured()
 	}
diff --git a/data-plane/THIRD-PARTY.txt b/data-plane/THIRD-PARTY.txt
index 715d8b9af..61d8510a0 100644
--- a/data-plane/THIRD-PARTY.txt
+++ b/data-plane/THIRD-PARTY.txt
@@ -113,8 +113,8 @@ Lists of 155 third-party dependencies.
      (The Apache Software License, Version 2.0) Zipkin Sender: OkHttp 3 (io.zipkin.reporter2:zipkin-sender-okhttp3:2.16.3 - https://github.com/openzipkin/zipkin-reporter-java/zipkin-sender-okhttp3)
      (The Apache Software License, Version 2.0) Zipkin Core Library (io.zipkin.zipkin2:zipkin:2.23.2 - https://github.com/openzipkin/zipkin/zipkin)
      (Eclipse Public License 1.0) JUnit (junit:junit:4.13.1 - http://junit.org)
-     (Apache License, Version 2.0) Byte Buddy (without dependencies) (net.bytebuddy:byte-buddy:1.11.2 - https://bytebuddy.net/byte-buddy)
-     (Apache License, Version 2.0) Byte Buddy agent (net.bytebuddy:byte-buddy-agent:1.11.2 - https://bytebuddy.net/byte-buddy-agent)
+     (Apache License, Version 2.0) Byte Buddy (without dependencies) (net.bytebuddy:byte-buddy:1.11.12 - https://bytebuddy.net/byte-buddy)
+     (Apache License, Version 2.0) Byte Buddy agent (net.bytebuddy:byte-buddy-agent:1.11.12 - https://bytebuddy.net/byte-buddy-agent)
      (Apache License, Version 2.0) (MIT License) Logstash Logback Encoder (net.logstash.logback:logstash-logback-encoder:6.6 - https://github.com/logstash/logstash-logback-encoder)
      (The MIT License) JOpt Simple (net.sf.jopt-simple:jopt-simple:4.6 - http://pholser.github.com/jopt-simple)
      (The MIT License) JOpt Simple (net.sf.jopt-simple:jopt-simple:5.0.4 - http://jopt-simple.github.io/jopt-simple)
@@ -141,8 +141,8 @@ Lists of 155 third-party dependencies.
      (Eclipse Public License v2.0) JUnit Platform Engine API (org.junit.platform:junit-platform-engine:1.7.2 - https://junit.org/junit5/)
      (Public Domain, per Creative Commons CC0) LatencyUtils (org.latencyutils:LatencyUtils:2.0.3 - http://latencyutils.github.io/LatencyUtils/)
      (The Apache Software License, Version 2.0) LZ4 and xxHash (org.lz4:lz4-java:1.7.1 - https://github.com/lz4/lz4-java)
-     (The MIT License) mockito-core (org.mockito:mockito-core:3.11.1 - https://github.com/mockito/mockito)
-     (The MIT License) mockito-junit-jupiter (org.mockito:mockito-junit-jupiter:3.11.1 - https://github.com/mockito/mockito)
+     (The MIT License) mockito-core (org.mockito:mockito-core:3.12.0 - https://github.com/mockito/mockito)
+     (The MIT License) mockito-junit-jupiter (org.mockito:mockito-junit-jupiter:3.12.0 - https://github.com/mockito/mockito)
      (Apache License, Version 2.0) Objenesis (org.objenesis:objenesis:3.2 - http://objenesis.org/objenesis)
      (GNU General Public License (GPL), version 2, with the Classpath exception) JMH Core (org.openjdk.jmh:jmh-core:1.33 - http://openjdk.java.net/projects/code-tools/jmh/jmh-core/)
      (GNU General Public License (GPL), version 2, with the Classpath exception) JMH Generators: Annotation Processors (org.openjdk.jmh:jmh-generator-annprocess:1.33 - http://openjdk.java.net/projects/code-tools/jmh/jmh-generator-annprocess/)
diff --git a/data-plane/pom.xml b/data-plane/pom.xml
index 69494fa12..9f29d90b1 100644
--- a/data-plane/pom.xml
+++ b/data-plane/pom.xml
@@ -53,7 +53,7 @@
     <assertj.version>3.20.1</assertj.version>
     <awaitility.version>4.1.0</awaitility.version>
     <junit.jupiter.version>5.7.2</junit.jupiter.version>
-    <mokito.junit.jupiter.version>3.11.1</mokito.junit.jupiter.version>
+    <mokito.junit.jupiter.version>3.12.0</mokito.junit.jupiter.version>
     <fabric8.kubernetes.version>5.7.0</fabric8.kubernetes.version>
     <kafka.version>2.7.0</kafka.version>
     <debezium.version>1.6.1.Final</debezium.version>
diff --git a/go.mod b/go.mod
index 62d25f38b..429c5e24f 100644
--- a/go.mod
+++ b/go.mod
@@ -21,8 +21,8 @@ require (
 	k8s.io/apiserver v0.20.7
 	k8s.io/client-go v0.20.7
 	k8s.io/utils v0.0.0-20210111153108-fddb29f9d009
-	knative.dev/eventing v0.25.1-0.20210818214503-4b18ab87646a
+	knative.dev/eventing v0.25.1-0.20210819160604-19fcdf4b2aed
 	knative.dev/hack v0.0.0-20210806075220-815cd312d65c
-	knative.dev/pkg v0.0.0-20210818135208-7b5ecbc0e477
+	knative.dev/pkg v0.0.0-20210819054404-bda81c029160
 	knative.dev/reconciler-test v0.0.0-20210806131721-1e1e9f72d9cd
 )
diff --git a/go.sum b/go.sum
index c801abedb..e45648fd9 100644
--- a/go.sum
+++ b/go.sum
@@ -1220,16 +1220,15 @@ k8s.io/kube-openapi v0.0.0-20201113171705-d219536bb9fd/go.mod h1:WOJ3KddDSol4tAG
 k8s.io/utils v0.0.0-20201110183641-67b214c5f920/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
 k8s.io/utils v0.0.0-20210111153108-fddb29f9d009 h1:0T5IaWHO3sJTEmCP6mUlBvMukxPKUQWqiI/YuiBNMiQ=
 k8s.io/utils v0.0.0-20210111153108-fddb29f9d009/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
-knative.dev/eventing v0.25.1-0.20210818214503-4b18ab87646a h1:5Qy+pV6/gn7o07b2bHuUeZ6AkfrOsgecahmA3IFr/vs=
-knative.dev/eventing v0.25.1-0.20210818214503-4b18ab87646a/go.mod h1:8jIsrnSONPgv+m63OTzpwZQJiQASYl77C3llCyYlBMU=
+knative.dev/eventing v0.25.1-0.20210819160604-19fcdf4b2aed h1:HRL8zo6EcWjb01g4Q842UVMns4mRosaj1A28OMZBuL4=
+knative.dev/eventing v0.25.1-0.20210819160604-19fcdf4b2aed/go.mod h1:5z8b751O9jUHaZbZTEnJB2ZkkvcurBb0YlqUxBtn9GI=
 knative.dev/hack v0.0.0-20210622141627-e28525d8d260/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
 knative.dev/hack v0.0.0-20210806075220-815cd312d65c h1:nOXoDWAAItwr4o0dp3nHr6skgpVD4IvME/UX84YNl5k=
 knative.dev/hack v0.0.0-20210806075220-815cd312d65c/go.mod h1:PHt8x8yX5Z9pPquBEfIj0X66f8iWkWfR0S/sarACJrI=
-knative.dev/hack/schema v0.0.0-20210622141627-e28525d8d260/go.mod h1:ffjwmdcrH5vN3mPhO8RrF2KfNnbHeCE2C60A+2cv3U0=
+knative.dev/hack/schema v0.0.0-20210806075220-815cd312d65c/go.mod h1:ffjwmdcrH5vN3mPhO8RrF2KfNnbHeCE2C60A+2cv3U0=
 knative.dev/pkg v0.0.0-20210803160015-21eb4c167cc5/go.mod h1:RPk5txNA3apR9X40D4MpUOP9/VqOG8CrtABWfOwGVS4=
-knative.dev/pkg v0.0.0-20210818135208-7b5ecbc0e477 h1:oHKwxMz8dV5pKXTAUOMbmZA0kgLkXKR11ISysegU/L8=
-knative.dev/pkg v0.0.0-20210818135208-7b5ecbc0e477/go.mod h1:RPk5txNA3apR9X40D4MpUOP9/VqOG8CrtABWfOwGVS4=
-knative.dev/reconciler-test v0.0.0-20210803183715-b61cc77c06f6/go.mod h1:+Kovy+G5zXZNcuO/uB+zfo37vFKZzsLIlWezt/nKMz0=
+knative.dev/pkg v0.0.0-20210819054404-bda81c029160 h1:1ae2qW+dz63xLcWcUxWdUzn9JDG98/4yTdGUECj6Joo=
+knative.dev/pkg v0.0.0-20210819054404-bda81c029160/go.mod h1:t6WzDPywQloi+AbOtiOejfpem1mLfKeuV+sjXGQLGN8=
 knative.dev/reconciler-test v0.0.0-20210806131721-1e1e9f72d9cd h1:mY2SFGIbL2gCw7o5fxyUMG0r2OcnChUKTGt3PtdIlas=
 knative.dev/reconciler-test v0.0.0-20210806131721-1e1e9f72d9cd/go.mod h1:+Kovy+G5zXZNcuO/uB+zfo37vFKZzsLIlWezt/nKMz0=
 modernc.org/cc v1.0.0/go.mod h1:1Sk4//wdnYJiUIxnW8ddKpaOJCF37yAdqYnkxUpaYxw=
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go
index 97ffc8759..d7b876c86 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_types.go
@@ -120,9 +120,9 @@ type TriggerStatus struct {
 	// +optional
 	SubscriberURI *apis.URL `json:"subscriberUri,omitempty"`
 
-	// DeadLetterURI is the resolved URI of the dead letter sink for this Trigger.
+	// DeadLetterSinkURI is the resolved URI of the dead letter sink for this Trigger.
 	// +optional
-	DeadLetterURI *apis.URL `json:"deadLetterUri,omitempty"`
+	DeadLetterSinkURI *apis.URL `json:"deadLetterSinkUri,omitempty"`
 }
 
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/zz_generated.deepcopy.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/zz_generated.deepcopy.go
index 7be79a4ee..908b4e354 100644
--- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/zz_generated.deepcopy.go
+++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/zz_generated.deepcopy.go
@@ -274,8 +274,8 @@ func (in *TriggerStatus) DeepCopyInto(out *TriggerStatus) {
 		*out = new(apis.URL)
 		(*in).DeepCopyInto(*out)
 	}
-	if in.DeadLetterURI != nil {
-		in, out := &in.DeadLetterURI, &out.DeadLetterURI
+	if in.DeadLetterSinkURI != nil {
+		in, out := &in.DeadLetterSinkURI, &out.DeadLetterSinkURI
 		*out = new(apis.URL)
 		(*in).DeepCopyInto(*out)
 	}
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/client/client.go b/vendor/knative.dev/eventing/pkg/client/injection/client/client.go
index b54ffc81d..1d6f31800 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/client/client.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/client/client.go
@@ -20,27 +20,56 @@ package client
 
 import (
 	context "context"
+	json "encoding/json"
+	errors "errors"
+	fmt "fmt"
 
+	v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	unstructured "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
+	runtime "k8s.io/apimachinery/pkg/runtime"
+	schema "k8s.io/apimachinery/pkg/runtime/schema"
+	types "k8s.io/apimachinery/pkg/types"
+	watch "k8s.io/apimachinery/pkg/watch"
+	discovery "k8s.io/client-go/discovery"
+	dynamic "k8s.io/client-go/dynamic"
 	rest "k8s.io/client-go/rest"
+	eventingv1 "knative.dev/eventing/pkg/apis/eventing/v1"
+	v1beta1 "knative.dev/eventing/pkg/apis/eventing/v1beta1"
+	flowsv1 "knative.dev/eventing/pkg/apis/flows/v1"
+	messagingv1 "knative.dev/eventing/pkg/apis/messaging/v1"
+	sourcesv1 "knative.dev/eventing/pkg/apis/sources/v1"
+	v1beta2 "knative.dev/eventing/pkg/apis/sources/v1beta2"
 	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
+	typedeventingv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/eventing/v1"
+	typedeventingv1beta1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/eventing/v1beta1"
+	typedflowsv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/flows/v1"
+	typedmessagingv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/messaging/v1"
+	typedsourcesv1 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1"
+	typedsourcesv1beta2 "knative.dev/eventing/pkg/client/clientset/versioned/typed/sources/v1beta2"
 	injection "knative.dev/pkg/injection"
+	dynamicclient "knative.dev/pkg/injection/clients/dynamicclient"
 	logging "knative.dev/pkg/logging"
 )
 
 func init() {
-	injection.Default.RegisterClient(withClient)
+	injection.Default.RegisterClient(withClientFromConfig)
 	injection.Default.RegisterClientFetcher(func(ctx context.Context) interface{} {
 		return Get(ctx)
 	})
+	injection.Dynamic.RegisterDynamicClient(withClientFromDynamic)
 }
 
 // Key is used as the key for associating information with a context.Context.
 type Key struct{}
 
-func withClient(ctx context.Context, cfg *rest.Config) context.Context {
+func withClientFromConfig(ctx context.Context, cfg *rest.Config) context.Context {
 	return context.WithValue(ctx, Key{}, versioned.NewForConfigOrDie(cfg))
 }
 
+func withClientFromDynamic(ctx context.Context) context.Context {
+	return context.WithValue(ctx, Key{}, &wrapClient{dyn: dynamicclient.Get(ctx)})
+}
+
 // Get extracts the versioned.Interface client from the context.
 func Get(ctx context.Context) versioned.Interface {
 	untyped := ctx.Value(Key{})
@@ -55,3 +84,1817 @@ func Get(ctx context.Context) versioned.Interface {
 	}
 	return untyped.(versioned.Interface)
 }
+
+type wrapClient struct {
+	dyn dynamic.Interface
+}
+
+var _ versioned.Interface = (*wrapClient)(nil)
+
+func (w *wrapClient) Discovery() discovery.DiscoveryInterface {
+	panic("Discovery called on dynamic client!")
+}
+
+func convert(from interface{}, to runtime.Object) error {
+	bs, err := json.Marshal(from)
+	if err != nil {
+		return fmt.Errorf("Marshal() = %w", err)
+	}
+	if err := json.Unmarshal(bs, to); err != nil {
+		return fmt.Errorf("Unmarshal() = %w", err)
+	}
+	return nil
+}
+
+// EventingV1beta1 retrieves the EventingV1beta1Client
+func (w *wrapClient) EventingV1beta1() typedeventingv1beta1.EventingV1beta1Interface {
+	return &wrapEventingV1beta1{
+		dyn: w.dyn,
+	}
+}
+
+type wrapEventingV1beta1 struct {
+	dyn dynamic.Interface
+}
+
+func (w *wrapEventingV1beta1) RESTClient() rest.Interface {
+	panic("RESTClient called on dynamic client!")
+}
+
+func (w *wrapEventingV1beta1) EventTypes(namespace string) typedeventingv1beta1.EventTypeInterface {
+	return &wrapEventingV1beta1EventTypeImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "eventing.knative.dev",
+			Version:  "v1beta1",
+			Resource: "eventtypes",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapEventingV1beta1EventTypeImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedeventingv1beta1.EventTypeInterface = (*wrapEventingV1beta1EventTypeImpl)(nil)
+
+func (w *wrapEventingV1beta1EventTypeImpl) Create(ctx context.Context, in *v1beta1.EventType, opts v1.CreateOptions) (*v1beta1.EventType, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1beta1",
+		Kind:    "EventType",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta1.EventType{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta1.EventType, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta1.EventType{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) List(ctx context.Context, opts v1.ListOptions) (*v1beta1.EventTypeList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta1.EventTypeList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta1.EventType, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta1.EventType{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) Update(ctx context.Context, in *v1beta1.EventType, opts v1.UpdateOptions) (*v1beta1.EventType, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1beta1",
+		Kind:    "EventType",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta1.EventType{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) UpdateStatus(ctx context.Context, in *v1beta1.EventType, opts v1.UpdateOptions) (*v1beta1.EventType, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1beta1",
+		Kind:    "EventType",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta1.EventType{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1beta1EventTypeImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+// EventingV1 retrieves the EventingV1Client
+func (w *wrapClient) EventingV1() typedeventingv1.EventingV1Interface {
+	return &wrapEventingV1{
+		dyn: w.dyn,
+	}
+}
+
+type wrapEventingV1 struct {
+	dyn dynamic.Interface
+}
+
+func (w *wrapEventingV1) RESTClient() rest.Interface {
+	panic("RESTClient called on dynamic client!")
+}
+
+func (w *wrapEventingV1) Brokers(namespace string) typedeventingv1.BrokerInterface {
+	return &wrapEventingV1BrokerImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "eventing.knative.dev",
+			Version:  "v1",
+			Resource: "brokers",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapEventingV1BrokerImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedeventingv1.BrokerInterface = (*wrapEventingV1BrokerImpl)(nil)
+
+func (w *wrapEventingV1BrokerImpl) Create(ctx context.Context, in *eventingv1.Broker, opts v1.CreateOptions) (*eventingv1.Broker, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1",
+		Kind:    "Broker",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Broker{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1BrokerImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapEventingV1BrokerImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapEventingV1BrokerImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*eventingv1.Broker, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Broker{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1BrokerImpl) List(ctx context.Context, opts v1.ListOptions) (*eventingv1.BrokerList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.BrokerList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1BrokerImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *eventingv1.Broker, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Broker{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1BrokerImpl) Update(ctx context.Context, in *eventingv1.Broker, opts v1.UpdateOptions) (*eventingv1.Broker, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1",
+		Kind:    "Broker",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Broker{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1BrokerImpl) UpdateStatus(ctx context.Context, in *eventingv1.Broker, opts v1.UpdateOptions) (*eventingv1.Broker, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1",
+		Kind:    "Broker",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Broker{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1BrokerImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+func (w *wrapEventingV1) Triggers(namespace string) typedeventingv1.TriggerInterface {
+	return &wrapEventingV1TriggerImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "eventing.knative.dev",
+			Version:  "v1",
+			Resource: "triggers",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapEventingV1TriggerImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedeventingv1.TriggerInterface = (*wrapEventingV1TriggerImpl)(nil)
+
+func (w *wrapEventingV1TriggerImpl) Create(ctx context.Context, in *eventingv1.Trigger, opts v1.CreateOptions) (*eventingv1.Trigger, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1",
+		Kind:    "Trigger",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Trigger{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1TriggerImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapEventingV1TriggerImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapEventingV1TriggerImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*eventingv1.Trigger, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Trigger{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1TriggerImpl) List(ctx context.Context, opts v1.ListOptions) (*eventingv1.TriggerList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.TriggerList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1TriggerImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *eventingv1.Trigger, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Trigger{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1TriggerImpl) Update(ctx context.Context, in *eventingv1.Trigger, opts v1.UpdateOptions) (*eventingv1.Trigger, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1",
+		Kind:    "Trigger",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Trigger{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1TriggerImpl) UpdateStatus(ctx context.Context, in *eventingv1.Trigger, opts v1.UpdateOptions) (*eventingv1.Trigger, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "eventing.knative.dev",
+		Version: "v1",
+		Kind:    "Trigger",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &eventingv1.Trigger{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapEventingV1TriggerImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+// FlowsV1 retrieves the FlowsV1Client
+func (w *wrapClient) FlowsV1() typedflowsv1.FlowsV1Interface {
+	return &wrapFlowsV1{
+		dyn: w.dyn,
+	}
+}
+
+type wrapFlowsV1 struct {
+	dyn dynamic.Interface
+}
+
+func (w *wrapFlowsV1) RESTClient() rest.Interface {
+	panic("RESTClient called on dynamic client!")
+}
+
+func (w *wrapFlowsV1) Parallels(namespace string) typedflowsv1.ParallelInterface {
+	return &wrapFlowsV1ParallelImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "flows.knative.dev",
+			Version:  "v1",
+			Resource: "parallels",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapFlowsV1ParallelImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedflowsv1.ParallelInterface = (*wrapFlowsV1ParallelImpl)(nil)
+
+func (w *wrapFlowsV1ParallelImpl) Create(ctx context.Context, in *flowsv1.Parallel, opts v1.CreateOptions) (*flowsv1.Parallel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "flows.knative.dev",
+		Version: "v1",
+		Kind:    "Parallel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Parallel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1ParallelImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapFlowsV1ParallelImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapFlowsV1ParallelImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*flowsv1.Parallel, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Parallel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1ParallelImpl) List(ctx context.Context, opts v1.ListOptions) (*flowsv1.ParallelList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.ParallelList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1ParallelImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *flowsv1.Parallel, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Parallel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1ParallelImpl) Update(ctx context.Context, in *flowsv1.Parallel, opts v1.UpdateOptions) (*flowsv1.Parallel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "flows.knative.dev",
+		Version: "v1",
+		Kind:    "Parallel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Parallel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1ParallelImpl) UpdateStatus(ctx context.Context, in *flowsv1.Parallel, opts v1.UpdateOptions) (*flowsv1.Parallel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "flows.knative.dev",
+		Version: "v1",
+		Kind:    "Parallel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Parallel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1ParallelImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+func (w *wrapFlowsV1) Sequences(namespace string) typedflowsv1.SequenceInterface {
+	return &wrapFlowsV1SequenceImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "flows.knative.dev",
+			Version:  "v1",
+			Resource: "sequences",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapFlowsV1SequenceImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedflowsv1.SequenceInterface = (*wrapFlowsV1SequenceImpl)(nil)
+
+func (w *wrapFlowsV1SequenceImpl) Create(ctx context.Context, in *flowsv1.Sequence, opts v1.CreateOptions) (*flowsv1.Sequence, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "flows.knative.dev",
+		Version: "v1",
+		Kind:    "Sequence",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Sequence{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1SequenceImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapFlowsV1SequenceImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapFlowsV1SequenceImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*flowsv1.Sequence, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Sequence{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1SequenceImpl) List(ctx context.Context, opts v1.ListOptions) (*flowsv1.SequenceList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.SequenceList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1SequenceImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *flowsv1.Sequence, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Sequence{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1SequenceImpl) Update(ctx context.Context, in *flowsv1.Sequence, opts v1.UpdateOptions) (*flowsv1.Sequence, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "flows.knative.dev",
+		Version: "v1",
+		Kind:    "Sequence",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Sequence{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1SequenceImpl) UpdateStatus(ctx context.Context, in *flowsv1.Sequence, opts v1.UpdateOptions) (*flowsv1.Sequence, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "flows.knative.dev",
+		Version: "v1",
+		Kind:    "Sequence",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &flowsv1.Sequence{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapFlowsV1SequenceImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+// MessagingV1 retrieves the MessagingV1Client
+func (w *wrapClient) MessagingV1() typedmessagingv1.MessagingV1Interface {
+	return &wrapMessagingV1{
+		dyn: w.dyn,
+	}
+}
+
+type wrapMessagingV1 struct {
+	dyn dynamic.Interface
+}
+
+func (w *wrapMessagingV1) RESTClient() rest.Interface {
+	panic("RESTClient called on dynamic client!")
+}
+
+func (w *wrapMessagingV1) Channels(namespace string) typedmessagingv1.ChannelInterface {
+	return &wrapMessagingV1ChannelImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "messaging.knative.dev",
+			Version:  "v1",
+			Resource: "channels",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapMessagingV1ChannelImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedmessagingv1.ChannelInterface = (*wrapMessagingV1ChannelImpl)(nil)
+
+func (w *wrapMessagingV1ChannelImpl) Create(ctx context.Context, in *messagingv1.Channel, opts v1.CreateOptions) (*messagingv1.Channel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "Channel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Channel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1ChannelImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapMessagingV1ChannelImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapMessagingV1ChannelImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*messagingv1.Channel, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Channel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1ChannelImpl) List(ctx context.Context, opts v1.ListOptions) (*messagingv1.ChannelList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.ChannelList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1ChannelImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *messagingv1.Channel, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Channel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1ChannelImpl) Update(ctx context.Context, in *messagingv1.Channel, opts v1.UpdateOptions) (*messagingv1.Channel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "Channel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Channel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1ChannelImpl) UpdateStatus(ctx context.Context, in *messagingv1.Channel, opts v1.UpdateOptions) (*messagingv1.Channel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "Channel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Channel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1ChannelImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+func (w *wrapMessagingV1) InMemoryChannels(namespace string) typedmessagingv1.InMemoryChannelInterface {
+	return &wrapMessagingV1InMemoryChannelImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "messaging.knative.dev",
+			Version:  "v1",
+			Resource: "inmemorychannels",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapMessagingV1InMemoryChannelImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedmessagingv1.InMemoryChannelInterface = (*wrapMessagingV1InMemoryChannelImpl)(nil)
+
+func (w *wrapMessagingV1InMemoryChannelImpl) Create(ctx context.Context, in *messagingv1.InMemoryChannel, opts v1.CreateOptions) (*messagingv1.InMemoryChannel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "InMemoryChannel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.InMemoryChannel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*messagingv1.InMemoryChannel, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.InMemoryChannel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) List(ctx context.Context, opts v1.ListOptions) (*messagingv1.InMemoryChannelList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.InMemoryChannelList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *messagingv1.InMemoryChannel, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.InMemoryChannel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) Update(ctx context.Context, in *messagingv1.InMemoryChannel, opts v1.UpdateOptions) (*messagingv1.InMemoryChannel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "InMemoryChannel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.InMemoryChannel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) UpdateStatus(ctx context.Context, in *messagingv1.InMemoryChannel, opts v1.UpdateOptions) (*messagingv1.InMemoryChannel, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "InMemoryChannel",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.InMemoryChannel{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1InMemoryChannelImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+func (w *wrapMessagingV1) Subscriptions(namespace string) typedmessagingv1.SubscriptionInterface {
+	return &wrapMessagingV1SubscriptionImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "messaging.knative.dev",
+			Version:  "v1",
+			Resource: "subscriptions",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapMessagingV1SubscriptionImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedmessagingv1.SubscriptionInterface = (*wrapMessagingV1SubscriptionImpl)(nil)
+
+func (w *wrapMessagingV1SubscriptionImpl) Create(ctx context.Context, in *messagingv1.Subscription, opts v1.CreateOptions) (*messagingv1.Subscription, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "Subscription",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Subscription{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*messagingv1.Subscription, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Subscription{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) List(ctx context.Context, opts v1.ListOptions) (*messagingv1.SubscriptionList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.SubscriptionList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *messagingv1.Subscription, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Subscription{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) Update(ctx context.Context, in *messagingv1.Subscription, opts v1.UpdateOptions) (*messagingv1.Subscription, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "Subscription",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Subscription{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) UpdateStatus(ctx context.Context, in *messagingv1.Subscription, opts v1.UpdateOptions) (*messagingv1.Subscription, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "messaging.knative.dev",
+		Version: "v1",
+		Kind:    "Subscription",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &messagingv1.Subscription{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapMessagingV1SubscriptionImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+// SourcesV1beta2 retrieves the SourcesV1beta2Client
+func (w *wrapClient) SourcesV1beta2() typedsourcesv1beta2.SourcesV1beta2Interface {
+	return &wrapSourcesV1beta2{
+		dyn: w.dyn,
+	}
+}
+
+type wrapSourcesV1beta2 struct {
+	dyn dynamic.Interface
+}
+
+func (w *wrapSourcesV1beta2) RESTClient() rest.Interface {
+	panic("RESTClient called on dynamic client!")
+}
+
+func (w *wrapSourcesV1beta2) PingSources(namespace string) typedsourcesv1beta2.PingSourceInterface {
+	return &wrapSourcesV1beta2PingSourceImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "sources.knative.dev",
+			Version:  "v1beta2",
+			Resource: "pingsources",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapSourcesV1beta2PingSourceImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedsourcesv1beta2.PingSourceInterface = (*wrapSourcesV1beta2PingSourceImpl)(nil)
+
+func (w *wrapSourcesV1beta2PingSourceImpl) Create(ctx context.Context, in *v1beta2.PingSource, opts v1.CreateOptions) (*v1beta2.PingSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1beta2",
+		Kind:    "PingSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta2.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*v1beta2.PingSource, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta2.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) List(ctx context.Context, opts v1.ListOptions) (*v1beta2.PingSourceList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta2.PingSourceList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *v1beta2.PingSource, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta2.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) Update(ctx context.Context, in *v1beta2.PingSource, opts v1.UpdateOptions) (*v1beta2.PingSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1beta2",
+		Kind:    "PingSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta2.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) UpdateStatus(ctx context.Context, in *v1beta2.PingSource, opts v1.UpdateOptions) (*v1beta2.PingSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1beta2",
+		Kind:    "PingSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &v1beta2.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1beta2PingSourceImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+// SourcesV1 retrieves the SourcesV1Client
+func (w *wrapClient) SourcesV1() typedsourcesv1.SourcesV1Interface {
+	return &wrapSourcesV1{
+		dyn: w.dyn,
+	}
+}
+
+type wrapSourcesV1 struct {
+	dyn dynamic.Interface
+}
+
+func (w *wrapSourcesV1) RESTClient() rest.Interface {
+	panic("RESTClient called on dynamic client!")
+}
+
+func (w *wrapSourcesV1) ApiServerSources(namespace string) typedsourcesv1.ApiServerSourceInterface {
+	return &wrapSourcesV1ApiServerSourceImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "sources.knative.dev",
+			Version:  "v1",
+			Resource: "apiserversources",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapSourcesV1ApiServerSourceImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedsourcesv1.ApiServerSourceInterface = (*wrapSourcesV1ApiServerSourceImpl)(nil)
+
+func (w *wrapSourcesV1ApiServerSourceImpl) Create(ctx context.Context, in *sourcesv1.ApiServerSource, opts v1.CreateOptions) (*sourcesv1.ApiServerSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "ApiServerSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ApiServerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*sourcesv1.ApiServerSource, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ApiServerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) List(ctx context.Context, opts v1.ListOptions) (*sourcesv1.ApiServerSourceList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ApiServerSourceList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *sourcesv1.ApiServerSource, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ApiServerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) Update(ctx context.Context, in *sourcesv1.ApiServerSource, opts v1.UpdateOptions) (*sourcesv1.ApiServerSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "ApiServerSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ApiServerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) UpdateStatus(ctx context.Context, in *sourcesv1.ApiServerSource, opts v1.UpdateOptions) (*sourcesv1.ApiServerSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "ApiServerSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ApiServerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ApiServerSourceImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+func (w *wrapSourcesV1) ContainerSources(namespace string) typedsourcesv1.ContainerSourceInterface {
+	return &wrapSourcesV1ContainerSourceImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "sources.knative.dev",
+			Version:  "v1",
+			Resource: "containersources",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapSourcesV1ContainerSourceImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedsourcesv1.ContainerSourceInterface = (*wrapSourcesV1ContainerSourceImpl)(nil)
+
+func (w *wrapSourcesV1ContainerSourceImpl) Create(ctx context.Context, in *sourcesv1.ContainerSource, opts v1.CreateOptions) (*sourcesv1.ContainerSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "ContainerSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ContainerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*sourcesv1.ContainerSource, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ContainerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) List(ctx context.Context, opts v1.ListOptions) (*sourcesv1.ContainerSourceList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ContainerSourceList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *sourcesv1.ContainerSource, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ContainerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) Update(ctx context.Context, in *sourcesv1.ContainerSource, opts v1.UpdateOptions) (*sourcesv1.ContainerSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "ContainerSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ContainerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) UpdateStatus(ctx context.Context, in *sourcesv1.ContainerSource, opts v1.UpdateOptions) (*sourcesv1.ContainerSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "ContainerSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.ContainerSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1ContainerSourceImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+func (w *wrapSourcesV1) PingSources(namespace string) typedsourcesv1.PingSourceInterface {
+	return &wrapSourcesV1PingSourceImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "sources.knative.dev",
+			Version:  "v1",
+			Resource: "pingsources",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapSourcesV1PingSourceImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedsourcesv1.PingSourceInterface = (*wrapSourcesV1PingSourceImpl)(nil)
+
+func (w *wrapSourcesV1PingSourceImpl) Create(ctx context.Context, in *sourcesv1.PingSource, opts v1.CreateOptions) (*sourcesv1.PingSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "PingSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1PingSourceImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapSourcesV1PingSourceImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapSourcesV1PingSourceImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*sourcesv1.PingSource, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1PingSourceImpl) List(ctx context.Context, opts v1.ListOptions) (*sourcesv1.PingSourceList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.PingSourceList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1PingSourceImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *sourcesv1.PingSource, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1PingSourceImpl) Update(ctx context.Context, in *sourcesv1.PingSource, opts v1.UpdateOptions) (*sourcesv1.PingSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "PingSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1PingSourceImpl) UpdateStatus(ctx context.Context, in *sourcesv1.PingSource, opts v1.UpdateOptions) (*sourcesv1.PingSource, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "PingSource",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.PingSource{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1PingSourceImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
+
+func (w *wrapSourcesV1) SinkBindings(namespace string) typedsourcesv1.SinkBindingInterface {
+	return &wrapSourcesV1SinkBindingImpl{
+		dyn: w.dyn.Resource(schema.GroupVersionResource{
+			Group:    "sources.knative.dev",
+			Version:  "v1",
+			Resource: "sinkbindings",
+		}),
+
+		namespace: namespace,
+	}
+}
+
+type wrapSourcesV1SinkBindingImpl struct {
+	dyn dynamic.NamespaceableResourceInterface
+
+	namespace string
+}
+
+var _ typedsourcesv1.SinkBindingInterface = (*wrapSourcesV1SinkBindingImpl)(nil)
+
+func (w *wrapSourcesV1SinkBindingImpl) Create(ctx context.Context, in *sourcesv1.SinkBinding, opts v1.CreateOptions) (*sourcesv1.SinkBinding, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "SinkBinding",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Create(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.SinkBinding{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error {
+	return w.dyn.Namespace(w.namespace).Delete(ctx, name, opts)
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error {
+	return w.dyn.Namespace(w.namespace).DeleteCollection(ctx, opts, listOpts)
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) Get(ctx context.Context, name string, opts v1.GetOptions) (*sourcesv1.SinkBinding, error) {
+	uo, err := w.dyn.Namespace(w.namespace).Get(ctx, name, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.SinkBinding{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) List(ctx context.Context, opts v1.ListOptions) (*sourcesv1.SinkBindingList, error) {
+	uo, err := w.dyn.Namespace(w.namespace).List(ctx, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.SinkBindingList{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts v1.PatchOptions, subresources ...string) (result *sourcesv1.SinkBinding, err error) {
+	uo, err := w.dyn.Namespace(w.namespace).Patch(ctx, name, pt, data, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.SinkBinding{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) Update(ctx context.Context, in *sourcesv1.SinkBinding, opts v1.UpdateOptions) (*sourcesv1.SinkBinding, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "SinkBinding",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).Update(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.SinkBinding{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) UpdateStatus(ctx context.Context, in *sourcesv1.SinkBinding, opts v1.UpdateOptions) (*sourcesv1.SinkBinding, error) {
+	in.SetGroupVersionKind(schema.GroupVersionKind{
+		Group:   "sources.knative.dev",
+		Version: "v1",
+		Kind:    "SinkBinding",
+	})
+	uo := &unstructured.Unstructured{}
+	if err := convert(in, uo); err != nil {
+		return nil, err
+	}
+	uo, err := w.dyn.Namespace(w.namespace).UpdateStatus(ctx, uo, opts)
+	if err != nil {
+		return nil, err
+	}
+	out := &sourcesv1.SinkBinding{}
+	if err := convert(uo, out); err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (w *wrapSourcesV1SinkBindingImpl) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error) {
+	return nil, errors.New("NYI: Watch")
+}
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/broker.go b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/broker.go
index 5109b5367..721a08104 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/broker.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/broker/broker.go
@@ -21,8 +21,15 @@ package broker
 import (
 	context "context"
 
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	labels "k8s.io/apimachinery/pkg/labels"
+	cache "k8s.io/client-go/tools/cache"
+	apiseventingv1 "knative.dev/eventing/pkg/apis/eventing/v1"
+	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
 	v1 "knative.dev/eventing/pkg/client/informers/externalversions/eventing/v1"
+	client "knative.dev/eventing/pkg/client/injection/client"
 	factory "knative.dev/eventing/pkg/client/injection/informers/factory"
+	eventingv1 "knative.dev/eventing/pkg/client/listers/eventing/v1"
 	controller "knative.dev/pkg/controller"
 	injection "knative.dev/pkg/injection"
 	logging "knative.dev/pkg/logging"
@@ -30,6 +37,7 @@ import (
 
 func init() {
 	injection.Default.RegisterInformer(withInformer)
+	injection.Dynamic.RegisterDynamicInformer(withDynamicInformer)
 }
 
 // Key is used for associating the Informer inside the context.Context.
@@ -41,6 +49,11 @@ func withInformer(ctx context.Context) (context.Context, controller.Informer) {
 	return context.WithValue(ctx, Key{}, inf), inf.Informer()
 }
 
+func withDynamicInformer(ctx context.Context) context.Context {
+	inf := &wrapper{client: client.Get(ctx)}
+	return context.WithValue(ctx, Key{}, inf)
+}
+
 // Get extracts the typed informer from the context.
 func Get(ctx context.Context) v1.BrokerInformer {
 	untyped := ctx.Value(Key{})
@@ -50,3 +63,44 @@ func Get(ctx context.Context) v1.BrokerInformer {
 	}
 	return untyped.(v1.BrokerInformer)
 }
+
+type wrapper struct {
+	client versioned.Interface
+
+	namespace string
+}
+
+var _ v1.BrokerInformer = (*wrapper)(nil)
+var _ eventingv1.BrokerLister = (*wrapper)(nil)
+
+func (w *wrapper) Informer() cache.SharedIndexInformer {
+	return cache.NewSharedIndexInformer(nil, &apiseventingv1.Broker{}, 0, nil)
+}
+
+func (w *wrapper) Lister() eventingv1.BrokerLister {
+	return w
+}
+
+func (w *wrapper) Brokers(namespace string) eventingv1.BrokerNamespaceLister {
+	return &wrapper{client: w.client, namespace: namespace}
+}
+
+func (w *wrapper) List(selector labels.Selector) (ret []*apiseventingv1.Broker, err error) {
+	lo, err := w.client.EventingV1().Brokers(w.namespace).List(context.TODO(), metav1.ListOptions{
+		LabelSelector: selector.String(),
+		// TODO(mattmoor): Incorporate resourceVersion bounds based on staleness criteria.
+	})
+	if err != nil {
+		return nil, err
+	}
+	for idx := range lo.Items {
+		ret = append(ret, &lo.Items[idx])
+	}
+	return ret, nil
+}
+
+func (w *wrapper) Get(name string) (*apiseventingv1.Broker, error) {
+	return w.client.EventingV1().Brokers(w.namespace).Get(context.TODO(), name, metav1.GetOptions{
+		// TODO(mattmoor): Incorporate resourceVersion bounds based on staleness criteria.
+	})
+}
diff --git a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/trigger.go b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/trigger.go
index d585db09d..59d81fd6d 100644
--- a/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/trigger.go
+++ b/vendor/knative.dev/eventing/pkg/client/injection/informers/eventing/v1/trigger/trigger.go
@@ -21,8 +21,15 @@ package trigger
 import (
 	context "context"
 
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	labels "k8s.io/apimachinery/pkg/labels"
+	cache "k8s.io/client-go/tools/cache"
+	apiseventingv1 "knative.dev/eventing/pkg/apis/eventing/v1"
+	versioned "knative.dev/eventing/pkg/client/clientset/versioned"
 	v1 "knative.dev/eventing/pkg/client/informers/externalversions/eventing/v1"
+	client "knative.dev/eventing/pkg/client/injection/client"
 	factory "knative.dev/eventing/pkg/client/injection/informers/factory"
+	eventingv1 "knative.dev/eventing/pkg/client/listers/eventing/v1"
 	controller "knative.dev/pkg/controller"
 	injection "knative.dev/pkg/injection"
 	logging "knative.dev/pkg/logging"
@@ -30,6 +37,7 @@ import (
 
 func init() {
 	injection.Default.RegisterInformer(withInformer)
+	injection.Dynamic.RegisterDynamicInformer(withDynamicInformer)
 }
 
 // Key is used for associating the Informer inside the context.Context.
@@ -41,6 +49,11 @@ func withInformer(ctx context.Context) (context.Context, controller.Informer) {
 	return context.WithValue(ctx, Key{}, inf), inf.Informer()
 }
 
+func withDynamicInformer(ctx context.Context) context.Context {
+	inf := &wrapper{client: client.Get(ctx)}
+	return context.WithValue(ctx, Key{}, inf)
+}
+
 // Get extracts the typed informer from the context.
 func Get(ctx context.Context) v1.TriggerInformer {
 	untyped := ctx.Value(Key{})
@@ -50,3 +63,44 @@ func Get(ctx context.Context) v1.TriggerInformer {
 	}
 	return untyped.(v1.TriggerInformer)
 }
+
+type wrapper struct {
+	client versioned.Interface
+
+	namespace string
+}
+
+var _ v1.TriggerInformer = (*wrapper)(nil)
+var _ eventingv1.TriggerLister = (*wrapper)(nil)
+
+func (w *wrapper) Informer() cache.SharedIndexInformer {
+	return cache.NewSharedIndexInformer(nil, &apiseventingv1.Trigger{}, 0, nil)
+}
+
+func (w *wrapper) Lister() eventingv1.TriggerLister {
+	return w
+}
+
+func (w *wrapper) Triggers(namespace string) eventingv1.TriggerNamespaceLister {
+	return &wrapper{client: w.client, namespace: namespace}
+}
+
+func (w *wrapper) List(selector labels.Selector) (ret []*apiseventingv1.Trigger, err error) {
+	lo, err := w.client.EventingV1().Triggers(w.namespace).List(context.TODO(), metav1.ListOptions{
+		LabelSelector: selector.String(),
+		// TODO(mattmoor): Incorporate resourceVersion bounds based on staleness criteria.
+	})
+	if err != nil {
+		return nil, err
+	}
+	for idx := range lo.Items {
+		ret = append(ret, &lo.Items[idx])
+	}
+	return ret, nil
+}
+
+func (w *wrapper) Get(name string) (*apiseventingv1.Trigger, error) {
+	return w.client.EventingV1().Triggers(w.namespace).Get(context.TODO(), name, metav1.GetOptions{
+		// TODO(mattmoor): Incorporate resourceVersion bounds based on staleness criteria.
+	})
+}
diff --git a/vendor/modules.txt b/vendor/modules.txt
index aff2b0fd7..381f1ab0a 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -954,7 +954,7 @@ k8s.io/utils/buffer
 k8s.io/utils/integer
 k8s.io/utils/pointer
 k8s.io/utils/trace
-# knative.dev/eventing v0.25.1-0.20210818214503-4b18ab87646a
+# knative.dev/eventing v0.25.1-0.20210819160604-19fcdf4b2aed
 ## explicit
 knative.dev/eventing/pkg/apis/config
 knative.dev/eventing/pkg/apis/duck
@@ -1065,7 +1065,7 @@ knative.dev/eventing/test/test_images/request-sender
 # knative.dev/hack v0.0.0-20210806075220-815cd312d65c
 ## explicit
 knative.dev/hack
-# knative.dev/pkg v0.0.0-20210818135208-7b5ecbc0e477
+# knative.dev/pkg v0.0.0-20210819054404-bda81c029160
 ## explicit
 knative.dev/pkg/apis
 knative.dev/pkg/apis/duck


Test patch:
diff --git a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/trigger.go b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/trigger.go
index bd9ba6ad0..cd03d0391 100644
--- a/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/trigger.go
+++ b/vendor/knative.dev/eventing/pkg/reconciler/testing/v1/trigger.go
@@ -192,7 +192,7 @@ func WithTriggerStatusSubscriberURI(uri string) TriggerOption {
 func WithTriggerStatusDeadLetterSinkURI(uri string) TriggerOption {
 	return func(t *v1.Trigger) {
 		u, _ := apis.ParseURL(uri)
-		t.Status.DeadLetterURI = u
+		t.Status.DeadLetterSinkURI = u
 	}
 }