public class ZookeeperConfiguration extends AbstractConfiguration
Configuration
that uses a ZooKeeper connection for retrieving the list of seed brokers.Modifier and Type | Field and Description |
---|---|
static org.springframework.integration.kafka.core.ZookeeperConfiguration.BrokerToBrokerAddressFunction |
brokerToBrokerAddressFunction |
Constructor and Description |
---|
ZookeeperConfiguration(java.lang.String zookeeperConnectionString) |
ZookeeperConfiguration(ZookeeperConnect zookeeperConnect) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<BrokerAddress> |
doGetBrokerAddresses() |
afterPropertiesSet, getBrokerAddresses, getBufferSize, getClientId, getDefaultPartitions, getDefaultTopic, getFetchMetadataTimeout, getMaxWait, getMinBytes, getSocketTimeout, setBufferSize, setClientId, setDefaultPartitions, setDefaultTopic, setFetchMetadataTimeout, setMaxWait, setMinBytes, setSocketTimeout
public static final org.springframework.integration.kafka.core.ZookeeperConfiguration.BrokerToBrokerAddressFunction brokerToBrokerAddressFunction
public ZookeeperConfiguration(java.lang.String zookeeperConnectionString)
public ZookeeperConfiguration(ZookeeperConnect zookeeperConnect)
protected java.util.List<BrokerAddress> doGetBrokerAddresses()
doGetBrokerAddresses
in class AbstractConfiguration