diff options
Diffstat (limited to 'kafka/test/kafkacat.yml')
| -rw-r--r-- | kafka/test/kafkacat.yml | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/test/kafkacat.yml b/kafka/test/kafkacat.yml index 61a265c..8d6c64e 100644 --- a/kafka/test/kafkacat.yml +++ b/kafka/test/kafkacat.yml @@ -23,8 +23,10 @@ data: echo "${UNIQUE: -41:5}:Test $UNIQUE" >> /shared/produce.tmp sleep $PC_WAIT LAST=$(tail -n 1 /shared/consumed.tmp) + [ -z "$LAST" ] && echo "Nothing consumed" && exit 1 LAST_TS=$(echo $LAST | awk -F';' '{print $1}') + [ -z "$LAST_TS" ] && echo "Failed to get timestamp for message: $LAST" && exit 1 LAST_MSG=$(echo $LAST | awk -F';' '{print $4}') NOW=$(date -u +%s%3N) DIFF_S=$((($NOW - $LAST_TS)/1000)) |