public class InterClusterConnection extends Object
Constructor and Description |
---|
InterClusterConnection() |
Modifier and Type | Method and Description |
---|---|
static String |
getBootstrapBrokerForListener(String listener,
Map<String,?> cfgMap) |
static String |
getListenerSecurityProtocol(String listener,
Map<String,?> cfgMap) |
public static String getBootstrapBrokerForListener(String listener, Map<String,?> cfgMap) throws org.apache.kafka.common.config.ConfigException
listener
- Type of listener you want to connect to. Usually "INTERNAL" or "EXTERNAL"cfgMap
- broker config of the broker you'll connect to. Should include
advertised.listeners that includes the listener you wantorg.apache.kafka.common.config.ConfigException
public static String getListenerSecurityProtocol(String listener, Map<String,?> cfgMap) throws org.apache.kafka.common.config.ConfigException
listener
- Type of listener you want to connect to. Usually "INTERNAL" or "EXTERNAL"cfgMap
- broker config of the broker you'll connect to. Should the mapping from
listeners to security protocolsorg.apache.kafka.common.config.ConfigException