org.springframework.kafka.core

Interface ConsumerFactory<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Known Implementing Classes:

DefaultKafkaConsumerFactory

public interface ConsumerFactory<K,V>

The strategy to produce a Consumer instance(s).

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.consumer.Consumer<K,V>	createConsumer()
boolean	isAutoCommit()

Method Detail

createConsumer

org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer()

isAutoCommit

boolean isAutoCommit()