Package com.linkedin.davinci.kafka.consumer

Class KafkaConsumerServiceDelegator.CurrentVersionConsumerPoolStrategy

java.lang.Object

com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.ConsumerPoolStrategy

com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.CurrentVersionConsumerPoolStrategy

Enclosing class:

KafkaConsumerServiceDelegator

public class KafkaConsumerServiceDelegator.CurrentVersionConsumerPoolStrategy
extends KafkaConsumerServiceDelegator.ConsumerPoolStrategy

Field Summary

Fields inherited from class com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.ConsumerPoolStrategy

consumerServices

Constructor Summary

Constructors

Constructor	Description
CurrentVersionConsumerPoolStrategy()

Method Summary

Modifier and Type	Method	Description
KafkaConsumerService	delegateKafkaConsumerServiceFor(PartitionReplicaIngestionContext topicPartitionReplicaRole)
List<KafkaConsumerService>	getConsumerServices()

Methods inherited from class java.lang.Object

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

Constructor Details

CurrentVersionConsumerPoolStrategy

public CurrentVersionConsumerPoolStrategy()

Method Details

delegateKafkaConsumerServiceFor

public KafkaConsumerService delegateKafkaConsumerServiceFor(PartitionReplicaIngestionContext topicPartitionReplicaRole)

Specified by:

delegateKafkaConsumerServiceFor in class KafkaConsumerServiceDelegator.ConsumerPoolStrategy

getConsumerServices

public List<KafkaConsumerService> getConsumerServices()

Overrides:

getConsumerServices in class KafkaConsumerServiceDelegator.ConsumerPoolStrategy