diff --git a/execution/infrastructure/kafka-lag-exporter/install.sh b/execution/infrastructure/kafka-lag-exporter/install.sh
new file mode 100644
index 0000000000000000000000000000000000000000..525e91be95a5f31b1418e3a697d855ddd2bab3dd
--- /dev/null
+++ b/execution/infrastructure/kafka-lag-exporter/install.sh
@@ -0,0 +1,6 @@
+helm install kafka-lag-exporter https://github.com/lightbend/kafka-lag-exporter/releases/download/v0.6.0/kafka-lag-exporter-0.6.0.tgz \
+  --set clusters\[0\].name=my-confluent-cp-kafka \
+  --set clusters\[0\].bootstrapBrokers=my-confluent-cp-kafka:9092 \
+  --set pollIntervalSeconds=15 #5
+
+# Helm could also create ServiceMonitor
diff --git a/execution/infrastructure/kafka-lag-exporter/service-monitor.yaml b/execution/infrastructure/kafka-lag-exporter/service-monitor.yaml
new file mode 100644
index 0000000000000000000000000000000000000000..141dd96f9bb3973bb0f22a4aa04c29768e0a1376
--- /dev/null
+++ b/execution/infrastructure/kafka-lag-exporter/service-monitor.yaml
@@ -0,0 +1,15 @@
+apiVersion: monitoring.coreos.com/v1
+kind: ServiceMonitor
+metadata:
+  labels:
+    app: kafka-lag-exporter
+    appScope: titan-ccp
+  name: kafka-lag-exporter
+spec:
+  selector:
+    matchLabels:
+      #app: cp-kafka
+      jobLabel: kafka-lag-exporter
+  endpoints:
+    - port: http
+      interval: 5s
\ No newline at end of file