public class BrokerConfigUtils extends Object
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) |
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)