brandboat commented on code in PR #15719:
URL: https://github.com/apache/kafka/pull/15719#discussion_r1567464576
##########
core/src/test/scala/unit/kafka/utils/TestUtils.scala:
##########
@@ -1524,7 +1524,8 @@ object TestUtils extends Logging {
logDirFailureChannel = new
LogDirFailureChannel(logDirs.size),
keepPartitionMetadataFile = true,
interBrokerProtocolVersion = interBrokerProtocolVersion,
- remoteStorageSystemEnable = remoteStorageSystemEnable)
+ remoteStorageSystemEnable = remoteStorageSystemEnable,
+ initialTaskDelayMs =
LogConfig.DEFAULT_INITIAL_TASK_DELAY_MS)
Review Comment:
Thanks for your comment @soarez :smiley: ! If I understand correctly
TestUtils#createLogManager use MockTime and the clock would advance immediately
after invoking the time#sleep method in the test, pointing to the corresponding
sleep time thereafter. The goal in this pr is to introduce a new internal
config to speed up for tests like e2e/integration tests which can't use
MockTime as above.
--
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]
