Class ApacheKafkaProducerAdapterFactory
java.lang.Object
com.linkedin.venice.pubsub.PubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>
com.linkedin.venice.pubsub.adapter.kafka.producer.ApacheKafkaProducerAdapterFactory
- All Implemented Interfaces:
Closeable
,AutoCloseable
public class ApacheKafkaProducerAdapterFactory
extends PubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>
Implementation of
PubSubProducerAdapterFactory
used to create Apache Kafka producers.
A producer created using this factory is usually used to send data to a single pub-sub topic.-
Constructor Summary
ConstructorsConstructorDescriptionConstructor for ApacheKafkaProducerAdapterFactory used for reflective instantiation. -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
create
(PubSubProducerAdapterContext context) Creates a producer adapter using the provided context.getName()
-
Constructor Details
-
ApacheKafkaProducerAdapterFactory
public ApacheKafkaProducerAdapterFactory()Constructor for ApacheKafkaProducerAdapterFactory used for reflective instantiation.
-
-
Method Details
-
create
Description copied from class:PubSubProducerAdapterFactory
Creates a producer adapter using the provided context.- Specified by:
create
in classPubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>
- Parameters:
context
- A context object that contains all the necessary information to create a producer adapter.- Returns:
- Returns an instance of a producer adapter
-
getName
- Specified by:
getName
in classPubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>
-
close
public void close()
-