diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-11-09 15:33:14 +0100 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-11-09 15:55:03 +0100 |
| commit | b8f6078ac45465eff37df9acd67d1bf2c41ae448 (patch) | |
| tree | 5d8e0dae3561136f03be9dd8f42d41657e10f657 | |
| parent | 46860ebca5b919b3fbe709e85701b084dc851ea9 (diff) | |
| download | kubernetes-kafka-1.8-manifests.tar.gz kubernetes-kafka-1.8-manifests.tar.bz2 kubernetes-kafka-1.8-manifests.zip | |
Fixes a test issue at start and at consumer error1.8-manifests
| -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)) |