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

For this on call issue, this PR fixes the problem, as a JAR was made and shared with customer to which they responded affirmatively.

Now they want a global release for this, hence putting this patch in all branches 10.0.x onwards.
---
 .../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)