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, boolean topicViewsEnabled, boolean clusterLinkK2Enabled, boolean tenantConfigSourceEnabled, int alterReplicaLogDirsMaxRequestBytes)

Method Summary

Modifier and Type	Method	Description
int	alterReplicaLogDirsMaxRequestBytes()	AlterReplicaLogDirs requests larger than this many bytes are rejected on the multi-tenant listener without parsing the body.
org.apache.kafka.common.network.BrokerFqdnBuilder	brokerFqdnBuilder()
String	brokerRack()
static MultiTenantInterceptorConfig	fromConfigMap(Map<String,?> configs)
static int	intConfig(Map<String,?> configs, String configName)
boolean	isClusterLinkK2Enabled()
boolean	isClusterPrefixForHostnameEnabled()
boolean	isFetchFromFollowerEnabled()
boolean	isFetchFromFollowerRequireLeaderEpochEnabled()
boolean	isPpv2EndPointSchemeEnabled()
boolean	isPpv2EndpointSchemeMapBrokerToGatewayZoneEnabled()
boolean	isSchemaValidationEnabled()
boolean	isTenantConfigSourceEnabled()
boolean	isTopicViewsEnabled()
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 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,
 boolean topicViewsEnabled,
 boolean clusterLinkK2Enabled,
 boolean tenantConfigSourceEnabled,
 int alterReplicaLogDirsMaxRequestBytes)

Method Details

fromConfigMap

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

isClusterPrefixForHostnameEnabled

public boolean isClusterPrefixForHostnameEnabled()

isFetchFromFollowerRequireLeaderEpochEnabled

public boolean isFetchFromFollowerRequireLeaderEpochEnabled()

isSchemaValidationEnabled

public boolean isSchemaValidationEnabled()

isTopicViewsEnabled

public boolean isTopicViewsEnabled()

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

isClusterLinkK2Enabled

public boolean isClusterLinkK2Enabled()

isTenantConfigSourceEnabled

public boolean isTenantConfigSourceEnabled()

alterReplicaLogDirsMaxRequestBytes

public int alterReplicaLogDirsMaxRequestBytes()

AlterReplicaLogDirs requests larger than this many bytes are rejected on the multi-tenant listener without parsing the body. A value below 0 means the check is disabled.

intConfig

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