...
Providing the command line tool kafka-consumer-perf-test.sh with an optional --polling-loop-timeout parameter:
parameter name | defaults to | type | time unit | usage |
---|---|---|---|---|
--timeout | 10000 | Long | ms | optional |
...
- Increasing polling loop timeout in ConsumerPerformance implementation up to 60 10 000 ms
- Making polling loop timeout reachable and modifiable by the end user from the command line kafka-consumer-perf-test tool
- If Print a warning message if the polling loop timeout is exceeded, print a warning message
Proposed changes in code available in this PR: https://github.com/apache/kafka/pull/4818
...