Verify schemas deletion process successfully, complement the related …

…test (#516)
kafka-ops · Aug 5, 2022 · fe3a156 · fe3a156
1 parent cc8f25c
commit fe3a156
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/test/java/com/purbon/kafka/topology/integration/RBACPRoviderRbacIT.java b/src/test/java/com/purbon/kafka/topology/integration/RBACPRoviderRbacIT.java
@@ -331,6 +331,15 @@ public void schemasRbacCreation() throws IOException {
       assertThat(names).contains(resource.getName());
       assertThat(resource.getResourceType()).isEqualTo("Subject");
     }
+    // remove the first and only schema and check if properly deleted.
+    topology.getProjects().get(0).setSchemas(Collections.emptyList());
+
+    accessControlManager.updatePlan(topology, plan);
+    plan.run();
+
+    resources = apiClient.lookupResourcesForSchemaRegistry(schema.getPrincipal(), RESOURCE_OWNER);
+    assertThat(resources).isEmpty();
+
   }
 
   @Test