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, boolean ppv2EndPointSchemeEnabled, org.apache.kafka.common.network.BrokerFqdnBuilder brokerFqdnBuilder)

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.network.BrokerFqdnBuilder	brokerFqdnBuilder()
String	brokerRack()
static MultiTenantInterceptorConfig	fromConfigMap(Map<String,?> configs)
static int	intConfig(Map<String,?> configs, String configName)
boolean	isClusterPrefixForHostnameEnabled()
boolean	isFetchFromFollowerEnabled()
boolean	isFetchFromFollowerRequireLeaderEpochEnabled()
boolean	isPpv2EndPointSchemeEnabled()
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(boolean clusterPrefixForHostnameEnabled,
                                    boolean schemaValidationEnabled,
                                    boolean sbcApisEnabled,
                                    boolean shouldAppendSubdomainToHostname,
                                    String replicaSelectorClass,
                                    String brokerRack,
                                    String validBrokerRackList,
                                    Map<String,String> subdomainSeparatorMap,
                                    String subdomainSeparatorVariable,
                                    boolean fetchFromFollowerRequireLeaderEpochEnabled,
                                    boolean ppv2EndPointSchemeEnabled,
                                    org.apache.kafka.common.network.BrokerFqdnBuilder brokerFqdnBuilder)

Method Detail

fromConfigMap

public static MultiTenantInterceptorConfig fromConfigMap(Map<String,?> configs)

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()

isPpv2EndPointSchemeEnabled

public boolean isPpv2EndPointSchemeEnabled()

brokerFqdnBuilder

public org.apache.kafka.common.network.BrokerFqdnBuilder brokerFqdnBuilder()

intConfig

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