aboutsummaryrefslogtreecommitdiff
path: root/addon-events/events-kube-kafka.yml
diff options
context:
space:
mode:
Diffstat (limited to 'addon-events/events-kube-kafka.yml')
-rw-r--r--addon-events/events-kube-kafka.yml12
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