Package com.linkedin.venice.beam.consumer

Interface VeniceChangelogConsumerProvider<K,V>

All Superinterfaces:

Serializable

All Known Implementing Classes:

LocalVeniceChangelogConsumerProvider

public interface VeniceChangelogConsumerProvider<K,V>
extends Serializable

Interface to provide a configured VeniceChangelogConsumer instance.

Method Summary

Modifier and Type	Method	Description
VeniceChangelogConsumer<K,V>	getVeniceChangelogConsumer(String storeName)
VeniceChangelogConsumer<K,V>	getVeniceChangelogConsumer(String storeName, String consumerId)

Method Details

getVeniceChangelogConsumer

VeniceChangelogConsumer<K,V> getVeniceChangelogConsumer(String storeName)
                                                 throws NoSuchMethodException,
InvocationTargetException,
InstantiationException,
IllegalAccessException

Throws:

NoSuchMethodException

InvocationTargetException

InstantiationException

IllegalAccessException

getVeniceChangelogConsumer

VeniceChangelogConsumer<K,V> getVeniceChangelogConsumer(String storeName,
 String consumerId)
                                                 throws NoSuchMethodException,
InvocationTargetException,
InstantiationException,
IllegalAccessException

Throws:

NoSuchMethodException

InvocationTargetException

InstantiationException

IllegalAccessException