feat: Kafka EventBus (#2502)

Signed-off-by: David Farr <david_farr@intuit.com>
Signed-off-by: Prema devi Kuppuswamy <premadk@gmail.com>
Signed-off-by: Bilal Bakht Ahmad <tringingly@gmail.com>
Co-authored-by: Prema <107519450+premadk@users.noreply.github.com>
Co-authored-by: Bilal Bakht Ahmad <bilalba@users.noreply.github.com>
Co-authored-by: Bilal Bakht Ahmad <tringingly@gmail.com>

.github/workflows/ci.yaml

@@ -113,7 +113,7 @@ jobs:
   e2e-tests:
     name: E2E Tests
     runs-on: ubuntu-latest
-    timeout-minutes: 20
+    timeout-minutes: 25
     env:
       KUBECONFIG: /home/runner/.kubeconfig
     strategy:
@@ -123,6 +123,7 @@ jobs:
         include:
           - driver: stan
           - driver: jetstream
+          - driver: kafka
     steps:
       - name: Checkout code
         uses: actions/checkout@v3

Makefile

@@ -87,7 +87,14 @@ test:
 	go test $(shell go list ./... | grep -v /vendor/ | grep -v /test/e2e/) -race -short -v
 
 test-functional:
-	go test -v -timeout 15m -count 1 --tags functional -p 1 ./test/e2e
+ifeq ($(EventBusDriver),kafka)
+	kubectl -n argo-events apply -k test/manifests/kafka
+	kubectl -n argo-events wait -l statefulset.kubernetes.io/pod-name=kafka-0 --for=condition=ready pod --timeout=60s
+endif
+	go test -v -timeout 20m -count 1 --tags functional -p 1 ./test/e2e
+ifeq ($(EventBusDriver),kafka)
+	kubectl -n argo-events delete -k test/manifests/kafka
+endif
 
 # to run just one of the functional e2e tests by name (i.e. 'make TestMetricsWithWebhook'):
 Test%: