Class VeniceChangelogConsumerClientFactory


  • public class VeniceChangelogConsumerClientFactory
    extends java.lang.Object
    • Constructor Detail

      • VeniceChangelogConsumerClientFactory

        public VeniceChangelogConsumerClientFactory​(ChangelogClientConfig globalChangelogClientConfig,
                                                    io.tehuti.metrics.MetricsRepository metricsRepository)
    • Method Detail

      • setD2ControllerClient

        protected void setD2ControllerClient​(D2ControllerClient d2ControllerClient)
      • getChangelogConsumer

        public <K,​V> VeniceChangelogConsumer<K,​V> getChangelogConsumer​(java.lang.String storeName,
                                                                                   java.lang.String consumerId)
      • getChangelogConsumer

        public <K,​V> VeniceChangelogConsumer<K,​V> getChangelogConsumer​(java.lang.String storeName,
                                                                                   java.lang.String consumerId,
                                                                                   java.lang.Class clazz)
        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.
      • getBootstrappingChangelogConsumer

        public <K,​V> BootstrappingVeniceChangelogConsumer<K,​V> getBootstrappingChangelogConsumer​(java.lang.String storeName,
                                                                                                             java.lang.String consumerId,
                                                                                                             java.lang.Class clazz)
        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​(java.lang.String storeName,
                                                                                                             java.lang.String consumerId)