From 21c5e23bac69ebf74d27feab367be2e5b4986302 Mon Sep 17 00:00:00 2001
From: Mickael Maison <mickael.maison@gmail.com>
Date: Sun, 22 Jan 2023 12:24:58 +0100
Subject: [PATCH] MINOR: Remove duplicate empty string check

---
 .../apache/kafka/connect/storage/SimpleHeaderConverter.java    | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java b/connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java
index 69c4b86189878..9aaed75f2bf7c 100644
--- a/connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java
+++ b/connect/api/src/main/java/org/apache/kafka/connect/storage/SimpleHeaderConverter.java
@@ -58,9 +58,6 @@ public SchemaAndValue toConnectHeader(String topic, String headerKey, byte[] val
         }
         try {
             String str = new String(value, UTF_8);
-            if (str.isEmpty()) {
-                return new SchemaAndValue(Schema.STRING_SCHEMA, str);
-            }
             return Values.parseString(str);
         } catch (NoSuchElementException e) {
             throw new DataException("Failed to deserialize value for header '" + headerKey + "' on topic '" + topic + "'", e);