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

Class ApacheKafkaConsumerAdapterFactory

java.lang.Object

com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerAdapterFactory

All Implemented Interfaces:

PubSubConsumerAdapterFactory<PubSubConsumerAdapter>, Closeable, AutoCloseable

public class ApacheKafkaConsumerAdapterFactory
extends Object
implements PubSubConsumerAdapterFactory<PubSubConsumerAdapter>

Constructor Summary

Constructors

Constructor	Description
ApacheKafkaConsumerAdapterFactory()

Method Summary

Modifier and Type	Method	Description
void	close()
ApacheKafkaConsumerAdapter	create(VeniceProperties veniceProperties, boolean isKafkaConsumerOffsetCollectionEnabled, PubSubMessageDeserializer pubSubMessageDeserializer, String consumerName)
String	getName()

Methods inherited from class java.lang.Object

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

Constructor Details

ApacheKafkaConsumerAdapterFactory

public ApacheKafkaConsumerAdapterFactory()

Method Details

create

public ApacheKafkaConsumerAdapter create(VeniceProperties veniceProperties,
 boolean isKafkaConsumerOffsetCollectionEnabled,
 PubSubMessageDeserializer pubSubMessageDeserializer,
 String consumerName)

Specified by:

create in interface PubSubConsumerAdapterFactory<PubSubConsumerAdapter>

Parameters:

veniceProperties - A copy of venice properties. Relevant consumer configs will be extracted from veniceProperties using prefix matching. For example, to construct kafka consumer configs that start with "kafka." prefix will be used.

isKafkaConsumerOffsetCollectionEnabled - A flag to enable collection of offset or not.

pubSubMessageDeserializer - To deserialize the raw byte records into PubSubMessages to process.

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

Returns:

Returns an instance of a consumer adapter

getName

public String getName()

Specified by:

getName in interface PubSubConsumerAdapterFactory<PubSubConsumerAdapter>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException