Class MultiTenantConfigRestrictions

java.lang.Object
io.confluent.kafka.multitenant.MultiTenantConfigRestrictions

public class MultiTenantConfigRestrictions extends Object
  • Field Details

    • EXTERNAL_LISTENER_PREFIX

      public static final String EXTERNAL_LISTENER_PREFIX
    • UPDATABLE_BROKER_CONFIGS

      public static final Set<String> UPDATABLE_BROKER_CONFIGS
    • VISIBLE_BROKER_CONFIGS

      public static final Set<String> VISIBLE_BROKER_CONFIGS
    • UPDATABLE_GROUP_CONFIGS

      public static final Set<String> UPDATABLE_GROUP_CONFIGS
  • Constructor Details

    • MultiTenantConfigRestrictions

      public MultiTenantConfigRestrictions()
  • Method Details

    • updatableTopicConfig

      public static boolean updatableTopicConfig(String configName, boolean schemaValidationEnabled)
    • updatableFreightTopicConfig

      public static boolean updatableFreightTopicConfig(String configName)
    • visibleTopicConfig

      public static boolean visibleTopicConfig(String configName, boolean schemaValidationEnabled)
    • prependExternalListenerToConfigName

      public static Optional<String> prependExternalListenerToConfigName(String configName)
      Return an empty Optional if `configName` is not an updatable listener config name, otherwise return the config name with `EXTERNAL_LISTENER_PREFIX` prepended within the Optional.
    • stripExternalListenerPrefixFromConfigName

      public static Optional<String> stripExternalListenerPrefixFromConfigName(String configName)
      Return an empty Optional if `configName` is not an updatable external listener config name, otherwise return the config name with `EXTERNAL_LISTENER_PREFIX` stripped within the Optional.