fix issue when listing transactionId resourceType in the RBAC provide…

…r as name is transient from the ACLs default one
kafka-ops · May 3, 2021 · dd33e45 · dd33e45
1 parent 6c48ea4
commit dd33e45
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 1 deletion.
diff --git a/src/main/java/com/purbon/kafka/topology/api/mds/RbacResourceType.java b/src/main/java/com/purbon/kafka/topology/api/mds/RbacResourceType.java
@@ -27,4 +27,19 @@ public String getName() {
   public String getPatternType() {
     return patternType;
   }
+
+  @Override
+  public String toString() {
+    return "RbacResourceType{"
+        + "resourceType='"
+        + resourceType
+        + '\''
+        + ", name='"
+        + name
+        + '\''
+        + ", patternType='"
+        + patternType
+        + '\''
+        + '}';
+  }
 }
diff --git a/src/main/java/com/purbon/kafka/topology/roles/RBACProvider.java b/src/main/java/com/purbon/kafka/topology/roles/RBACProvider.java
@@ -65,7 +65,7 @@ public Map<String, List<TopologyAclBinding>> listAcls() {
           }
           TopologyAclBinding binding =
               TopologyAclBinding.build(
-                  resource.getResourceType().toUpperCase(),
+                  normalize(resource.getResourceType()),
                   resource.getName(),
                   "*",
                   roleName,
@@ -77,4 +77,9 @@ public Map<String, List<TopologyAclBinding>> listAcls() {
     }
     return map;
   }
+
+  private String normalize(String resourceType) {
+    String[] fields = resourceType.split("(?=\\p{Upper})");
+    return String.join("_", fields).toUpperCase();
+  }
 }