io.confluent.kafka.multitenant

Class MultiTenantInterceptorConfig

java.lang.Object

io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

public class MultiTenantInterceptorConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static MultiTenantInterceptorConfig	DEFAULT

Constructor Summary

Constructors

Constructor and Description
MultiTenantInterceptorConfig(boolean clusterPrefixForHostnameEnabled, boolean schemaValidationEnabled, boolean sbcApisEnabled, boolean shouldAppendSubdomainToHostname, String replicaSelectorClass, String brokerRack, String validBrokerRackList, Map<String,String> subdomainSeparatorMap, String subdomainSeparatorVariable, boolean fetchFromFollowerRequireLeaderEpochEnabled)
MultiTenantInterceptorConfig(Map<String,?> configs)

Method Summary

Modifier and Type	Method and Description
String	brokerRack()
static int	intConfig(Map<String,?> configs, String configName)
boolean	isClusterPrefixForHostnameEnabled()
boolean	isFetchFromFollowerEnabled()
boolean	isFetchFromFollowerRequireLeaderEpochEnabled()
boolean	isSchemaValidationEnabled()
boolean	sbcApisEnabled() Denotes whether the SBC APIs (like ConfluentAdmin.removeBrokers(List)) will be allowed through the interceptor
boolean	shouldAppendSubdomainToHostname()
Map<String,String>	subdomainSeparatorMap()
String	subdomainSeparatorVariable()
Set<String>	validBrokerRackSet()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT

public static final MultiTenantInterceptorConfig DEFAULT

Constructor Detail

MultiTenantInterceptorConfig

public MultiTenantInterceptorConfig(Map<String,?> configs)

MultiTenantInterceptorConfig

public MultiTenantInterceptorConfig(boolean clusterPrefixForHostnameEnabled,
                                    boolean schemaValidationEnabled,
                                    boolean sbcApisEnabled,
                                    boolean shouldAppendSubdomainToHostname,
                                    String replicaSelectorClass,
                                    String brokerRack,
                                    String validBrokerRackList,
                                    Map<String,String> subdomainSeparatorMap,
                                    String subdomainSeparatorVariable,
                                    boolean fetchFromFollowerRequireLeaderEpochEnabled)

Method Detail

isClusterPrefixForHostnameEnabled

public boolean isClusterPrefixForHostnameEnabled()

isFetchFromFollowerRequireLeaderEpochEnabled

public boolean isFetchFromFollowerRequireLeaderEpochEnabled()

isSchemaValidationEnabled

public boolean isSchemaValidationEnabled()

sbcApisEnabled

public boolean sbcApisEnabled()

Denotes whether the SBC APIs (like ConfluentAdmin.removeBrokers(List)) will be allowed through the interceptor

shouldAppendSubdomainToHostname

public boolean shouldAppendSubdomainToHostname()

subdomainSeparatorMap

public Map<String,String> subdomainSeparatorMap()

subdomainSeparatorVariable

public String subdomainSeparatorVariable()

brokerRack

public String brokerRack()

validBrokerRackSet

public Set<String> validBrokerRackSet()

isFetchFromFollowerEnabled

public boolean isFetchFromFollowerEnabled()

intConfig

public static int intConfig(Map<String,?> configs,
                            String configName)