We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 593a838 commit c902ca7Copy full SHA for c902ca7
test/basic-with-kafkacat.yml
@@ -45,8 +45,9 @@ data:
45
fi
46
47
# get info about this message
48
- kafkacat -Q -b $BOOTSTRAP -t test-basic-with-kafkacat:0:$LAST_TS || \
49
- 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
50
+ [ $? -eq 0 ] || echo "At $(date +%FT%H:%M:%S.%3N) bootstrap broker(s) might be down"
51
# but don't fail the test; producer and consumer should keep going if there are other brokers
52
53
# We haven't asserted that the consumer works, so we'll just have to assume that it will exit if it fails
0 commit comments