Package io.confluent.telemetry

Class BrokerConfigUtils

java.lang.Object

io.confluent.telemetry.BrokerConfigUtils

public class BrokerConfigUtils
extends Object

This class was created to extract the interbroker client configs from the broker at runtime. Since the reporter is passed all of the broker configs during initialization, we decided that it makes more sense to just extract them here as opposed to trying to duplicate configs and special-case our reporter inside the broker code. This is essentially copied code from the KafkaConfig and Endpoint broker classes.

Constructor Summary

Constructors

Constructor	Description
BrokerConfigUtils()

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

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

Constructor Details

BrokerConfigUtils

public BrokerConfigUtils()

Method Details

getBalanceReplicationFactor

public static String getBalanceReplicationFactor(Map<String,Object> config)

return the config value for ConfluentConfigs.BALANCER_TOPICS_REPLICATION_FACTOR_CONFIG

Parameters:

config -

Returns:

the value of the config if defined, otherwise null

getInterBrokerEndpoint

public static org.apache.kafka.common.Endpoint getInterBrokerEndpoint(Map<String,Object> config)

deriveLocalProducerConfigs

public static Map<String,Object> deriveLocalProducerConfigs(Map<String,Object> originals)

getBrokerRack

public static Optional<String> getBrokerRack(Map<String,Object> configs)