diff --git a/mountpoint-s3-client/src/s3_crt_client.rs b/mountpoint-s3-client/src/s3_crt_client.rs
index f28a965fc..dc3fea056 100644
--- a/mountpoint-s3-client/src/s3_crt_client.rs
+++ b/mountpoint-s3-client/src/s3_crt_client.rs
@@ -75,6 +75,7 @@ pub struct S3ClientConfig {
     endpoint: Option<Endpoint>,
     user_agent_prefix: Option<String>,
     request_payer: Option<String>,
+    bucket_owner: Option<String>,
 }
 
 impl Default for S3ClientConfig {
@@ -86,6 +87,7 @@ impl Default for S3ClientConfig {
             endpoint: None,
             user_agent_prefix: None,
             request_payer: None,
+            bucket_owner: None,
         }
     }
 }
@@ -136,6 +138,13 @@ impl S3ClientConfig {
         self.request_payer = Some(request_payer.to_owned());
         self
     }
+
+    /// Set an expected bucket owner value
+    #[must_use = "S3ClientConfig follows a builder pattern"]
+    pub fn bucket_owner(mut self, bucket_owner: &str) -> Self {
+        self.bucket_owner = Some(bucket_owner.to_owned());
+        self
+    }
 }
 
 #[derive(Debug, Clone, Default)]
@@ -180,6 +189,7 @@ struct S3CrtClientInner {
     user_agent_header: String,
     request_payer: Option<String>,
     part_size: usize,
+    bucket_owner: Option<String>,
 }
 
 impl S3CrtClientInner {
@@ -277,6 +287,7 @@ impl S3CrtClientInner {
             user_agent_header,
             request_payer: config.request_payer,
             part_size: config.part_size,
+            bucket_owner: config.bucket_owner,
         })
     }
 
@@ -304,6 +315,10 @@ impl S3CrtClientInner {
             message.add_header(&Header::new("x-amz-request-payer", payer))?;
         }
 
+        if let Some(ref owner) = self.bucket_owner {
+            message.add_header(&Header::new("x-amz-expected-bucket-owner", owner))?;
+        }
+
         Ok(S3Message {
             inner: message,
             uri,
@@ -798,6 +813,8 @@ impl ObjectClient for S3CrtClient {
 
 #[cfg(test)]
 mod tests {
+    use std::assert_eq;
+
     use super::*;
     use test_case::test_case;
 
@@ -868,4 +885,13 @@ mod tests {
         headers.add_header(&header).unwrap();
         extract_range_header(&headers)
     }
+
+    /// Simple test to ensure the expected bucket owner can be set
+    #[test]
+    fn test_expected_bucket_owner() {
+        let mut config: S3ClientConfig = Default::default();
+
+        config = config.bucket_owner("some_acnt_id");
+        assert_eq!(config.bucket_owner, Some("some_acnt_id".to_owned()));
+    }
 }
diff --git a/mountpoint-s3/src/main.rs b/mountpoint-s3/src/main.rs
index fb4a18c01..4de4e8e78 100644
--- a/mountpoint-s3/src/main.rs
+++ b/mountpoint-s3/src/main.rs
@@ -234,6 +234,9 @@ struct CliArgs {
 
     #[clap(long, help = "Use a specific profile from your credential file.", help_heading = AWS_CREDENTIALS)]
     pub profile: Option<String>,
+
+    #[clap(long, help = "Expected bucket owner (use: <aws-acct-id>)", help_heading = AWS_CREDENTIALS)]
+    pub expected_bucket_owner: Option<String>,
 }
 
 impl CliArgs {
@@ -406,6 +409,10 @@ fn mount(args: CliArgs) -> anyhow::Result<FuseSession> {
         client_config = client_config.request_payer("requester");
     }
 
+    if let Some(ref owner) = args.expected_bucket_owner {
+        client_config = client_config.bucket_owner(owner);
+    }
+
     let client = create_client_for_bucket(
         &args.bucket_name,
         args.region.as_deref(),