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

Class ApacheKafkaAdminAdapterFactory

java.lang.Object

com.linkedin.venice.pubsub.PubSubAdminAdapterFactory<PubSubAdminAdapter>

com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapterFactory

All Implemented Interfaces:

Closeable, AutoCloseable

public class ApacheKafkaAdminAdapterFactory
extends PubSubAdminAdapterFactory<PubSubAdminAdapter>

Implementation of PubSubProducerAdapterFactory used to create Apache Kafka admin clients. A kafka based admin client created using this factory is for managing and inspecting topics, brokers, configurations and ACLs.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
PubSubAdminAdapter	create(PubSubAdminAdapterContext adminAdapterContext)	Creates a PubSub admin adapter.
String	getName()

Methods inherited from class java.lang.Object

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

Constructor Details

ApacheKafkaAdminAdapterFactory

public ApacheKafkaAdminAdapterFactory()

Constructor for ApacheKafkaAdminAdapterFactory used mainly for reflective instantiation.

Method Details

create

public PubSubAdminAdapter create(PubSubAdminAdapterContext adminAdapterContext)

Description copied from class: PubSubAdminAdapterFactory

Creates a PubSub admin adapter.

Specified by:

create in class PubSubAdminAdapterFactory<PubSubAdminAdapter>

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 String getName()

Specified by:

getName in class PubSubAdminAdapterFactory<PubSubAdminAdapter>

close

public void close()
           throws IOException

Throws:

IOException