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

Class ApacheKafkaAdminAdapterFactory

java.lang.Object

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

All Implemented Interfaces:

PubSubAdminAdapterFactory<PubSubAdminAdapter>, Closeable, AutoCloseable

public class ApacheKafkaAdminAdapterFactory
extends Object
implements 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()

Method Summary

Modifier and Type	Method	Description
void	close()
PubSubAdminAdapter	create(VeniceProperties veniceProperties, PubSubTopicRepository pubSubTopicRepository)
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()

Method Details

create

public PubSubAdminAdapter create(VeniceProperties veniceProperties,
 PubSubTopicRepository pubSubTopicRepository)

Specified by:

create in interface PubSubAdminAdapterFactory<PubSubAdminAdapter>

Parameters:

veniceProperties - A copy of venice properties. Relevant producer configs will be extracted from veniceProperties using prefix matching. For example, to construct kafka producer configs that start with "kafka." prefix will be used.

pubSubTopicRepository - A repo to cache created PubSubTopics.

Returns:

Returns an instance of an admin adapter

getName

public String getName()

Specified by:

getName in interface PubSubAdminAdapterFactory<PubSubAdminAdapter>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException