From 6d4cf1f7e22fa43b58430c723f8315869c9aa7a8 Mon Sep 17 00:00:00 2001
From: "Hortal, Javier" <Javier.Hortal@adidas.com>
Date: Mon, 3 Feb 2025 18:23:38 +0100
Subject: [PATCH] Add case sensitive validation

---
 kafka/kafka_acls.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/kafka/kafka_acls.go b/kafka/kafka_acls.go
index efbbf014..b76c612b 100644
--- a/kafka/kafka_acls.go
+++ b/kafka/kafka_acls.go
@@ -265,17 +265,17 @@ func (c *Client) CreateACL(s StringlyTypedACL) error {
 }
 
 func stringToACLResource(in string) (out sarama.AclResourceType) {
-	if err := out.UnmarshalText([]byte(in)); err == nil {
+	if err := out.UnmarshalText([]byte(in)); err == nil && out.String() == in { // Forces case-sensitive comparison
 		return
 	}
 	return unknownConversion
 }
 
 func ACLResourceToString(in sarama.AclResourceType) string {
-	if out, err := in.MarshalText(); err == nil {
-		return string(out)
+	if in == sarama.AclResourceUnknown {
+		return "unknownConversion"
 	}
-	return "unknownConversion"
+	return in.String()
 }
 
 func stringToOperation(in string) sarama.AclOperation {