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 for tests 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org