Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class AbstractConfiguration

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

public abstract class AbstractConfiguration
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean, Configuration

Default implementation of a Configuration, storing the default topic and partitions explicitly. Implementors must provide a strategy for retrieving the seed brokers.

Author:
Marius Bogoevici

Constructor Summary
AbstractConfiguration()
           
 
Method Summary
 void afterPropertiesSet()
           
protected abstract  java.util.List<BrokerAddress> doGetBrokerAddresses()
           
 java.util.List<BrokerAddress> getBrokerAddresses()
          The list of seed broker addresses used by this Configuration.
 java.util.List<Partition> getDefaultPartitions()
          A list of default partitions to perform operations on.
 java.lang.String getDefaultTopic()
          A default topic to perform operations on.
 void setDefaultPartitions(java.util.List<Partition> defaultPartitions)
           
 void setDefaultTopic(java.lang.String defaultTopic)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AbstractConfiguration

public AbstractConfiguration()
Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception
Specified by:
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
Throws:
java.lang.Exception

getBrokerAddresses

public final java.util.List<BrokerAddress> getBrokerAddresses()
Description copied from interface: Configuration
The list of seed broker addresses used by this Configuration.

Specified by:
getBrokerAddresses in interface Configuration
Returns:
the broker addresses

doGetBrokerAddresses

protected abstract java.util.List<BrokerAddress> doGetBrokerAddresses()

getDefaultPartitions

public java.util.List<Partition> getDefaultPartitions()
Description copied from interface: Configuration
A list of default partitions to perform operations on.

Specified by:
getDefaultPartitions in interface Configuration
Returns:
the list of partitions

setDefaultPartitions

public void setDefaultPartitions(java.util.List<Partition> defaultPartitions)

getDefaultTopic

public java.lang.String getDefaultTopic()
Description copied from interface: Configuration
A default topic to perform operations on.

Specified by:
getDefaultTopic in interface Configuration
Returns:
a topic name

setDefaultTopic

public void setDefaultTopic(java.lang.String defaultTopic)

Spring Integration Kafka Support