K
- the key type.V
- the value type.public class DefaultKafkaConsumerFactory<K,V> extends java.lang.Object implements ConsumerFactory<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() |
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
createKafkaConsumer() |
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 org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer()
createConsumer
in interface ConsumerFactory<K,V>
protected org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createKafkaConsumer()
public boolean isAutoCommit()
isAutoCommit
in interface ConsumerFactory<K,V>