org.springframework.integration.kafka.core
Class BrokerAddressListConfiguration

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

public class BrokerAddressListConfiguration
extends AbstractConfiguration

Kafka Configuration where the seed brokers are set up explicitly.


Constructor Summary
BrokerAddressListConfiguration(BrokerAddress... brokerAddresses)
           
 
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
 

Constructor Detail

BrokerAddressListConfiguration

public BrokerAddressListConfiguration(BrokerAddress... brokerAddresses)
Method Detail

doGetBrokerAddresses

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