diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-10-16 10:51:12 +0200 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-11-09 13:48:51 +0100 |
| commit | a3196474939f399ec23272738df3a536386abe7b (patch) | |
| tree | 8f95baef4d63c4f6e25fb3b5e64aeb2432973ccd | |
| parent | f4387f1c89f6cc4d1d1778dd0aabba54c7eef8c1 (diff) | |
| download | kubernetes-kafka-a3196474939f399ec23272738df3a536386abe7b.tar.gz kubernetes-kafka-a3196474939f399ec23272738df3a536386abe7b.tar.bz2 kubernetes-kafka-a3196474939f399ec23272738df3a536386abe7b.zip | |
Divides a couple of librdkafka timoeuts by 100
| -rw-r--r-- | test/basic-with-kafkacat.yml | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/basic-with-kafkacat.yml b/test/basic-with-kafkacat.yml index d5ec996..78b5819 100644 --- a/test/basic-with-kafkacat.yml +++ b/test/basic-with-kafkacat.yml @@ -45,8 +45,9 @@ data: fi # get info about this message - kafkacat -Q -b $BOOTSTRAP -t test-basic-with-kafkacat:0:$LAST_TS || \ - echo "At $(date +%FT%H:%M:%S.%3N) bootstrap broker might be down" + kafkacat -Q -b $BOOTSTRAP -t test-basic-with-kafkacat:0:$LAST_TS \ + -X socket.timeout.ms=600 -X session.timeout.ms=300 -X request.timeout.ms=50 -X metadata.request.timeout.ms=600 + [ $? -eq 0 ] || echo "At $(date +%FT%H:%M:%S.%3N) bootstrap broker(s) might be down" # but don't fail the test; producer and consumer should keep going if there are other brokers # We haven't asserted that the consumer works, so we'll just have to assume that it will exit if it fails |