From b85a505201ad092f1c143dec16dfa7fd372a8aea Mon Sep 17 00:00:00 2001 From: David Farr Date: Fri, 27 Jan 2023 10:22:18 -0800 Subject: [PATCH] Enable kafka functional tests Signed-off-by: David Farr --- .github/workflows/ci.yaml | 1 + controllers/eventsource/resource.go | 2 ++ controllers/sensor/resource.go | 2 ++ 3 files changed, 5 insertions(+) diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml index 681794918e..b6b4bcb49a 100644 --- a/.github/workflows/ci.yaml +++ b/.github/workflows/ci.yaml @@ -125,6 +125,7 @@ jobs: include: - driver: stan - driver: jetstream + - driver: kafka steps: - name: Checkout code uses: actions/checkout@v3 diff --git a/controllers/eventsource/resource.go b/controllers/eventsource/resource.go index 53de809f87..52b93dffe0 100644 --- a/controllers/eventsource/resource.go +++ b/controllers/eventsource/resource.go @@ -207,6 +207,8 @@ func buildDeployment(args *AdaptorArgs, eventBus *eventbusv1alpha1.EventBus) (*a case eventBus.Status.Config.JetStream != nil: jsConf := eventBus.Status.Config.JetStream accessSecret = jsConf.AccessSecret + case eventBus.Status.Config.Kafka != nil: + accessSecret = nil // todo default: return nil, fmt.Errorf("unsupported event bus") } diff --git a/controllers/sensor/resource.go b/controllers/sensor/resource.go index 4e546e8e9d..cd00e517bb 100644 --- a/controllers/sensor/resource.go +++ b/controllers/sensor/resource.go @@ -168,6 +168,8 @@ func buildDeployment(args *AdaptorArgs, eventBus *eventbusv1alpha1.EventBus) (*a case eventBus.Status.Config.JetStream != nil: jsConf := eventBus.Status.Config.JetStream accessSecret = jsConf.AccessSecret + case eventBus.Status.Config.Kafka != nil: + accessSecret = nil // todo default: return nil, fmt.Errorf("unsupported event bus") }