aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStaffan Olsson <staffan@repos.se>2017-10-26 21:56:03 +0200
committerStaffan Olsson <staffan@repos.se>2017-10-26 21:56:03 +0200
commitb9e7b8a02e328309907bd024619008d8d7cdfc07 (patch)
tree29a8e08d8a36bb02218f7bda6a249b7e2b04e96b
parent8d0d99302b80e960b592d1d8779b3c502815fc19 (diff)
downloadkubernetes-kafka-b9e7b8a02e328309907bd024619008d8d7cdfc07.tar.gz
kubernetes-kafka-b9e7b8a02e328309907bd024619008d8d7cdfc07.tar.bz2
kubernetes-kafka-b9e7b8a02e328309907bd024619008d8d7cdfc07.zip
Makes things a bit less obscure if for example RBAC fails
-rw-r--r--addon-events/events-kube-kafka.yml14
1 files changed, 12 insertions, 2 deletions
diff --git a/addon-events/events-kube-kafka.yml b/addon-events/events-kube-kafka.yml
index 2d6913a..062d097 100644
--- a/addon-events/events-kube-kafka.yml
+++ b/addon-events/events-kube-kafka.yml
@@ -21,10 +21,18 @@ spec:
containers:
- name: kafkacat-curl
image: solsson/kafkacat-curl@sha256:6ad61f2e6343359c3972d7a86815568c0a1d0560068134c5d702a152eb5123a0
+ env:
+ - name: BOOTSTRAP
+ value: kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
+ - name: TOPIC
+ value: ops-kube-events-all-json-001
command:
- /bin/bash
- -ec
+ # curl errors will go to kafka, kafkacat errors will got to log
- >
+ echo "Started at $(date -u +%FT%TZ) producing to $TOPIC"
+ ;
curl
-s
--cacert /run/secrets/kubernetes.io/serviceaccount/ca.crt
@@ -32,7 +40,9 @@ spec:
https://$KUBERNETES_SERVICE_HOST:$KUBERNETES_SERVICE_PORT/api/v1/watch/events
|
kafkacat
- -b kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
- -t ops-kube-events-all-json-001
+ -b $BOOTSTRAP
+ -t $TOPIC
-P
-z snappy
+ -v
+ -d broker,topic