Skip to content

Commit e05e3a4

Browse files
authored
feat(core): Replace fixed parameters with environment variables (#3075)
1 parent 5d6881b commit e05e3a4

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/kafka/log/stream/s3/network/ControllerRequestSender.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
import org.apache.kafka.server.ControllerRequestCompletionHandler;
3232
import org.apache.kafka.server.NodeToControllerChannelManager;
3333

34+
import com.automq.stream.utils.Systems;
3435
import com.automq.stream.utils.Threads;
3536

3637
import org.slf4j.Logger;
@@ -51,7 +52,7 @@ public class ControllerRequestSender {
5152

5253
private static final Logger LOGGER = LoggerFactory.getLogger(ControllerRequestSender.class);
5354

54-
private static final long MAX_RETRY_DELAY_MS = 10 * 1000; // 10s
55+
private static final long MAX_RETRY_DELAY_MS = Systems.getEnvLong("AUTOMQ_CONTROLLER_REQUEST_MAX_RETRY_DELAY_MS", 10L * 1000); // 10s
5556

5657
private final RetryPolicyContext retryPolicyContext;
5758

0 commit comments

Comments
 (0)