Package com.linkedin.davinci.kafka.consumer

Class KafkaConsumerServiceDelegator.ConsumerPoolStrategy

java.lang.Object

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

Direct Known Subclasses:

KafkaConsumerServiceDelegator.CurrentVersionConsumerPoolStrategy, KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy

Enclosing class:

KafkaConsumerServiceDelegator

public abstract class KafkaConsumerServiceDelegator.ConsumerPoolStrategy
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.List<KafkaConsumerService>	consumerServices

Constructor Summary

Constructors

Constructor	Description
ConsumerPoolStrategy()

Method Summary

Modifier and Type	Method	Description
protected abstract KafkaConsumerService	delegateKafkaConsumerServiceFor(PartitionReplicaIngestionContext topicPartitionReplicaRole)
protected java.util.List<KafkaConsumerService>	getConsumerServices()

Methods inherited from class java.lang.Object

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

Field Detail

consumerServices

protected final java.util.List<KafkaConsumerService> consumerServices

Constructor Detail

ConsumerPoolStrategy

public ConsumerPoolStrategy()

Method Detail

delegateKafkaConsumerServiceFor

protected abstract KafkaConsumerService delegateKafkaConsumerServiceFor(PartitionReplicaIngestionContext topicPartitionReplicaRole)

getConsumerServices

protected java.util.List<KafkaConsumerService> getConsumerServices()