public class BrokerConfigUtils
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
ADVERTISED_HOST_NAME_PROP |
protected static java.lang.String |
ADVERTISED_LISTENERS_PROP |
protected static java.lang.String |
ADVERTISED_PORT_PROP |
protected static java.lang.String |
HOST_NAME_DEFAULT |
protected static java.lang.String |
HOST_NAME_PROP |
protected static java.lang.String |
INTER_BROKER_LISTENER_NAME_DEFAULT |
protected static java.lang.String |
INTER_BROKER_LISTENER_NAME_PROP |
protected static java.lang.String |
INTER_BROKER_SECURITY_PROTOCOL_DEFAULT |
protected static java.lang.String |
INTER_BROKER_SECURITY_PROTOCOL_PROP |
protected static java.lang.String |
LISTENER_SECURITY_PROTOCOL_MAP_DEFAULT |
protected static java.lang.String |
LISTENER_SECURITY_PROTOCOL_MAP_PROP |
protected static java.lang.String |
LISTENERS_PROP |
protected static int |
PORT_DEFAULT |
protected static java.lang.String |
PORT_PROP |
protected static java.lang.String |
RACK_PROP |
protected static java.lang.String |
URI_PARSE_REGEX_STRING |
Constructor and Description |
---|
BrokerConfigUtils() |
Modifier and Type | Method and Description |
---|---|
static java.util.Map<java.lang.String,java.lang.Object> |
deriveLocalProducerConfigs(java.util.Map<java.lang.String,java.lang.Object> originals) |
static java.lang.String |
getBalanceReplicationFactor(java.util.Map<java.lang.String,java.lang.Object> config)
return the config value for ConfluentConfigs.BALANCER_TOPICS_REPLICATION_FACTOR_CONFIG
|
static java.util.Optional<java.lang.String> |
getBrokerRack(java.util.Map<java.lang.String,java.lang.Object> configs) |
static org.apache.kafka.common.Endpoint |
getInterBrokerEndpoint(java.util.Map<java.lang.String,java.lang.Object> config) |
protected static final java.lang.String RACK_PROP
protected static final java.lang.String ADVERTISED_HOST_NAME_PROP
protected static final java.lang.String HOST_NAME_PROP
protected static final java.lang.String HOST_NAME_DEFAULT
protected static final java.lang.String ADVERTISED_PORT_PROP
protected static final java.lang.String PORT_PROP
protected static final int PORT_DEFAULT
protected static final java.lang.String ADVERTISED_LISTENERS_PROP
protected static final java.lang.String LISTENERS_PROP
protected static final java.lang.String LISTENER_SECURITY_PROTOCOL_MAP_PROP
protected static final java.lang.String LISTENER_SECURITY_PROTOCOL_MAP_DEFAULT
protected static final java.lang.String INTER_BROKER_SECURITY_PROTOCOL_PROP
protected static final java.lang.String INTER_BROKER_SECURITY_PROTOCOL_DEFAULT
protected static final java.lang.String INTER_BROKER_LISTENER_NAME_PROP
protected static final java.lang.String INTER_BROKER_LISTENER_NAME_DEFAULT
protected static final java.lang.String URI_PARSE_REGEX_STRING
public static java.lang.String getBalanceReplicationFactor(java.util.Map<java.lang.String,java.lang.Object> config)
config
- public static org.apache.kafka.common.Endpoint getInterBrokerEndpoint(java.util.Map<java.lang.String,java.lang.Object> config)
public static java.util.Map<java.lang.String,java.lang.Object> deriveLocalProducerConfigs(java.util.Map<java.lang.String,java.lang.Object> originals)
public static java.util.Optional<java.lang.String> getBrokerRack(java.util.Map<java.lang.String,java.lang.Object> configs)