Enable kafka functional tests

Signed-off-by: David Farr <david_farr@intuit.com>
intuit-data-os · Feb 1, 2023 · b85a505 · b85a505
1 parent 31b5ae2
commit b85a505
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git 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
@@ -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
@@ -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")
 	}