diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-10-26 22:07:21 +0200 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-10-26 22:23:38 +0200 |
| commit | d628275ff253366f93c2533c7bdd191c909ebd69 (patch) | |
| tree | 53916c22ca44278980860dbde714cc926614d864 | |
| parent | e4c517984066f8e76909ec8a38fd414ada2c10c4 (diff) | |
| download | kubernetes-kafka-d628275ff253366f93c2533c7bdd191c909ebd69.tar.gz kubernetes-kafka-d628275ff253366f93c2533c7bdd191c909ebd69.tar.bz2 kubernetes-kafka-d628275ff253366f93c2533c7bdd191c909ebd69.zip | |
bash -e is important, in combination with curl -f, so ...
we don't send error messages to the topic
(even if it's json -- format is different and it's pretty printed)
| -rw-r--r-- | addon-events/events-kube-kafka.yml | 14 |
1 files changed, 2 insertions, 12 deletions
diff --git a/addon-events/events-kube-kafka.yml b/addon-events/events-kube-kafka.yml index a707b1c..92387aa 100644 --- a/addon-events/events-kube-kafka.yml +++ b/addon-events/events-kube-kafka.yml @@ -28,12 +28,12 @@ spec: value: ops-kube-events-all-json-001 command: - /bin/bash - - -c - # curl errors will go to kafka, kafkacat errors will got to log + - -ec - > echo "Started at $(date -u +%FT%TZ) producing to $TOPIC" ; curl + -f -s --cacert /run/secrets/kubernetes.io/serviceaccount/ca.crt --header "Authorization: Bearer $(cat /run/secrets/kubernetes.io/serviceaccount/token)" @@ -46,13 +46,3 @@ spec: -z snappy -v -d broker,topic - ; - echo "Last message on topic:" - ; - kafkacat - -b $BOOTSTRAP - -t $TOPIC - -C - -o -1 - -c 1 - -z snappy |