Class MultiTenantInterceptorConfig

java.lang.Object

io.confluent.kafka.multitenant.MultiTenantInterceptorConfig

public class MultiTenantInterceptorConfig
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final MultiTenantInterceptorConfig	DEFAULT

Constructor Summary

Constructors

Constructor

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

Method Summary

Modifier and Type	Method	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	isPpv2EndpointSchemeMapBrokerToGatewayZoneEnabled()
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()
boolean	zoneTaggedRequestMetricsEnabled()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT

public static final MultiTenantInterceptorConfig DEFAULT

Constructor Details

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

Method Details

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

isPpv2EndpointSchemeMapBrokerToGatewayZoneEnabled

public boolean isPpv2EndpointSchemeMapBrokerToGatewayZoneEnabled()

brokerFqdnBuilder

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

zoneTaggedRequestMetricsEnabled

public boolean zoneTaggedRequestMetricsEnabled()

intConfig

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