Package com.linkedin.venice.pubsub

Class PubSubConsumerAdapterFactory<ADAPTER extends PubSubConsumerAdapter>

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ApacheKafkaConsumerAdapterFactory

public abstract class PubSubConsumerAdapterFactory<ADAPTER extends PubSubConsumerAdapter>
extends Object
implements Closeable

Generic factory interface for creating PubSub consumers.

Concrete implementations should create and configure consumers for a specific PubSub system (e.g., Kafka, Pulsar).

Implementations must provide a public no-arg constructor to support reflective instantiation.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
abstract ADAPTER	create(PubSubConsumerAdapterContext context)	Creates a PubSub consumer adapter.
abstract String	getName()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Details

PubSubConsumerAdapterFactory

public PubSubConsumerAdapterFactory()

Constructor for PubSubConsumerAdapterFactory used mainly for reflective instantiation.

Method Details

create

public abstract ADAPTER create(PubSubConsumerAdapterContext context)

Creates a PubSub consumer adapter.

Parameters:

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

Returns:

An instance of the PubSub consumer adapter.

getName

public abstract String getName()