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

Class ApacheKafkaProducerAdapterFactory

java.lang.Object

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

All Implemented Interfaces:

PubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>, Closeable, AutoCloseable

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

Method Summary

Modifier and Type	Method	Description
void	close()
ApacheKafkaProducerAdapter	create(VeniceProperties veniceProperties, String producerName, String brokerAddressToOverride)
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()

Method Details

create

public ApacheKafkaProducerAdapter create(VeniceProperties veniceProperties,
 String producerName,
 String brokerAddressToOverride)

Specified by:

create in interface PubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>

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.

producerName - Name of the producer. If not null, it will be used to set the context for producer thread.

brokerAddressToOverride - Broker address to use when creating a producer. If this value is null, local broker address present in veniceProperties will be used.

Returns:

Returns an instance of a producer adapter

getName

public String getName()

Specified by:

getName in interface PubSubProducerAdapterFactory<ApacheKafkaProducerAdapter>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable