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, setSocketTimeoutpublic 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