|
Spring Integration Kafka Support | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.integration.kafka.core.AbstractConfiguration
public abstract class AbstractConfiguration
Default implementation of a Configuration, storing the default topic and partitions,
as well as connectivity parameters.
Implementors must provide a strategy for retrieving the seed brokers.
| 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. |
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 |
void |
setBufferSize(int bufferSize)
The buffer size for this client |
void |
setClientId(java.lang.String clientId)
A client name to be used throughout this connection. |
void |
setDefaultPartitions(java.util.List<Partition> defaultPartitions)
|
void |
setDefaultTopic(java.lang.String defaultTopic)
|
void |
setFetchMetadataTimeout(int fetchMetadataTimeout)
The timeout on fetching metadata (e.g. |
void |
setMaxWait(int maxWait)
The maximum amount of time that a server fetch operation will wait before returning (unless minFetchSizeInBytes) are available. |
void |
setMinBytes(int minBytes)
The minimum amount of data that a server fetch operation will wait for before returning, unless maxWait has elapsed. |
void |
setSocketTimeout(int socketTimeout)
The socket timeout for this client |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public AbstractConfiguration()
| Method Detail |
|---|
public void setMinBytes(int minBytes)
maxWait has elapsed.
In conjunction with Configuration.getMaxWait()}, controls latency
and throughput.
Smaller values increase responsiveness, but may increase the number of poll operations,
potentially reducing throughput and increasing CPU consumption.
minBytes - the amount of data to fetchpublic int getMinBytes()
ConfigurationmaxWait has elapsed.
In conjunction with Configuration.getMaxWait()}, controls latency
and throughput.
Smaller values increase responsiveness, but may increase the number of poll operations,
potentially reducing throughput and increasing CPU consumption.
getMinBytes in interface Configurationpublic void setMaxWait(int maxWait)
minFetchSizeInBytes) are available.
In conjunction with 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.
maxWait - timeout to waitpublic int getMaxWait()
ConfigurationminFetchSizeInBytes) are available.
In conjunction with 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.
getMaxWait in interface Configurationpublic java.lang.String getClientId()
Configuration
getClientId in interface Configurationpublic void setClientId(java.lang.String clientId)
clientId - the client namepublic int getBufferSize()
Configuration
getBufferSize in interface Configurationpublic void setBufferSize(int bufferSize)
bufferSize - the buffer sizepublic int getSocketTimeout()
Configuration
getSocketTimeout in interface Configurationpublic void setSocketTimeout(int socketTimeout)
socketTimeout - the socket timeoutpublic void setFetchMetadataTimeout(int fetchMetadataTimeout)
fetchMetadataTimeout - timeoutpublic int getFetchMetadataTimeout()
Configuration
getFetchMetadataTimeout in interface Configurationpublic final java.util.List<BrokerAddress> getBrokerAddresses()
Configuration
getBrokerAddresses in interface Configurationpublic java.util.List<Partition> getDefaultPartitions()
Configuration
getDefaultPartitions in interface Configurationpublic void setDefaultPartitions(java.util.List<Partition> defaultPartitions)
public java.lang.String getDefaultTopic()
Configuration
getDefaultTopic in interface Configurationpublic void setDefaultTopic(java.lang.String defaultTopic)
public void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exceptionprotected abstract java.util.List<BrokerAddress> doGetBrokerAddresses()
|
Spring Integration Kafka Support | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||