Add case sensitive validation

Mongey · Feb 3, 2025 · 6d4cf1f · 6d4cf1f
1 parent b9191ae
commit 6d4cf1f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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 {