org.axonframework.kafka.eventhandling.consumer

Class DefaultConsumerFactory<K,V>

java.lang.Object

org.axonframework.kafka.eventhandling.consumer.DefaultConsumerFactory<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

ConsumerFactory<K,V>

public class DefaultConsumerFactory<K,V>
extends Object
implements ConsumerFactory<K,V>

The ConsumerFactory implementation to produce a new Consumer instance. On each invocation of createConsumer() it will create a new instance based on properties supplied via configs

Author:

Nakul Mishra

Constructor Summary

Constructors

Constructor and Description
DefaultConsumerFactory(Map<String,Object> configs)

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultConsumerFactory

public DefaultConsumerFactory(Map<String,Object> configs)

Method Detail

createConsumer

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

Description copied from interface: ConsumerFactory

Create a consumer with the settings supplied in configuration properties.

Specified by:

createConsumer in interface ConsumerFactory<K,V>

Returns:

the consumer.