Runs KSQL using the kind of deployment that REST Proxy has

3 files changed, 77 insertions, 0 deletions

diff --git a/ksql/ksql-config.yml b/ksql/ksql-config.yml
new file mode 100644
index 0000000..2e1a372
--- /dev/null
+++ b/ksql/ksql-config.yml
@@ -0,0 +1,30 @@
+kind: ConfigMap
+metadata:
+  name: ksql-config
+  namespace: kafka
+apiVersion: v1
+data:
+  ksqlserver.properties: |-
+    bootstrap.servers=kafka-0.broker.kafka.svc.cluster.local:9092
+    application.id=ksql_server_quickstart
+    ksql.command.topic.suffix=commands
+
+    listeners=http://0.0.0.0:80
+
+  log4j.properties: |-
+    log4j.rootLogger=INFO, stdout
+
+    log4j.appender.stdout=org.apache.log4j.ConsoleAppender
+    log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
+    log4j.appender.stdout.layout.ConversionPattern=[%d] %p %m (%c:%L)%n
+
+    log4j.appender.streams=org.apache.log4j.ConsoleAppender
+    log4j.appender.streams.layout=org.apache.log4j.PatternLayout
+    log4j.appender.streams.layout.ConversionPattern=[%d] %p %m (%c:%L)%n
+
+    log4j.logger.kafka=ERROR, stdout
+    log4j.logger.org.apache.kafka.streams=INFO, streams
+    log4j.additivity.org.apache.kafka.streams=false
+    log4j.logger.org.apache.zookeeper=ERROR, stdout
+    log4j.logger.org.apache.kafka=ERROR, stdout
+    log4j.logger.org.I0Itec.zkclient=ERROR, stdout
diff --git a/ksql/ksql-service.yml b/ksql/ksql-service.yml
new file mode 100644
index 0000000..2668592
--- /dev/null
+++ b/ksql/ksql-service.yml
@@ -0,0 +1,10 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: ksql
+  namespace: kafka
+spec:
+  ports:
+  - port: 80
+  selector:
+    app: ksql
diff --git a/ksql/ksql.yml b/ksql/ksql.yml
new file mode 100644
index 0000000..b042955
--- /dev/null
+++ b/ksql/ksql.yml
@@ -0,0 +1,37 @@
+apiVersion: apps/v1beta1
+kind: Deployment
+metadata:
+  name: ksql
+  namespace: kafka
+spec:
+  replicas: 1
+  strategy:
+    type: RollingUpdate
+    rollingUpdate:
+      maxUnavailable: 0
+      maxSurge: 1
+  template:
+    metadata:
+      labels:
+        app: ksql
+    spec:
+      containers:
+      - name: cp
+        image: solsson/kafka-ksql@sha256:5b8555bcc047ca26c28f3932a1f3cb84baa7bb2f0f4bdc4856b9881053ae4465
+        readinessProbe:
+          httpGet:
+            path: /
+            port: 80
+        livenessProbe:
+          httpGet:
+            path: /
+            port: 80
+        ports:
+        - containerPort: 80
+        volumeMounts:
+        - name: config
+          mountPath: /etc/ksql-rest-app
+      volumes:
+      - name: config
+        configMap:
+          name: ksql-config