This is an automated email from the ASF dual-hosted git repository.
showuon pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4cec840baf2 KAFKA-16661: Added a lower `log.initial.task.delay.ms`
value (#16221)
4cec840baf2 is described below
commit 4cec840baf2b32261751e8d48c80c273390696a8
Author: Vinay Agarwal <[email protected]>
AuthorDate: Mon Jul 15 14:36:54 2024 +0530
KAFKA-16661: Added a lower `log.initial.task.delay.ms` value (#16221)
added a lower log.initial.task.delay.ms value to integration test framework
to 500ms
Reviewers: Luke Chen <[email protected]>
---
core/src/test/scala/unit/kafka/utils/TestUtils.scala | 1 +
.../src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/core/src/test/scala/unit/kafka/utils/TestUtils.scala
b/core/src/test/scala/unit/kafka/utils/TestUtils.scala
index c9349201968..369ac60d135 100755
--- a/core/src/test/scala/unit/kafka/utils/TestUtils.scala
+++ b/core/src/test/scala/unit/kafka/utils/TestUtils.scala
@@ -348,6 +348,7 @@ object TestUtils extends Logging {
props.put(ServerConfigs.CONTROLLED_SHUTDOWN_RETRY_BACKOFF_MS_CONFIG, "100")
props.put(CleanerConfig.LOG_CLEANER_DEDUPE_BUFFER_SIZE_PROP, "2097152")
props.put(GroupCoordinatorConfig.OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG,
"1")
+ props.put(ServerLogConfigs.LOG_INITIAL_TASK_DELAY_MS_CONFIG, "100")
if
(!props.containsKey(GroupCoordinatorConfig.OFFSETS_TOPIC_PARTITIONS_CONFIG))
props.put(GroupCoordinatorConfig.OFFSETS_TOPIC_PARTITIONS_CONFIG, "5")
if
(!props.containsKey(GroupCoordinatorConfig.GROUP_INITIAL_REBALANCE_DELAY_MS_CONFIG))
diff --git
a/server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java
b/server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java
index 17d4e683978..c6e0810262c 100644
---
a/server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java
+++
b/server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java
@@ -195,4 +195,4 @@ public class ServerLogConfigs {
public static final Long LOG_DIR_FAILURE_TIMEOUT_MS_DEFAULT = 30000L;
public static final String LOG_DIR_FAILURE_TIMEOUT_MS_DOC = "If the broker
is unable to successfully communicate to the controller that some log " +
"directory has failed for longer than this time, the broker will fail
and shut down.";
-}
+}
\ No newline at end of file
