From b8f6078ac45465eff37df9acd67d1bf2c41ae448 Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Thu, 9 Nov 2017 15:33:14 +0100
Subject: Fixes a test issue at start and at consumer error

---
 kafka/test/kafkacat.yml | 2 ++
 1 file changed, 2 insertions(+)

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))
-- 
cgit v1.2.3