org.axonframework.kafka.eventhandling.consumer

Interface ConsumerFactory<K,V>

All Known Implementing Classes:

DefaultConsumerFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface ConsumerFactory<K,V>

The strategy to produce a Consumer instance(s).

Since:

3.0

Author:

Nakul Mishra

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.consumer.Consumer<K,V>	createConsumer() Create a consumer with the settings supplied in configuration properties.

Method Detail

createConsumer

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

Create a consumer with the settings supplied in configuration properties.

Returns:

the consumer.