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

Reply via email to