From c367752598e299cbb51e593d4ee25a723a3b286e Mon Sep 17 00:00:00 2001
From: Nikhil Srivastava <50985174+Enigma25@users.noreply.github.com>
Date: Tue, 26 Sep 2023 21:23:10 +0530
Subject: [PATCH] Removed x-amz-server-side-encryption to get SEE-C working

Same as https://github.com/confluentinc/kafka-connect-storage-cloud/pull/684
---
 .../confluent/connect/s3/storage/S3OutputStream.java  | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git a/kafka-connect-s3/src/main/java/io/confluent/connect/s3/storage/S3OutputStream.java b/kafka-connect-s3/src/main/java/io/confluent/connect/s3/storage/S3OutputStream.java
index 97d037f2f..2d587e57f 100644
--- a/kafka-connect-s3/src/main/java/io/confluent/connect/s3/storage/S3OutputStream.java
+++ b/kafka-connect-s3/src/main/java/io/confluent/connect/s3/storage/S3OutputStream.java
@@ -201,19 +201,10 @@ private void internalClose() throws IOException {
     super.close();
   }
 
-  private ObjectMetadata newObjectMetadata() {
-    ObjectMetadata meta = new ObjectMetadata();
-    if (StringUtils.isNotBlank(ssea)) {
-      meta.setSSEAlgorithm(ssea);
-    }
-    return meta;
-  }
-
   private MultipartUpload newMultipartUpload() throws IOException {
     InitiateMultipartUploadRequest initRequest = new InitiateMultipartUploadRequest(
         bucket,
-        key,
-        newObjectMetadata()
+        key
     ).withCannedACL(cannedAcl);
 
     if (SSEAlgorithm.KMS.toString().equalsIgnoreCase(ssea)