Skip to content

Commit b69712b

Browse files
committed
feat(core): Replace fixed parameters with environment variables
1 parent da9ae1a commit b69712b

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

core/src/main/java/kafka/automq/failover/NodeRuntimeMetadata.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,10 @@
2323
import org.apache.kafka.controller.stream.NodeMetadata;
2424
import org.apache.kafka.controller.stream.NodeState;
2525

26+
import com.automq.stream.utils.Systems;
27+
2628
import java.util.Map;
2729
import java.util.Objects;
28-
import java.util.concurrent.TimeUnit;
2930

3031
/**
3132
* NodeRuntimeMetadata is a runtime view of a node's metadata.
@@ -40,7 +41,7 @@ public final class NodeRuntimeMetadata {
4041
* @see ClusterControlManager#getNextNodeId()
4142
*/
4243
private static final int MAX_CONTROLLER_ID = 1000 - 1;
43-
private static final long DONT_FAILOVER_AFTER_NEW_EPOCH_MS = TimeUnit.MINUTES.toMillis(1);
44+
private static final long DONT_FAILOVER_AFTER_NEW_EPOCH_MS = Systems.getEnvLong("AUTOMQ_CONTROLLER_DONT_FAILOVER_AFTER_NEW_EPOCH_MS", 60L * 1000);
4445
private final int id;
4546
private final long epoch;
4647
private final String walConfigs;

0 commit comments

Comments
 (0)