diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-10-26 22:02:53 +0200 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-10-26 22:02:59 +0200 |
| commit | e4c517984066f8e76909ec8a38fd414ada2c10c4 (patch) | |
| tree | 0d80b0298695a74a09493ea3b9f02be285abfb32 | |
| parent | b9e7b8a02e328309907bd024619008d8d7cdfc07 (diff) | |
| download | kubernetes-kafka-e4c517984066f8e76909ec8a38fd414ada2c10c4.tar.gz kubernetes-kafka-e4c517984066f8e76909ec8a38fd414ada2c10c4.tar.bz2 kubernetes-kafka-e4c517984066f8e76909ec8a38fd414ada2c10c4.zip | |
Argh, curl will pretty print the json ...
and kafkacat will produce each line separately
| -rw-r--r-- | addon-events/events-kube-kafka.yml | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/addon-events/events-kube-kafka.yml b/addon-events/events-kube-kafka.yml index 062d097..a707b1c 100644 --- a/addon-events/events-kube-kafka.yml +++ b/addon-events/events-kube-kafka.yml @@ -28,7 +28,7 @@ spec: value: ops-kube-events-all-json-001 command: - /bin/bash - - -ec + - -c # curl errors will go to kafka, kafkacat errors will got to log - > echo "Started at $(date -u +%FT%TZ) producing to $TOPIC" @@ -46,3 +46,13 @@ spec: -z snappy -v -d broker,topic + ; + echo "Last message on topic:" + ; + kafkacat + -b $BOOTSTRAP + -t $TOPIC + -C + -o -1 + -c 1 + -z snappy |