public class InterClusterConnection
extends java.lang.Object
Constructor and Description |
---|
InterClusterConnection() |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
getBootstrapBrokerForListener(java.lang.String listener,
java.util.Map<java.lang.String,?> cfgMap) |
static java.lang.String |
getListenerSecurityProtocol(java.lang.String listener,
java.util.Map<java.lang.String,?> cfgMap) |
public static java.lang.String getBootstrapBrokerForListener(java.lang.String listener, java.util.Map<java.lang.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 java.lang.String getListenerSecurityProtocol(java.lang.String listener, java.util.Map<java.lang.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