K - the key type.V - the value type.public class DefaultKafkaConsumerFactory<K,V> extends java.lang.Object implements ConsumerFactory<K,V>, ClientIdSuffixAware<K,V>
ConsumerFactory implementation to produce a new Consumer instance
for provided Map configs and optional Deserializer keyDeserializer,
valueDeserializer implementations on each createConsumer()
invocation.| Constructor and Description |
|---|
DefaultKafkaConsumerFactory(java.util.Map<java.lang.String,java.lang.Object> configs) |
DefaultKafkaConsumerFactory(java.util.Map<java.lang.String,java.lang.Object> configs,
org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer,
org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.kafka.clients.consumer.Consumer<K,V> |
createConsumer() |
org.apache.kafka.clients.consumer.Consumer<K,V> |
createConsumer(java.lang.String clientIdSuffix)
Create a consumer, appending the suffix to the
client.id property,
if present. |
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
createKafkaConsumer() |
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
createKafkaConsumer(java.util.Map<java.lang.String,java.lang.Object> configs) |
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
createKafkaConsumer(java.lang.String clientIdSuffix) |
java.util.Map<java.lang.String,java.lang.Object> |
getConfigurationProperties()
Return an unmodifiable reference to the configuration map for this factory.
|
boolean |
isAutoCommit() |
void |
setKeyDeserializer(org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer) |
void |
setValueDeserializer(org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer) |
public DefaultKafkaConsumerFactory(java.util.Map<java.lang.String,java.lang.Object> configs)
public void setKeyDeserializer(org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer)
public void setValueDeserializer(org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)
public java.util.Map<java.lang.String,java.lang.Object> getConfigurationProperties()
public org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer()
createConsumer in interface ConsumerFactory<K,V>public org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(java.lang.String clientIdSuffix)
ClientIdSuffixAwareclient.id property,
if present.createConsumer in interface ClientIdSuffixAware<K,V>clientIdSuffix - the suffix.protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createKafkaConsumer()
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createKafkaConsumer(java.lang.String clientIdSuffix)
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createKafkaConsumer(java.util.Map<java.lang.String,java.lang.Object> configs)
public boolean isAutoCommit()
isAutoCommit in interface ConsumerFactory<K,V>