From 302704b3d8fdd57e7def529654190386a49b4492 Mon Sep 17 00:00:00 2001
From: Nikhil Srivastava <50985174+Enigma25@users.noreply.github.com>
Date: Tue, 26 Sep 2023 18:29:59 +0530
Subject: [PATCH] Removed x-amz-server-side-encryption to get SEE-C working
 #684

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 a8afac74f..d547b6f3f 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)