ApacheKafkaAdminAdapterFactory (venice API)

java.lang.Object
- com.linkedin.venice.pubsub.adapter.kafka.admin.ApacheKafkaAdminAdapterFactory

All Implemented Interfaces:

PubSubAdminAdapterFactory<PubSubAdminAdapter>, java.io.Closeable, java.lang.AutoCloseable
```
public class ApacheKafkaAdminAdapterFactory
extends java.lang.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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`PubSubAdminAdapter`	`create(VeniceProperties veniceProperties, PubSubTopicRepository pubSubTopicRepository)`
`java.lang.String`	`getName()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ApacheKafkaAdminAdapterFactory
```
public ApacheKafkaAdminAdapterFactory()
```
- Method Detail
  - 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 java.lang.String getName()
```
    Specified by:
    
    getName in interface PubSubAdminAdapterFactory<PubSubAdminAdapter>
  - close
```
public void close()
           throws java.io.IOException
```
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Throws:
    
    java.io.IOException