Package io.eventuate.messaging.kafka.basic.consumer

Class DefaultKafkaConsumerFactory

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.DefaultKafkaConsumerFactory

All Implemented Interfaces:

KafkaConsumerFactory

public class DefaultKafkaConsumerFactory
extends Object
implements KafkaConsumerFactory

Constructor Summary

Constructors

Constructor	Description
DefaultKafkaConsumerFactory()

Method Summary

Modifier and Type	Method	Description
KafkaMessageConsumer	makeConsumer(String subscriptionId, Properties consumerProperties)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultKafkaConsumerFactory

public DefaultKafkaConsumerFactory()

Method Details

makeConsumer

public KafkaMessageConsumer makeConsumer(String subscriptionId,
 Properties consumerProperties)

Specified by:

makeConsumer in interface KafkaConsumerFactory