Package com.linkedin.venice.pubsub
Interface PubSubAdminAdapterFactory<ADAPTER extends PubSubAdminAdapter>
-
- All Superinterfaces:
java.lang.AutoCloseable
,java.io.Closeable
- All Known Implementing Classes:
ApacheKafkaAdminAdapterFactory
public interface PubSubAdminAdapterFactory<ADAPTER extends PubSubAdminAdapter> extends java.io.Closeable
Generic admin factory interface. A pus-sub specific concrete implementation of this interface should be provided to be able to create and instantiate admins for that system.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ADAPTER
create(VeniceProperties veniceProperties, PubSubTopicRepository pubSubTopicRepository)
java.lang.String
getName()
-
-
-
Method Detail
-
create
ADAPTER create(VeniceProperties veniceProperties, PubSubTopicRepository pubSubTopicRepository)
- 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 createdPubSubTopic
s.- Returns:
- Returns an instance of an admin adapter
-
getName
java.lang.String getName()
-
-