diff --git a/flow/dynamicconf/dynamicconf.go b/flow/dynamicconf/dynamicconf.go index 5a5c2eb638..c0a9afcde3 100644 --- a/flow/dynamicconf/dynamicconf.go +++ b/flow/dynamicconf/dynamicconf.go @@ -44,7 +44,7 @@ func dynamicConfNumber[T constraints.Integer](ctx context.Context, key string, d return defaultValue } - result, err := strconv.ParseUint(value.String, 10, 32) + result, err := strconv.ParseInt(value.String, 10, 64) if err != nil { logger.LoggerFromCtx(ctx).Error("Failed to parse uint32: %v", err) return defaultValue