Spring Integration Kafka Support

org.springframework.integration.kafka.core
Interface Configuration

All Known Implementing Classes:
AbstractConfiguration, BrokerAddressListConfiguration, ZookeeperConfiguration

public interface Configuration

Used to configure a DefaultConnectionFactory. Provides a list of seed brokers.

Author:
Marius Bogoevici

Method Summary
 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.
 

Method Detail

getBrokerAddresses

java.util.List<BrokerAddress> getBrokerAddresses()
The list of seed broker addresses used by this Configuration.

Returns:
the broker addresses

getDefaultPartitions

java.util.List<Partition> getDefaultPartitions()
A list of default partitions to perform operations on.

Returns:
the list of partitions

getDefaultTopic

java.lang.String getDefaultTopic()
A default topic to perform operations on.

Returns:
a topic name

Spring Integration Kafka Support