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