fix a stupid missed thing when loading the hybrid provider, this code…

… really needs to be done cleaner
kafka-ops · Apr 27, 2022 · a611d3f · a611d3f
1 parent 195f0a3
commit a611d3f
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/main/java/com/purbon/kafka/topology/AccessControlProviderFactory.java b/src/main/java/com/purbon/kafka/topology/AccessControlProviderFactory.java
@@ -47,9 +47,9 @@ public AccessControlProvider get() throws IOException {
               ccloudProviderConstructor.newInstance(builderAdminClient, config);
         case CONFLUENT_HYBRID_CLOUD_CONTROL_CLASS:
           Constructor<?> hybridCcloudProviderConstructor =
-                  clazz.getConstructor(TopologyBuilderAdminClient.class, Configuration.class);
+              clazz.getConstructor(TopologyBuilderAdminClient.class, Configuration.class);
           return (HybridCCloudAclsProvider)
-                  hybridCcloudProviderConstructor.newInstance(builderAdminClient, config);
+              hybridCcloudProviderConstructor.newInstance(builderAdminClient, config);
         case RBAC_ACCESS_CONTROL_CLASS:
           Constructor<?> rbacProviderConstructor = clazz.getConstructor(MDSApiClient.class);
           MDSApiClient apiClient = apiClientLogIn();
@@ -71,7 +71,8 @@ public BindingsBuilderProvider builder() throws IOException {
     try {
       if (accessControlClass.equalsIgnoreCase(ACCESS_CONTROL_DEFAULT_CLASS)) {
         return new AclsBindingsBuilder(config);
-      } else if (accessControlClass.equalsIgnoreCase(CONFLUENT_CLOUD_CONTROL_CLASS)) {
+      } else if (accessControlClass.equalsIgnoreCase(CONFLUENT_CLOUD_CONTROL_CLASS)
+          || accessControlClass.equalsIgnoreCase(CONFLUENT_HYBRID_CLOUD_CONTROL_CLASS)) {
         return new AclsBindingsBuilder(config);
       } else if (accessControlClass.equalsIgnoreCase(RBAC_ACCESS_CONTROL_CLASS)) {
         MDSApiClient apiClient = apiClientLogIn();