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

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

Constructors

Constructor	Description
ApacheKafkaProducerAdapterFactory()	Constructor for ApacheKafkaProducerAdapterFactory used for reflective instantiation.

Method Summary

Modifier and Type	Method	Description
void	close()
ApacheKafkaProducerAdapter	create(PubSubProducerAdapterContext context)	Creates a producer adapter using the provided context.
String	getName()

Methods inherited from class java.lang.Object

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

Constructor Details

ApacheKafkaProducerAdapterFactory

public ApacheKafkaProducerAdapterFactory()

Constructor for ApacheKafkaProducerAdapterFactory used for reflective instantiation.

Method Details

create

public ApacheKafkaProducerAdapter create(PubSubProducerAdapterContext context)

Description copied from class: PubSubProducerAdapterFactory

Creates a producer adapter using the provided context.

Specified by:

create in class PubSubProducerAdapterFactory<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

public String getName()

Specified by:

getName in class PubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>

close

public void close()