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 on each createConsumer()
invocation.| Constructor and Description |
|---|
DefaultKafkaConsumerFactory(java.util.Map<java.lang.String,java.lang.Object> configs) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.kafka.clients.consumer.Consumer<K,V> |
createConsumer() |
boolean |
isAutoCommit() |
public DefaultKafkaConsumerFactory(java.util.Map<java.lang.String,java.lang.Object> configs)
public org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer()
createConsumer in interface ConsumerFactory<K,V>public boolean isAutoCommit()
isAutoCommit in interface ConsumerFactory<K,V>