lucasbru opened a new pull request, #22461: URL: https://github.com/apache/kafka/pull/22461
This change makes the consumer close timeout configurable in the `VerifiableConsumer` system test tool instead of relying on a hardcoded value. The Java tool now accepts a `--close-timeout` argument in milliseconds, and the Python test service (`verifiable_consumer.py`) exposes this as a `close_timeout_sec` parameter that is passed through on the command line. While here, the deprecated `KafkaConsumer.close(Duration)` call is replaced with the newer `CloseOptions.timeout()` API. The motivation is test stability. The Python service waits for nodes to exit within 30 seconds, so the consumer close needs to complete in less than that. The service now defaults to a 15 second close timeout, which leaves enough headroom, and individual tests can override it when a particular scenario needs a different value. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
