net.researchgate.kafka.metamorph

Class PartitionConsumerFactory

java.lang.Object

net.researchgate.kafka.metamorph.PartitionConsumerFactory

public class PartitionConsumerFactory
extends java.lang.Object

Implementation-agnostic factory for new PartitionConsumer instance creation.

This factory returns implementation-specific provider which implements PartitionConsumerProvider interface.

Constructor Summary

Constructors

Constructor and Description
PartitionConsumerFactory()

Method Summary

Modifier and Type	Method and Description
PartitionConsumerProvider	getProvider() Get implementation-specific provider which is able to create PartitionConsumer

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionConsumerFactory

public PartitionConsumerFactory()

Method Detail

getProvider

public PartitionConsumerProvider getProvider()

Get implementation-specific provider which is able to create PartitionConsumer

Returns:

partition consumer provider