Package com.linkedin.venice.pubsub.adapter.kafka.consumer

Class ApacheKafkaConsumerAdapterFactory

java.lang.Object

com.linkedin.venice.pubsub.PubSubConsumerAdapterFactory<PubSubConsumerAdapter>

com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapterFactory

All Implemented Interfaces:

Closeable, AutoCloseable

public class ApacheKafkaConsumerAdapterFactory
extends PubSubConsumerAdapterFactory<PubSubConsumerAdapter>

Constructor Summary

Constructors

Constructor	Description
ApacheKafkaConsumerAdapterFactory()	Constructor for ApacheKafkaConsumerAdapterFactory used mainly for reflective instantiation.

Method Summary

Modifier and Type	Method	Description
void	close()
ApacheKafkaConsumerAdapter	create(PubSubConsumerAdapterContext context)	Creates a PubSub consumer adapter.
String	getName()

Methods inherited from class java.lang.Object

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

Constructor Details

ApacheKafkaConsumerAdapterFactory

public ApacheKafkaConsumerAdapterFactory()

Constructor for ApacheKafkaConsumerAdapterFactory used mainly for reflective instantiation.

Method Details

create

public ApacheKafkaConsumerAdapter create(PubSubConsumerAdapterContext context)

Description copied from class: PubSubConsumerAdapterFactory

Creates a PubSub consumer adapter.

Specified by:

create in class PubSubConsumerAdapterFactory<PubSubConsumerAdapter>

Parameters:

context - The context containing all dependencies and configurations required to create a consumer.

Returns:

An instance of the PubSub consumer adapter.

getName

public String getName()

Specified by:

getName in class PubSubConsumerAdapterFactory<PubSubConsumerAdapter>

close

public void close()
           throws IOException

Throws:

IOException