Package com.linkedin.venice.pubsub

Class PubSubProducerAdapterFactory<ADAPTER extends PubSubProducerAdapter>

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

ApacheKafkaProducerAdapterFactory

public abstract class PubSubProducerAdapterFactory<ADAPTER extends PubSubProducerAdapter>
extends Object
implements Closeable

Generic factory interface for creating PubSub producers.

Concrete implementations should create and configure producers 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
PubSubProducerAdapterFactory()	Constructor for PubSubProducerAdapterFactory used mainly for reflective instantiation.

Method Summary

Modifier and Type	Method	Description
abstract ADAPTER	create(PubSubProducerAdapterContext context)	Creates a producer adapter using the provided context.
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

PubSubProducerAdapterFactory

public PubSubProducerAdapterFactory()

Constructor for PubSubProducerAdapterFactory used mainly for reflective instantiation.

Method Details

create

public abstract ADAPTER create(PubSubProducerAdapterContext context)

Creates a producer adapter using the provided context.

Parameters:

context - A context object that contains all the necessary information to create a producer adapter.

Returns:

Returns an instance of a producer adapter

getName

public abstract String getName()