|
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()
Configuration
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.
getMinBytes
in interface Configuration
public 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()
Configuration
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.
getMaxWait
in interface Configuration
public java.lang.String getClientId()
Configuration
getClientId
in interface Configuration
public void setClientId(java.lang.String clientId)
clientId
- the client namepublic int getBufferSize()
Configuration
getBufferSize
in interface Configuration
public void setBufferSize(int bufferSize)
bufferSize
- the buffer sizepublic int getSocketTimeout()
Configuration
getSocketTimeout
in interface Configuration
public void setSocketTimeout(int socketTimeout)
socketTimeout
- the socket timeoutpublic void setFetchMetadataTimeout(int fetchMetadataTimeout)
fetchMetadataTimeout
- timeoutpublic int getFetchMetadataTimeout()
Configuration
getFetchMetadataTimeout
in interface Configuration
public final java.util.List<BrokerAddress> getBrokerAddresses()
Configuration
getBrokerAddresses
in interface Configuration
public java.util.List<Partition> getDefaultPartitions()
Configuration
getDefaultPartitions
in interface Configuration
public void setDefaultPartitions(java.util.List<Partition> defaultPartitions)
public java.lang.String getDefaultTopic()
Configuration
getDefaultTopic
in interface Configuration
public void setDefaultTopic(java.lang.String defaultTopic)
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
protected 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 |