Package com.linkedin.venice.pubsub

Class PubSubAdminAdapterFactory<ADAPTER extends PubSubAdminAdapter>

java.lang.Object
com.linkedin.venice.pubsub.PubSubAdminAdapterFactory<ADAPTER>
All Implemented Interfaces:
Closeable, AutoCloseable
Direct Known Subclasses:
ApacheKafkaAdminAdapterFactory
public abstract class PubSubAdminAdapterFactory<ADAPTER extends PubSubAdminAdapter> extends Object implements Closeable
Generic factory interface for creating PubSub system-specific admin instances.

Concrete implementations of this interface are expected to provide the logic for creating and instantiating admin components tailored to a specific PubSub system (e.g., Kafka, Pulsar).

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

  • Constructor Details

    • PubSubAdminAdapterFactory

      public PubSubAdminAdapterFactory()
      Constructor for PubSubAdminAdapterFactory used mainly for reflective instantiation.

  • Method Details

    • create

      public abstract ADAPTER create(PubSubAdminAdapterContext adminAdapterContext)
      Creates a PubSub admin adapter.
      Parameters:
      adminAdapterContext - The context containing all dependencies and configurations required to create an admin adapter.
      Returns:
      An instance of the PubSub admin adapter.

    • getName

      public abstract String getName()