feat(dash): add initial kafka injector support

crates/dash/operator/src/ctx/injectors/kafka.yaml.j2

@@ -0,0 +1,33 @@
+---
+apiVersion: kafka.strimzi.io/v1beta2
+kind: Kafka
+metadata:
+  name: "{{ metadata.name }}"
+  namespace: "{{ metadata.namespace }}"
+spec:
+  kafka:
+    replicas: 1
+    listeners:
+      - name: plain
+        port: 9092
+        type: internal
+        tls: false
+      - name: tls
+        port: 9093
+        type: internal
+        tls: true
+    config:
+      default.replication.factor: 1
+      min.insync.replicas: 1
+      offsets.topic.replication.factor: 1
+      transaction.state.log.min.isr: 1
+      transaction.state.log.replication.factor: 1
+    storage:
+      type: ephemeral
+  zookeeper:
+    replicas: 1
+    storage:
+      type: ephemeral
+  entityOperator:
+    topicOperator: {}
+    userOperator: {}

crates/dash/operator/src/ctx/injectors/mod.rs

@@ -30,6 +30,7 @@ macro_rules! define_injector {
 }
 
 define_injector![
+    kafka as "kafka",
     nats as "nats",
     otlp as "dash-observability",
 ];

crates/dash/operator/src/main.rs

@@ -15,6 +15,7 @@ pub(crate) mod consts {
 async fn main() {
     join!(
         self::ctx::function::Ctx::spawn_crd(),
+        self::ctx::injectors::kafka::Ctx::spawn(),
         self::ctx::injectors::nats::Ctx::spawn(),
         self::ctx::injectors::otlp::Ctx::spawn(),
         self::ctx::job::Ctx::spawn_crd(),