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.
 int getBufferSize()
          The buffer size for this client
 java.lang.String getClientId()
          The client name to be used throughout this connection.
 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.
 int getFetchMetadataTimeout()
          The timeout on fetching metadata (e.g.
 int getMaxWait()
          The maximum amount of time that a server fetch operation will wait before returning (unless minFetchSizeInBytes) are available.
 int getMinBytes()
          The minimum amount of data that a server fetch operation will wait for before returning, unless maxWait has elapsed.
 int getSocketTimeout()
          The socket timeout for this client
 

Method Detail

getMinBytes

int getMinBytes()
The minimum amount of data that a server fetch operation will wait for before returning, unless maxWait has elapsed. In conjunction with getMaxWait()}, controls latency and throughput. Smaller values increase responsiveness, but may increase the number of poll operations, potentially reducing throughput and increasing CPU consumption.

Returns:
the minimum amount of data for a fetch operation

getMaxWait

int getMaxWait()
The maximum amount of time that a server fetch operation will wait before returning (unless minFetchSizeInBytes) are available. In conjunction with AbstractConfiguration.setMinBytes(int), controls latency and throughput. Smaller intervals increase responsiveness, but may increase the number of poll operations, potentially increasing CPU consumption and reducing throughput.

Returns:
the maximum wait time for a fetch operation

getClientId

java.lang.String getClientId()
The client name to be used throughout this connection.

Returns:
the client id for a connection

getBufferSize

int getBufferSize()
The buffer size for this client

Returns:
the buffer size

getSocketTimeout

int getSocketTimeout()
The socket timeout for this client

Returns:
the socket timeout

getFetchMetadataTimeout

int getFetchMetadataTimeout()
The timeout on fetching metadata (e.g. partition leaders)

Returns:
the fetch metadata timeout

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