Repository: knative-sandbox/eventing-kafka
Pull request #344 (2021-01-29 16:32:20)

Add http endpoint to communicate dispatcher readySubscriber status
this is a WIP/PoC for one half of a more immediate fix for the
'readySubscriber' issues in the kafkachannel.  This will need some of
the work that @devguyio is working on with lifting the network prober
to knative/pkg.  However, I'm about as far as I think I can get until
I know more about that implementation.

/hold

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

This pull-request has been approved by: *<a href="https://github.com/knative-sandbox/eventing-kafka/pull/344#" title="Author self-approved">lberk</a>*

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

The pull request process is described [here](https://git.k8s.io/community/contributors/guide/owners.md#the-code-review-process)

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

- ~~[OWNERS](https://github.com/knative-sandbox/eventing-kafka/blob/master/OWNERS)~~ [lberk]

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

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/channel/consolidated/dispatcher/dispatcher.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1355192076580425728/artifacts/line-cov.html#file0) | 62.0% | 50.9% | -11.2

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

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

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-metrics-robot: The following is the coverage report on the affected files.
Say `/test pull-knative-sandbox-eventing-kafka-go-coverage` to re-run this coverage report

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/channel/consolidated/dispatcher/dispatcher.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1355193789823586304/artifacts/line-cov.html#file0) | 62.0% | 50.9% | -11.2

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

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

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-unit-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1355193789806809088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1355193789781643264) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-unit-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1355193789806809088) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1355193789781643264) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1355193789689368576) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<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 -->
slinkydeveloper: /assign
knative-prow-robot: @lberk: PR needs rebase.

<details>

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1355193789781643264) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1355193789689368576) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1355193789781643264) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1355193789689368576) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1355193789781643264) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1355193789689368576) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1355193789781643264) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1355193789689368576) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356596364565286912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1355193789781643264) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1355193789689368576) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356596364565286912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b8ff57347e02ce7288b93e7dc509df7e57a239dc | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1355193789689368576) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356596364565286912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-build-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356596364603035648) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356596364565286912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-build-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356596364603035648) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356596364527538176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<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 -->
devguyio: @lberk Do we also need some changes to the dispatcher yaml to expose the port? 
devguyio: /assign
knative-prow-robot: @lberk: The following tests **failed**, say `/retest` to rerun all failed tests:

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356596364565286912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356596364527538176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-unit-tests | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356596364619812864) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356596364527538176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356596364640784384) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356596364527538176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356740825572184064) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356596364548509696) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356596364527538176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356740825572184064) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356596364527538176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356740825572184064) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356740825484103680) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 39cef58b1bdc0a0bc48f732d58b8c4de397fe924 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356596364582064128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356740825572184064) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356740825484103680) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356740825463132160) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356740825572184064) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356740825484103680) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356740825463132160) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356740825521852416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356740825572184064) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356740825463132160) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356740825521852416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-unit-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356740825572184064) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356740825521852416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356740825521852416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356742208476155904) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356740825555406848) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356742208476155904) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356742208438407168) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356740825588961280) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356742208476155904) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356742208438407168) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 2307bf35ebcf48a605803d75ae6436eacdf5c32a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356740825509269504) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356742208476155904) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356742208438407168) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356742208476155904) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356742208438407168) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356742208417435648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356742208476155904) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356742208417435648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356742208379686912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356742208417435648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356774516147097600) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356742208396464128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356742208417435648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356774516147097600) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356742208417435648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356774516147097600) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356742208463572992) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356774516147097600) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-go-coverage | ee9ab23ba2226770ba8bd5794a23e2a4ad0bf8f0 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356742208497127424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356774516147097600) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-build-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356774516126126080) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356774516147097600) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-build-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356774516126126080) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356774516172263424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356774516147097600) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356774516172263424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356774516105154560) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356774516172263424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-unit-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356777342764060672) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356774516042240000) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356774516172263424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-unit-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356777342764060672) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356774516067405824) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356774516172263424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-unit-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356777342764060672) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356777342663397376) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-go-coverage | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356774516172263424) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-unit-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356777342764060672) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356777342663397376) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 55231cb69530ff470fc80dbcdea4991ca4221ef8 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356774516084183040) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-unit-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356777342764060672) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356777342663397376) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356777342785032192) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-unit-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356777342764060672) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356777342663397376) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356777342785032192) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356777342705340416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-unit-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356777342764060672) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356777342785032192) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356777342705340416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356777342743089152) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356777342785032192) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356777342705340416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356777342722117632) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356777342785032192) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356777342705340416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-go-coverage | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356777342785032192) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356777342705340416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356779267714715648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356777342705340416) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356779267714715648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 11590512aed1094d0086a8bf51d7e8744c4aa09f | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356777342684368896) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356779267714715648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356779267693744128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356779267714715648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356779267693744128) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356779267676966912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356779267714715648) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356779267676966912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356779267756658688) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356779267676966912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356779267655995392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356779267676966912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356973772833296384) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356779267676966912) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356973772833296384) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356973772720050176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356779267735687168) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356973772833296384) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356973772720050176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356973772736827392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-go-coverage | 327ecbf241b5eac6d844e4e3c050329f6569956e | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356779267777630208) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356973772833296384) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356973772720050176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356973772736827392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-build-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356973772803936256) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-unit-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1356973772833296384) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356973772720050176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356973772736827392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-build-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356973772803936256) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356973772854267904) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-metrics-robot: The following is the coverage report on the affected files.
Say `/test pull-knative-sandbox-eventing-kafka-go-coverage` to re-run this coverage report

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/channel/consolidated/dispatcher/dispatcher.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357014062659014656/artifacts/line-cov.html#file0) | 62.9% | 63.9% | 1.0

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356973772720050176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356973772736827392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-build-tests | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1356973772803936256) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-go-coverage | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1356973772854267904) | `/test pull-knative-sandbox-eventing-kafka-go-coverage`
pull-knative-sandbox-eventing-kafka-unit-tests | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1357014062633848832) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1356973772720050176) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356973772736827392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-unit-tests | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1357014062633848832) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1357014062612877312) | `/test pull-knative-sandbox-eventing-kafka-build-tests`

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

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl/1356973772761993216) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-sasl`
pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed/1356973772782964736) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-distributed`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls | caf4240711f8adcd449345026768ef2b22fed5e5 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls/1356973772736827392) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated-tls`
pull-knative-sandbox-eventing-kafka-unit-tests | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1357014062633848832) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`
pull-knative-sandbox-eventing-kafka-build-tests | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1357014062612877312) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1357014062537379840) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`

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

<details>

Instructions for interacting with me using PR comments are available [here](https://git.k8s.io/community/contributors/guide/pull-requests.md).  If you have questions or suggestions related to my behavior, please file an issue against the [kubernetes/test-infra](https://github.com/kubernetes/test-infra/issues/new?title=Prow%20issue:) repository. I understand the commands that are listed [here](https://go.k8s.io/bot-commands).
</details>
<!-- test report -->
knative-metrics-robot: The following is the coverage report on the affected files.
Say `/test pull-knative-sandbox-eventing-kafka-go-coverage` to re-run this coverage report

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/channel/consolidated/dispatcher/dispatcher.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357048600319758336/artifacts/line-cov.html#file0) | 62.9% | 63.9% | 1.0

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

Test name | Commit | Details | Rerun command
--- | --- | --- | ---
pull-knative-sandbox-eventing-kafka-build-tests | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-build-tests/1357014062612877312) | `/test pull-knative-sandbox-eventing-kafka-build-tests`
pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated | b1837325bc124a0fa8995109c4dfc055241f464a | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated/1357014062537379840) | `/test pull-knative-sandbox-eventing-kafka-integration-test-channel-consolidated`
pull-knative-sandbox-eventing-kafka-unit-tests | 1f235674cf3ca1b5c942aff08b5bf7eb633d8432 | [link](https://prow.knative.dev/view/gs/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-unit-tests/1357048600302981120) | `/test pull-knative-sandbox-eventing-kafka-unit-tests`

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

<details>

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

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

```diff
@@            Coverage Diff             @@
##           master     #344      +/-   ##
==========================================
- Coverage   75.17%   74.88%   -0.29%     
==========================================
  Files         124      124              
  Lines        4705     4755      +50     
==========================================
+ Hits         3537     3561      +24     
- Misses        948      970      +22     
- Partials      220      224       +4     
```


| [Impacted Files](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/344?src=pr&el=tree) | Coverage Δ | |
|---|---|---|
| [pkg/source/adapter/adapter.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/344/diff?src=pr&el=tree#diff-cGtnL3NvdXJjZS9hZGFwdGVyL2FkYXB0ZXIuZ28=) | `66.10% <0.00%> (-1.14%)` | :arrow_down: |
| [pkg/channel/consolidated/dispatcher/dispatcher.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/344/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvY29uc29saWRhdGVkL2Rpc3BhdGNoZXIvZGlzcGF0Y2hlci5nbw==) | `51.61% <67.27%> (+2.49%)` | :arrow_up: |
| [pkg/common/consumer/consumer\_handler.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/344/diff?src=pr&el=tree#diff-cGtnL2NvbW1vbi9jb25zdW1lci9jb25zdW1lcl9oYW5kbGVyLmdv) | `82.60% <100.00%> (+1.65%)` | :arrow_up: |
| [pkg/source/mtadapter/adapter.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/344/diff?src=pr&el=tree#diff-cGtnL3NvdXJjZS9tdGFkYXB0ZXIvYWRhcHRlci5nbw==) | `68.75% <100.00%> (+0.49%)` | :arrow_up: |
| [...el/distributed/dispatcher/dispatcher/dispatcher.go](https://codecov.io/gh/knative-sandbox/eventing-kafka/pull/344/diff?src=pr&el=tree#diff-cGtnL2NoYW5uZWwvZGlzdHJpYnV0ZWQvZGlzcGF0Y2hlci9kaXNwYXRjaGVyL2Rpc3BhdGNoZXIuZ28=) | `65.45% <0.00%> (-6.37%)` | :arrow_down: |

------

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

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

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/channel/consolidated/dispatcher/dispatcher.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357050956121903104/artifacts/line-cov.html#file0) | 62.9% | 63.9% | 1.0
[pkg/common/consumer/consumer_handler.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357050956121903104/artifacts/line-cov.html#file1) | 89.5% | 90.5% | 1.0

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

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/channel/consolidated/dispatcher/dispatcher.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357068361703362560/artifacts/line-cov.html#file0) | 62.9% | 63.9% | 1.0
[pkg/common/consumer/consumer_handler.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357068361703362560/artifacts/line-cov.html#file1) | 89.5% | 90.5% | 1.0

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

File | Old Coverage | New Coverage | Delta
---- |:------------:|:------------:|:-----:
[pkg/channel/consolidated/dispatcher/dispatcher.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357076704387928064/artifacts/line-cov.html#file0) | 62.9% | 67.2% | 4.3
[pkg/common/consumer/consumer_handler.go](https://storage.cloud.google.com/knative-prow/pr-logs/pull/knative-sandbox_eventing-kafka/344/pull-knative-sandbox-eventing-kafka-go-coverage/1357076704387928064/artifacts/line-cov.html#file1) | 89.5% | 90.5% | 1.0

lberk: /unhold
I've added back the observekind so that there should be no functional changes if/when merging this. Once @devguyio posts his controller status PR, we can remove the observekind there.

Patch:
diff --git a/cmd/channel/distributed/dispatcher/main.go b/cmd/channel/distributed/dispatcher/main.go
index 5b8f750bb..4fa74bd2c 100644
--- a/cmd/channel/distributed/dispatcher/main.go
+++ b/cmd/channel/distributed/dispatcher/main.go
@@ -22,6 +22,8 @@ import (
 	"strconv"
 	"strings"
 
+	"knative.dev/eventing/pkg/kncloudevents"
+
 	"go.uber.org/zap"
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/client-go/kubernetes"
@@ -114,6 +116,12 @@ func main() {
 
 	statsReporter := metrics.NewStatsReporter(logger)
 
+	// Increase The Idle Connection Limits From Transport Defaults (see net/http/DefaultTransport)
+	kncloudevents.ConfigureConnectionArgs(&kncloudevents.ConnectionArgs{
+		MaxIdleConns:        constants.DefaultMaxIdleConns,
+		MaxIdleConnsPerHost: constants.DefaultMaxIdleConnsPerHost,
+	})
+
 	// Create The Dispatcher With Specified Configuration
 	dispatcherConfig := dispatch.DispatcherConfig{
 		Logger:        logger,
diff --git a/config/channel/consolidated/deployments/dispatcher.yaml b/config/channel/consolidated/deployments/dispatcher.yaml
index 45977778c..896f9ea9e 100644
--- a/config/channel/consolidated/deployments/dispatcher.yaml
+++ b/config/channel/consolidated/deployments/dispatcher.yaml
@@ -60,6 +60,9 @@ spec:
         - containerPort: 9090
           name: metrics
           protocol: TCP
+        - containerPort: 8081
+          name: sub-status
+          protocol: TCP
         volumeMounts:
         - name: config-kafka
           mountPath: /etc/config-kafka
@@ -85,6 +88,10 @@ spec:
     port: 80
     protocol: TCP
     targetPort: 8080
+  - name: http-sub-status
+    port: 8081
+    protocol: TCP
+    targetPort: 8081
   selector:
     messaging.knative.dev/channel: kafka-channel
     messaging.knative.dev/role: dispatcher
diff --git a/config/source/multi/201-adapter-clusterrole.yaml b/config/source/multi/201-adapter-clusterrole.yaml
index 367d62d6f..dc3f471c6 100644
--- a/config/source/multi/201-adapter-clusterrole.yaml
+++ b/config/source/multi/201-adapter-clusterrole.yaml
@@ -55,6 +55,13 @@ rules:
   - list
   - watch
 
+- apiGroups:
+    - ""
+  resources:
+    - secrets
+  verbs:
+    - get
+
 - apiGroups:
    - ""
   resources:
diff --git a/pkg/channel/consolidated/dispatcher/dispatcher.go b/pkg/channel/consolidated/dispatcher/dispatcher.go
index 5bf384315..c79d675d0 100644
--- a/pkg/channel/consolidated/dispatcher/dispatcher.go
+++ b/pkg/channel/consolidated/dispatcher/dispatcher.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2018 The Knative Authors
+Copyright 2021 The Knative Authors
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
@@ -17,6 +17,7 @@ package dispatcher
 
 import (
 	"context"
+	"encoding/json"
 	"errors"
 	"fmt"
 	nethttp "net/http"
@@ -24,6 +25,8 @@ import (
 	"sync"
 	"sync/atomic"
 
+	"k8s.io/apimachinery/pkg/util/sets"
+
 	"knative.dev/eventing-kafka/pkg/common/client"
 	"knative.dev/eventing-kafka/pkg/common/tracing"
 
@@ -44,6 +47,18 @@ import (
 	"knative.dev/eventing-kafka/pkg/common/consumer"
 )
 
+const (
+	dispatcherReadySubHeader = "K-Subscriber-Status"
+)
+
+type KafkaSubscription struct {
+	subs []types.UID
+
+	// readySubscriptionsLock must be used to synchronize access to channelReadySubscriptions
+	readySubscriptionsLock    sync.RWMutex
+	channelReadySubscriptions sets.String
+}
+
 type KafkaDispatcher struct {
 	hostToChannelMap atomic.Value
 	// hostToChannelMapLock is used to update hostToChannelMap
@@ -53,7 +68,7 @@ type KafkaDispatcher struct {
 	dispatcher *eventingchannels.MessageDispatcherImpl
 
 	kafkaSyncProducer    sarama.SyncProducer
-	channelSubscriptions map[eventingchannels.ChannelReference][]types.UID
+	channelSubscriptions map[eventingchannels.ChannelReference]*KafkaSubscription
 	subsConsumerGroups   map[types.UID]sarama.ConsumerGroup
 	subscriptions        map[types.UID]Subscription
 	// consumerUpdateLock must be used to update kafkaConsumers
@@ -88,6 +103,43 @@ func (sub Subscription) String() string {
 	return s.String()
 }
 
+func (d *KafkaDispatcher) ServeHTTP(w nethttp.ResponseWriter, r *nethttp.Request) {
+	if r.Method != nethttp.MethodGet {
+		w.WriteHeader(nethttp.StatusMethodNotAllowed)
+		d.logger.Errorf("Received request method that wasn't GET: %s", r.Method)
+		return
+	}
+	uriSplit := strings.Split(r.RequestURI, "/")
+	if len(uriSplit) != 3 {
+		w.WriteHeader(nethttp.StatusNotFound)
+		d.logger.Errorf("Unable to process request: %s", r.RequestURI)
+		return
+	}
+	channelRefNamespace, channelRefName := uriSplit[1], uriSplit[2]
+	channelRef := eventingchannels.ChannelReference{
+		Name:      channelRefName,
+		Namespace: channelRefNamespace,
+	}
+	if _, ok := d.channelSubscriptions[channelRef]; !ok {
+		w.WriteHeader(nethttp.StatusNotFound)
+		return
+	}
+	d.channelSubscriptions[channelRef].readySubscriptionsLock.RLock()
+	defer d.channelSubscriptions[channelRef].readySubscriptionsLock.RUnlock()
+	var subscriptions = make(map[string][]string)
+	w.Header().Set(dispatcherReadySubHeader, channelRefName)
+	subscriptions[channelRefNamespace+"/"+channelRefName] = d.channelSubscriptions[channelRef].channelReadySubscriptions.List()
+	jsonResult, err := json.Marshal(subscriptions)
+	if err != nil {
+		d.logger.Errorf("Error marshalling json for sub-status channelref: %s/%s, %w", channelRefNamespace, channelRefName, err)
+		return
+	}
+	_, err = w.Write(jsonResult)
+	if err != nil {
+		d.logger.Errorf("Error writing jsonResult to serveHTTP writer: %w", err)
+	}
+}
+
 func NewDispatcher(ctx context.Context, args *KafkaDispatcherArgs) (*KafkaDispatcher, error) {
 	conf, err := client.NewConfigBuilder().
 		WithClientId(args.ClientID).
@@ -114,7 +166,7 @@ func NewDispatcher(ctx context.Context, args *KafkaDispatcherArgs) (*KafkaDispat
 	dispatcher := &KafkaDispatcher{
 		dispatcher:           eventingchannels.NewMessageDispatcher(args.Logger.Desugar()),
 		kafkaConsumerFactory: consumer.NewConsumerGroupFactory(args.Brokers, conf),
-		channelSubscriptions: make(map[eventingchannels.ChannelReference][]types.UID),
+		channelSubscriptions: make(map[eventingchannels.ChannelReference]*KafkaSubscription),
 		subsConsumerGroups:   make(map[types.UID]sarama.ConsumerGroup),
 		subscriptions:        make(map[types.UID]Subscription),
 		kafkaSyncProducer:    producer,
@@ -122,6 +174,10 @@ func NewDispatcher(ctx context.Context, args *KafkaDispatcherArgs) (*KafkaDispat
 		topicFunc:            args.TopicFunc,
 	}
 
+	go func() {
+		dispatcher.logger.Fatal(nethttp.ListenAndServe(":8081", dispatcher))
+	}()
+
 	podName, err := env.GetRequiredConfigValue(args.Logger.Desugar(), env.PodNameEnvVarKey)
 	if err != nil {
 		return nil, err
@@ -180,9 +236,14 @@ type KafkaDispatcherArgs struct {
 }
 
 type consumerMessageHandler struct {
-	logger     *zap.SugaredLogger
-	sub        Subscription
-	dispatcher *eventingchannels.MessageDispatcherImpl
+	logger            *zap.SugaredLogger
+	sub               Subscription
+	dispatcher        *eventingchannels.MessageDispatcherImpl
+	kafkaSubscription *KafkaSubscription
+}
+
+func (c consumerMessageHandler) SetReady(ready bool) {
+	c.kafkaSubscription.SetReady(c.sub.UID, ready)
 }
 
 func (c consumerMessageHandler) Handle(ctx context.Context, consumerMessage *sarama.ConsumerMessage) (bool, error) {
@@ -235,6 +296,22 @@ type ChannelConfig struct {
 	Subscriptions []Subscription
 }
 
+// SetReady will mark the subid in the KafkaSubscription and call any registered callbacks
+func (ks *KafkaSubscription) SetReady(subID types.UID, ready bool) {
+	ks.readySubscriptionsLock.Lock()
+	defer ks.readySubscriptionsLock.Unlock()
+	if ready {
+		if !ks.channelReadySubscriptions.Has(string(subID)) {
+			ks.channelReadySubscriptions.Insert(string(subID))
+		}
+	} else {
+		if ks.channelReadySubscriptions.Has(string(subID)) {
+			ks.channelReadySubscriptions.Delete(string(subID))
+		}
+	}
+
+}
+
 // UpdateKafkaConsumers will be called by new CRD based kafka channel dispatcher controller.
 func (d *KafkaDispatcher) UpdateKafkaConsumers(config *Config) (map[types.UID]error, error) {
 	if config == nil {
@@ -256,9 +333,16 @@ func (d *KafkaDispatcher) UpdateKafkaConsumers(config *Config) (map[types.UID]er
 
 			// Check if sub already exists
 			exists := false
-			for _, s := range d.channelSubscriptions[channelRef] {
-				if s == subSpec.UID {
-					exists = true
+			if _, ok := d.channelSubscriptions[channelRef]; ok {
+				for _, s := range d.channelSubscriptions[channelRef].subs {
+					if s == subSpec.UID {
+						exists = true
+					}
+				}
+			} else { //ensure the pointer is populated or things go boom
+				d.channelSubscriptions[channelRef] = &KafkaSubscription{
+					subs:                      []types.UID{},
+					channelReadySubscriptions: sets.String{},
 				}
 			}
 
@@ -278,7 +362,7 @@ func (d *KafkaDispatcher) UpdateKafkaConsumers(config *Config) (map[types.UID]er
 	// Unsubscribe and close consumer for any deleted subscriptions
 	subsToRemove := make(map[eventingchannels.ChannelReference][]types.UID)
 	for channelRef, actualSubs := range d.channelSubscriptions {
-		subsToRemove[channelRef] = uidSetDifference(actualSubs, newSubs)
+		subsToRemove[channelRef] = uidSetDifference(actualSubs.subs, newSubs)
 	}
 
 	for channelRef, subs := range subsToRemove {
@@ -287,7 +371,7 @@ func (d *KafkaDispatcher) UpdateKafkaConsumers(config *Config) (map[types.UID]er
 				return nil, err
 			}
 		}
-		d.channelSubscriptions[channelRef] = newSubs
+		d.channelSubscriptions[channelRef].subs = newSubs
 	}
 
 	return failedToSubscribe, nil
@@ -360,7 +444,7 @@ func (d *KafkaDispatcher) subscribe(channelRef eventingchannels.ChannelReference
 	topicName := d.topicFunc(utils.KafkaChannelSeparator, channelRef.Namespace, channelRef.Name)
 	groupID := fmt.Sprintf("kafka.%s.%s.%s", channelRef.Namespace, channelRef.Name, string(sub.UID))
 
-	handler := &consumerMessageHandler{d.logger, sub, d.dispatcher}
+	handler := &consumerMessageHandler{d.logger, sub, d.dispatcher, d.channelSubscriptions[channelRef]}
 
 	consumerGroup, err := d.kafkaConsumerFactory.StartConsumerGroup(groupID, []string{topicName}, d.logger, handler)
 
@@ -378,7 +462,7 @@ func (d *KafkaDispatcher) subscribe(channelRef eventingchannels.ChannelReference
 		}
 	}()
 
-	d.channelSubscriptions[channelRef] = append(d.channelSubscriptions[channelRef], sub.UID)
+	d.channelSubscriptions[channelRef].subs = append(d.channelSubscriptions[channelRef].subs, sub.UID)
 	d.subscriptions[sub.UID] = sub
 	d.subsConsumerGroups[sub.UID] = consumerGroup
 
@@ -390,14 +474,17 @@ func (d *KafkaDispatcher) subscribe(channelRef eventingchannels.ChannelReference
 func (d *KafkaDispatcher) unsubscribe(channel eventingchannels.ChannelReference, sub Subscription) error {
 	d.logger.Infow("Unsubscribing from channel", zap.Any("channel", channel), zap.String("subscription", sub.String()))
 	delete(d.subscriptions, sub.UID)
-	if subsSlice, ok := d.channelSubscriptions[channel]; ok {
+	if _, ok := d.channelSubscriptions[channel]; !ok {
+		return nil
+	}
+	if subsSlice := d.channelSubscriptions[channel].subs; subsSlice != nil {
 		var newSlice []types.UID
 		for _, oldSub := range subsSlice {
 			if oldSub != sub.UID {
 				newSlice = append(newSlice, oldSub)
 			}
 		}
-		d.channelSubscriptions[channel] = newSlice
+		d.channelSubscriptions[channel].subs = newSlice
 	}
 	if consumer, ok := d.subsConsumerGroups[sub.UID]; ok {
 		delete(d.subsConsumerGroups, sub.UID)
diff --git a/pkg/channel/consolidated/reconciler/dispatcher/kafkachannel.go b/pkg/channel/consolidated/reconciler/dispatcher/kafkachannel.go
index c34b6d06f..e1e01a38d 100644
--- a/pkg/channel/consolidated/reconciler/dispatcher/kafkachannel.go
+++ b/pkg/channel/consolidated/reconciler/dispatcher/kafkachannel.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2019 The Knative Authors
+Copyright 2021 The Knative Authors
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
diff --git a/pkg/channel/distributed/dispatcher/constants/constants.go b/pkg/channel/distributed/dispatcher/constants/constants.go
index ef95d04c3..72713cc1e 100644
--- a/pkg/channel/distributed/dispatcher/constants/constants.go
+++ b/pkg/channel/distributed/dispatcher/constants/constants.go
@@ -18,5 +18,9 @@ package constants
 
 // Global Constants
 const (
+	// Values Used When Creating A New Dispatcher
+	DefaultMaxIdleConns        = 1000
+	DefaultMaxIdleConnsPerHost = 100
+
 	Component = "eventing-kafka-channel-dispatcher"
 )
diff --git a/pkg/common/consumer/consumer_factory.go b/pkg/common/consumer/consumer_factory.go
index 76faf69ab..0d6da8b3d 100644
--- a/pkg/common/consumer/consumer_factory.go
+++ b/pkg/common/consumer/consumer_factory.go
@@ -48,7 +48,6 @@ func (c *customConsumerGroup) Errors() <-chan error {
 
 func (c *customConsumerGroup) Close() error {
 	c.cancel()
-	close(c.handlerErrorChannel)
 	return c.ConsumerGroup.Close()
 }
 
@@ -64,6 +63,7 @@ func (c kafkaConsumerGroupFactoryImpl) StartConsumerGroup(groupID string, topics
 	ctx, cancel := context.WithCancel(context.Background())
 
 	go func() {
+		defer close(errorCh)
 		for {
 			consumerHandler := NewConsumerHandler(logger, handler, errorCh)
 
diff --git a/pkg/common/consumer/consumer_handler.go b/pkg/common/consumer/consumer_handler.go
index b27ccecdb..092b3083f 100644
--- a/pkg/common/consumer/consumer_handler.go
+++ b/pkg/common/consumer/consumer_handler.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2019 The Knative Authors
+Copyright 2021 The Knative Authors
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
@@ -28,6 +28,7 @@ type KafkaConsumerHandler interface {
 	// When this function returns true, the consumer group offset is marked as consumed.
 	// The returned error is enqueued in errors channel.
 	Handle(context context.Context, message *sarama.ConsumerMessage) (bool, error)
+	SetReady(ready bool)
 }
 
 // ConsumerHandler implements sarama.ConsumerGroupHandler and provides some glue code to simplify message handling
@@ -59,6 +60,7 @@ func (consumer *SaramaConsumerHandler) Setup(sarama.ConsumerGroupSession) error
 // Cleanup is run at the end of a session, once all ConsumeClaim goroutines have exited
 func (consumer *SaramaConsumerHandler) Cleanup(session sarama.ConsumerGroupSession) error {
 	consumer.logger.Info("cleanup handler")
+	consumer.handler.SetReady(false)
 	return nil
 }
 
@@ -83,6 +85,7 @@ func (consumer *SaramaConsumerHandler) ConsumeClaim(session sarama.ConsumerGroup
 		if err != nil {
 			consumer.logger.Infow("Failure while handling a message", zap.String("topic", message.Topic), zap.Int32("partition", message.Partition), zap.Int64("offset", message.Offset), zap.Error(err))
 			consumer.errors <- err
+			consumer.handler.SetReady(false)
 		}
 
 		if mustMark {
@@ -90,6 +93,7 @@ func (consumer *SaramaConsumerHandler) ConsumeClaim(session sarama.ConsumerGroup
 			if ce := consumer.logger.Desugar().Check(zap.DebugLevel, "debugging"); ce != nil {
 				consumer.logger.Debugw("Message marked", zap.String("topic", message.Topic), zap.Binary("value", message.Value))
 			}
+			consumer.handler.SetReady(true)
 		}
 
 	}
diff --git a/pkg/source/adapter/adapter.go b/pkg/source/adapter/adapter.go
index 1450c0ef5..2dba25b4f 100644
--- a/pkg/source/adapter/adapter.go
+++ b/pkg/source/adapter/adapter.go
@@ -121,6 +121,8 @@ func (a *Adapter) start(stopCh <-chan struct{}) error {
 	return nil
 }
 
+func (a *Adapter) SetReady(_ bool) {}
+
 func (a *Adapter) Handle(ctx context.Context, msg *sarama.ConsumerMessage) (bool, error) {
 	if a.rateLimiter != nil {
 		a.rateLimiter.Wait(ctx)
diff --git a/pkg/source/mtadapter/adapter.go b/pkg/source/mtadapter/adapter.go
index ec17abf49..6172caeb9 100644
--- a/pkg/source/mtadapter/adapter.go
+++ b/pkg/source/mtadapter/adapter.go
@@ -20,16 +20,18 @@ import (
 	"context"
 	"sync"
 
-	"golang.org/x/time/rate"
-
 	cloudevents "github.com/cloudevents/sdk-go/v2"
 	"go.uber.org/zap"
-
-	"knative.dev/pkg/logging"
-	pkgsource "knative.dev/pkg/source"
+	"golang.org/x/time/rate"
+	corev1 "k8s.io/api/core/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
 
 	"knative.dev/eventing/pkg/adapter/v2"
 	"knative.dev/eventing/pkg/kncloudevents"
+	kubeclient "knative.dev/pkg/client/injection/kube/client"
+	"knative.dev/pkg/logging"
+	pkgsource "knative.dev/pkg/source"
 
 	"knative.dev/eventing-kafka/pkg/apis/sources/v1beta1"
 	"knative.dev/eventing-kafka/pkg/common/scheduler"
@@ -52,6 +54,7 @@ type Adapter struct {
 	logger      *zap.SugaredLogger
 	client      cloudevents.Client
 	adapterCtor adapter.MessageAdapterConstructor
+	kubeClient  kubernetes.Interface
 
 	sourcesMu sync.RWMutex
 	sources   map[string]context.CancelFunc
@@ -72,6 +75,7 @@ func newAdapter(ctx context.Context, processed adapter.EnvConfigAccessor, ceClie
 		config:      config,
 		logger:      logger,
 		adapterCtor: adapterCtor,
+		kubeClient:  kubeclient.Get(ctx),
 		sourcesMu:   sync.RWMutex{},
 		sources:     make(map[string]context.CancelFunc),
 	}
@@ -112,6 +116,20 @@ func (a *Adapter) Update(ctx context.Context, obj *v1beta1.KafkaSource) {
 		},
 		KafkaEnvConfig: source.KafkaEnvConfig{
 			BootstrapServers: obj.Spec.BootstrapServers,
+			Net: source.AdapterNet{
+				SASL: source.AdapterSASL{
+					Enable:   obj.Spec.Net.SASL.Enable,
+					User:     a.ResolveSecret(ctx, obj.Namespace, obj.Spec.Net.SASL.User.SecretKeyRef),
+					Password: a.ResolveSecret(ctx, obj.Namespace, obj.Spec.Net.SASL.Password.SecretKeyRef),
+					Type:     a.ResolveSecret(ctx, obj.Namespace, obj.Spec.Net.SASL.Type.SecretKeyRef),
+				},
+				TLS: source.AdapterTLS{
+					Enable: obj.Spec.Net.TLS.Enable,
+					Cert:   a.ResolveSecret(ctx, obj.Namespace, obj.Spec.Net.TLS.Cert.SecretKeyRef),
+					Key:    a.ResolveSecret(ctx, obj.Namespace, obj.Spec.Net.TLS.Key.SecretKeyRef),
+					CACert: a.ResolveSecret(ctx, obj.Namespace, obj.Spec.Net.TLS.CACert.SecretKeyRef),
+				},
+			},
 		},
 		Topics:        obj.Spec.Topics,
 		ConsumerGroup: obj.Spec.ConsumerGroup,
@@ -129,7 +147,7 @@ func (a *Adapter) Update(ctx context.Context, obj *v1beta1.KafkaSource) {
 
 	httpBindingsSender, err := kncloudevents.NewHTTPMessageSenderWithTarget(obj.Status.SinkURI.String())
 	if err != nil {
-		a.logger.Fatal("error building cloud event client", zap.Error(err))
+		a.logger.Fatalw("error building cloud event client", zap.Error(err))
 	}
 
 	adapter := a.adapterCtor(ctx, &config, httpBindingsSender, reporter)
@@ -143,7 +161,7 @@ func (a *Adapter) Update(ctx context.Context, obj *v1beta1.KafkaSource) {
 	go func(ctx context.Context) {
 		err := adapter.Start(ctx)
 		if err != nil {
-			a.logger.Error("adapter failed to start", zap.Error(err))
+			a.logger.Errorw("adapter failed to start", zap.Error(err))
 		}
 
 	}(ctx)
@@ -170,3 +188,17 @@ func (a *Adapter) Remove(ctx context.Context, obj *v1beta1.KafkaSource) {
 	delete(a.sources, key)
 	a.sourcesMu.Unlock()
 }
+
+// ResolveSecret resolves the secret reference
+func (a *Adapter) ResolveSecret(ctx context.Context, ns string, ref *corev1.SecretKeySelector) string {
+	if ref == nil {
+		return ""
+	}
+	secret, err := a.kubeClient.CoreV1().Secrets(ns).Get(ctx, ref.Name, metav1.GetOptions{})
+	if err != nil {
+		a.logger.Fatalw("failed to read secret", zap.String("secretname", ref.Name), zap.Error(err))
+		return ""
+	}
+
+	return string(secret.Data[ref.Key])
+}
diff --git a/pkg/source/reconciler/source/resources/receive_adapter.go b/pkg/source/reconciler/source/resources/receive_adapter.go
index 72d309aad..88ef224c6 100644
--- a/pkg/source/reconciler/source/resources/receive_adapter.go
+++ b/pkg/source/reconciler/source/resources/receive_adapter.go
@@ -104,6 +104,10 @@ func MakeReceiveAdapter(args *ReceiveAdapterArgs) *v1.Deployment {
 							Name:  "receive-adapter",
 							Image: args.Image,
 							Env:   env,
+							Ports: []corev1.ContainerPort{
+								{Name: "metrics", ContainerPort: 9090},
+								{Name: "profiling", ContainerPort: 8008},
+							},
 						},
 					},
 				},


Test patch:
diff --git a/pkg/channel/consolidated/dispatcher/dispatcher_test.go b/pkg/channel/consolidated/dispatcher/dispatcher_test.go
index 543ca7e2c..50375af28 100644
--- a/pkg/channel/consolidated/dispatcher/dispatcher_test.go
+++ b/pkg/channel/consolidated/dispatcher/dispatcher_test.go
@@ -1,5 +1,5 @@
 /*
-Copyright 2019 The Knative Authors
+Copyright 2021 The Knative Authors
 
 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
@@ -19,6 +19,10 @@ package dispatcher
 import (
 	"context"
 	"errors"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+	"net/http/httptest"
 	"net/url"
 	"testing"
 
@@ -320,7 +324,7 @@ func TestDispatcher_UpdateConfig(t *testing.T) {
 			t.Logf("Running %s", t.Name())
 			d := &KafkaDispatcher{
 				kafkaConsumerFactory: &mockKafkaConsumerFactory{},
-				channelSubscriptions: make(map[eventingchannels.ChannelReference][]types.UID),
+				channelSubscriptions: make(map[eventingchannels.ChannelReference]*KafkaSubscription),
 				subsConsumerGroups:   make(map[types.UID]sarama.ConsumerGroup),
 				subscriptions:        make(map[types.UID]Subscription),
 				topicFunc:            utils.TopicName,
@@ -439,6 +443,195 @@ func TestNewDispatcher(t *testing.T) {
 	}
 }
 
+func TestSetReady(t *testing.T) {
+	testCases := []struct {
+		name             string
+		ready            bool
+		subID            types.UID
+		originalKafkaSub *KafkaSubscription
+		desiredKafkaSub  *KafkaSubscription
+	}{
+		{
+			name:  "doesn't have the sub, add it (on ready)",
+			ready: true,
+			subID: "foo",
+			originalKafkaSub: &KafkaSubscription{
+				channelReadySubscriptions: sets.String{"bar": sets.Empty{}},
+			},
+			desiredKafkaSub: &KafkaSubscription{
+				subs:                      []types.UID{},
+				channelReadySubscriptions: sets.String{"bar": sets.Empty{}, "foo": sets.Empty{}},
+			},
+		},
+		{
+			name:  "has the sub already (on ready)",
+			ready: true,
+			subID: "foo",
+			originalKafkaSub: &KafkaSubscription{
+				channelReadySubscriptions: sets.String{"foo": sets.Empty{}, "bar": sets.Empty{}},
+			},
+			desiredKafkaSub: &KafkaSubscription{
+				channelReadySubscriptions: sets.String{"foo": sets.Empty{}, "bar": sets.Empty{}},
+			},
+		},
+		{
+			name:  "has the sub, delete it (on !ready)",
+			ready: false,
+			subID: "foo",
+			originalKafkaSub: &KafkaSubscription{
+				channelReadySubscriptions: sets.String{"foo": sets.Empty{}, "bar": sets.Empty{}},
+			},
+			desiredKafkaSub: &KafkaSubscription{
+				channelReadySubscriptions: sets.String{"bar": sets.Empty{}},
+			},
+		},
+		{
+			name:  "doesn't have the sub to delete (on !ready)",
+			ready: false,
+			subID: "foo",
+			originalKafkaSub: &KafkaSubscription{
+				channelReadySubscriptions: sets.String{"bar": sets.Empty{}},
+			},
+			desiredKafkaSub: &KafkaSubscription{
+				channelReadySubscriptions: sets.String{"bar": sets.Empty{}},
+			},
+		},
+	}
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			t.Logf("Running %s", t.Name())
+			tc.originalKafkaSub.SetReady(tc.subID, tc.ready)
+			if diff := cmp.Diff(tc.desiredKafkaSub.channelReadySubscriptions, tc.originalKafkaSub.channelReadySubscriptions); diff != "" {
+				t.Errorf("unexpected ChannelReadySubscription (-want, +got) = %v", diff)
+			}
+		})
+	}
+}
+
+func TestServeHTTP(t *testing.T) {
+
+	httpGet := "GET"
+	httpPost := "POST"
+	testCases := []struct {
+		name               string
+		responseReturnCode int
+		desiredJson        []byte
+		channelSubs        map[eventingchannels.ChannelReference]*KafkaSubscription
+		requestURI         string
+		httpMethod         string
+	}{
+		{
+			name:               "channelref not found",
+			httpMethod:         httpGet,
+			responseReturnCode: http.StatusNotFound,
+			desiredJson:        []byte{},
+			requestURI:         "/exist/thisDoesNot",
+		}, {
+			name:               "nop",
+			httpMethod:         httpGet,
+			responseReturnCode: http.StatusNotFound,
+			desiredJson:        []byte{},
+			requestURI:         "///",
+		}, {
+			name:               "no ready subscribers",
+			httpMethod:         httpGet,
+			responseReturnCode: http.StatusOK,
+			desiredJson:        []byte(`{"bar/foo":[]}`),
+			channelSubs: map[eventingchannels.ChannelReference]*KafkaSubscription{
+				{Name: "foo", Namespace: "bar"}: {
+					subs:                      []types.UID{},
+					channelReadySubscriptions: sets.String{},
+				},
+			},
+			requestURI: "/bar/foo",
+		}, {
+			name:               "different channelref called from populated channref (different ns)",
+			httpMethod:         httpGet,
+			desiredJson:        []byte{},
+			responseReturnCode: http.StatusNotFound,
+			channelSubs: map[eventingchannels.ChannelReference]*KafkaSubscription{
+				{Name: "foo", Namespace: "baz"}: {
+					subs:                      []types.UID{"a", "b"},
+					channelReadySubscriptions: sets.String{"a": sets.Empty{}, "b": sets.Empty{}},
+				},
+			},
+			requestURI: "/bar/foo",
+		}, {
+			name:               "return correct subscription",
+			httpMethod:         httpGet,
+			desiredJson:        []byte(`{"bar/foo":["a","b"]}`),
+			responseReturnCode: http.StatusOK,
+			channelSubs: map[eventingchannels.ChannelReference]*KafkaSubscription{
+				{Name: "foo", Namespace: "bar"}: {
+					subs:                      []types.UID{"a", "b"},
+					channelReadySubscriptions: sets.String{"a": sets.Empty{}, "b": sets.Empty{}},
+				},
+			},
+			requestURI: "/bar/foo",
+		}, {
+			name:               "return correct subscription from multiple chanrefs",
+			httpMethod:         httpGet,
+			desiredJson:        []byte(`{"bar/foo":["a","b"]}`),
+			responseReturnCode: http.StatusOK,
+			channelSubs: map[eventingchannels.ChannelReference]*KafkaSubscription{
+				{Name: "table", Namespace: "flip"}: {
+					subs:                      []types.UID{"c", "d"},
+					channelReadySubscriptions: sets.String{"c": sets.Empty{}},
+				},
+				{Name: "foo", Namespace: "bar"}: {
+					subs:                      []types.UID{"a", "b"},
+					channelReadySubscriptions: sets.String{"a": sets.Empty{}, "b": sets.Empty{}},
+				},
+			},
+			requestURI: "/bar/foo",
+		}, {
+			name:               "bad request uri",
+			httpMethod:         httpGet,
+			desiredJson:        []byte{},
+			responseReturnCode: http.StatusNotFound,
+			requestURI:         "/here/be/dragons/there/are/too/many/slashes",
+		}, {
+			name:               "bad request method (POST)",
+			httpMethod:         httpPost,
+			desiredJson:        []byte{},
+			responseReturnCode: http.StatusMethodNotAllowed,
+		},
+	}
+	d := &KafkaDispatcher{
+		channelSubscriptions: make(map[eventingchannels.ChannelReference]*KafkaSubscription),
+		logger:               zaptest.NewLogger(t).Sugar(),
+	}
+	ts := httptest.NewServer(d)
+	defer ts.Close()
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			t.Logf("Running %s", t.Name())
+			d.channelSubscriptions = tc.channelSubs
+
+			request, _ := http.NewRequest(tc.httpMethod, fmt.Sprintf("%s%s", ts.URL, tc.requestURI), nil)
+			//			resp, err := http.Get(fmt.Sprintf("%s%s", ts.URL, tc.requestURI))
+			resp, err := http.DefaultClient.Do(request)
+			if err != nil {
+				t.Errorf("Could not send request to subscriber endpoint: %v", err)
+			}
+			if resp.StatusCode != tc.responseReturnCode {
+				t.Errorf("unepxected status returned: want: %d, got: %d", tc.responseReturnCode, resp.StatusCode)
+			}
+			respBody, err := ioutil.ReadAll(resp.Body)
+			defer resp.Body.Close()
+			if err != nil {
+				t.Errorf("Could not read response from subscriber endpoint: %v", err)
+			}
+			if testing.Verbose() && len(respBody) > 0 {
+				t.Logf("http response: %s\n", string(respBody))
+			}
+			if diff := cmp.Diff(tc.desiredJson, respBody); diff != "" {
+				t.Errorf("unexpected readysubscriber status response: (-want, +got) = %v", diff)
+			}
+		})
+	}
+}
+
 var sortStrings = cmpopts.SortSlices(func(x, y string) bool {
 	return x < y
 })
diff --git a/pkg/common/consumer/consumer_handler_test.go b/pkg/common/consumer/consumer_handler_test.go
index 354869611..14953e6c1 100644
--- a/pkg/common/consumer/consumer_handler_test.go
+++ b/pkg/common/consumer/consumer_handler_test.go
@@ -114,6 +114,9 @@ func (m mockMessageHandler) Handle(ctx context.Context, message *sarama.Consumer
 	}
 }
 
+func (m mockMessageHandler) SetReady(ready bool) {
+}
+
 //------ Tests
 
 func Test(t *testing.T) {
diff --git a/pkg/source/mtadapter/adapter_test.go b/pkg/source/mtadapter/adapter_test.go
index 94690790e..d0579abb9 100644
--- a/pkg/source/mtadapter/adapter_test.go
+++ b/pkg/source/mtadapter/adapter_test.go
@@ -25,6 +25,7 @@ import (
 
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
+	_ "knative.dev/pkg/client/injection/kube/client/fake"
 	pkgtesting "knative.dev/pkg/reconciler/testing"
 	"knative.dev/pkg/source"
 
diff --git a/test/e2e-common.sh b/test/e2e-common.sh
index ae01b8ca1..f55a1ae35 100755
--- a/test/e2e-common.sh
+++ b/test/e2e-common.sh
@@ -456,7 +456,7 @@ function test_mt_source() {
   echo "Testing the multi-tenant source"
   install_mt_source || return 1
 
-  go_test_e2e -tags=mtsource -timeout=5m -test.parallel=${TEST_PARALLEL} ./test/...  || fail_test
+  go_test_e2e -tags=source,mtsource -timeout=5m -test.parallel=${TEST_PARALLEL} ./test/...  || fail_test
 
   uninstall_mt_source || return 1
 }
diff --git a/test/e2e/kafka_source_reconciler_test.go b/test/e2e/kafka_source_reconciler_test.go
index bf9130032..51bf6eb19 100644
--- a/test/e2e/kafka_source_reconciler_test.go
+++ b/test/e2e/kafka_source_reconciler_test.go
@@ -1,4 +1,4 @@
-//+build e2e mtsource
+//+build e2e
 //+build source
 
 /*