org.springframework.integration.kafka.core
Class ZookeeperConfiguration

java.lang.Object
  extended by org.springframework.integration.kafka.core.AbstractConfiguration
      extended by org.springframework.integration.kafka.core.ZookeeperConfiguration
All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean, Configuration

public class ZookeeperConfiguration
extends AbstractConfiguration

Kafka Configuration that uses a ZooKeeper connection for retrieving the list of seed brokers.


Field Summary
static org.springframework.integration.kafka.core.ZookeeperConfiguration.BrokerToBrokerAddressFunction brokerToBrokerAddressFunction
           
 
Constructor Summary
ZookeeperConfiguration(java.lang.String zookeeperConnectionString)
           
ZookeeperConfiguration(ZookeeperConnect zookeeperConnect)
           
 
Method Summary
protected  java.util.List<BrokerAddress> doGetBrokerAddresses()
           
 
Methods inherited from class org.springframework.integration.kafka.core.AbstractConfiguration
afterPropertiesSet, getBrokerAddresses, getBufferSize, getClientId, getDefaultPartitions, getDefaultTopic, getFetchMetadataTimeout, getMaxWait, getMinBytes, getSocketTimeout, setBufferSize, setClientId, setDefaultPartitions, setDefaultTopic, setFetchMetadataTimeout, setMaxWait, setMinBytes, setSocketTimeout
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

brokerToBrokerAddressFunction

public static final org.springframework.integration.kafka.core.ZookeeperConfiguration.BrokerToBrokerAddressFunction brokerToBrokerAddressFunction
Constructor Detail

ZookeeperConfiguration

public ZookeeperConfiguration(java.lang.String zookeeperConnectionString)

ZookeeperConfiguration

public ZookeeperConfiguration(ZookeeperConnect zookeeperConnect)
Method Detail

doGetBrokerAddresses

protected java.util.List<BrokerAddress> doGetBrokerAddresses()
Specified by:
doGetBrokerAddresses in class AbstractConfiguration