Spring Integration Kafka Support

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.

Author:
Marius Bogoevici

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

Spring Integration Kafka Support