Class TenantLifecycleManager

java.lang.Object
io.confluent.kafka.multitenant.TenantLifecycleManager
public class TenantLifecycleManager extends Object

  • Constructor Details

    • TenantLifecycleManager

      public TenantLifecycleManager(Map<String,?> configs, org.apache.kafka.common.utils.Time time)

  • Method Details

    • setAdminSupplierAndCreateClient

      public void setAdminSupplierAndCreateClient(Function<String, org.apache.kafka.clients.admin.Admin> adminClientSupplier)

    • createAdminClient

      public void createAdminClient()

    • updateTenantState

      public void updateTenantState(io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata lcMeta)

    • isClusterActive

      public boolean isClusterActive(String lcId)
      Returns true if the cluster with the given id is active, false otherwise (a non-existing cluster is considered inactive)

    • inactiveClusters

      public Set<String> inactiveClusters()
      Return all logical clusters that are deactivated

    • deactivatedClusters

      public Set<String> deactivatedClusters()
      Returns the list of all tenants that are deactivated, but not yet being deleted.
      Returns:
      a set of logical cluster IDs

    • fullyDeletedClusters

      public Set<String> fullyDeletedClusters()
      Return all logical clusters that are considered deleted and we won't try to delete again Used for testing

    • deletedClusters

      public Set<String> deletedClusters()
      Return all logical clusters that were deleted or being deleted Used for testing
      Returns:
      set of logical cluster IDs

    • deleteTenants

      public void deleteTenants()

    • close

      public void close()