Package com.linkedin.davinci.consumer

Class VeniceChangelogConsumerClientFactory

java.lang.Object

com.linkedin.davinci.consumer.VeniceChangelogConsumerClientFactory

public class VeniceChangelogConsumerClientFactory
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	VeniceChangelogConsumerClientFactory.ViewClassGetter

Field Summary

Fields

Modifier and Type	Field	Description
protected VeniceChangelogConsumerClientFactory.ViewClassGetter	viewClassGetter

Constructor Summary

Constructors

Constructor	Description
VeniceChangelogConsumerClientFactory(ChangelogClientConfig globalChangelogClientConfig, io.tehuti.metrics.MetricsRepository metricsRepository)

Method Summary

Modifier and Type	Method	Description
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName)
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName, String consumerId)
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName, String consumerId, Class<K> keyClass, Class<V> valueClass, org.apache.avro.Schema valueSchema)	Use this if you're using the experimental client
<K, V> BootstrappingVeniceChangelogConsumer<K,V>	getBootstrappingChangelogConsumer(String storeName, String consumerId, Class<V> valueClass)	Creates a BootstrappingVeniceChangelogConsumer with consumer id.
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName)	Default method to create a VeniceChangelogConsumer given a storeName.
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName, String consumerId)
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName, String consumerId, Class<V> valueClass)	Creates a VeniceChangelogConsumer with consumer id.
<K, V> VeniceChangelogConsumer<K,V>	getChangelogConsumer(String storeName, String consumerId, Class<V> valueClass, String viewNameOverride)
protected static PubSubConsumerAdapter	getPubSubConsumer(ChangelogClientConfig changelogClientConfig, String consumerName)
protected void	setConsumer(PubSubConsumerAdapter consumer)
protected void	setD2ControllerClient(D2ControllerClient d2ControllerClient)
protected void	setViewClassGetter(VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter)

Methods inherited from class java.lang.Object

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

Field Details

viewClassGetter

protected VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter

Constructor Details

VeniceChangelogConsumerClientFactory

public VeniceChangelogConsumerClientFactory(ChangelogClientConfig globalChangelogClientConfig,
 io.tehuti.metrics.MetricsRepository metricsRepository)

Method Details

setD2ControllerClient

protected void setD2ControllerClient(D2ControllerClient d2ControllerClient)

setConsumer

protected void setConsumer(PubSubConsumerAdapter consumer)

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName)

Default method to create a VeniceChangelogConsumer given a storeName.

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName,
 String consumerId)

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName,
 String consumerId,
 Class<V> valueClass)

Creates a VeniceChangelogConsumer with consumer id. This is used to create multiple consumers so that each consumer can only subscribe to certain partitions. Multiple such consumers can work in parallel.

getChangelogConsumer

public <K,
V> VeniceChangelogConsumer<K,V> getChangelogConsumer(String storeName,
 String consumerId,
 Class<V> valueClass,
 String viewNameOverride)

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName)

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName,
 String consumerId,
 Class<K> keyClass,
 Class<V> valueClass,
 org.apache.avro.Schema valueSchema)

Use this if you're using the experimental client

Parameters:

keyClass - The SpecificRecord class for your key

valueClass - The SpecificRecord class for your value

valueSchema - The Schema for your values

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName,
 String consumerId,
 Class<V> valueClass)

Creates a BootstrappingVeniceChangelogConsumer with consumer id. This is used to create multiple consumers so that each consumer can only subscribe to certain partitions.

getBootstrappingChangelogConsumer

public <K,
V>
BootstrappingVeniceChangelogConsumer<K,V> getBootstrappingChangelogConsumer(String storeName,
 String consumerId)

getPubSubConsumer

protected static PubSubConsumerAdapter getPubSubConsumer(ChangelogClientConfig changelogClientConfig,
 String consumerName)

setViewClassGetter

protected void setViewClassGetter(VeniceChangelogConsumerClientFactory.ViewClassGetter viewClassGetter)