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 Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<KafkaConsumerService>	consumerServices

Constructor Summary

Constructors

Constructor	Description
ConsumerPoolStrategy()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

consumerServices

protected final List<KafkaConsumerService> consumerServices

Constructor Details

ConsumerPoolStrategy

public ConsumerPoolStrategy()

Method Details

delegateKafkaConsumerServiceFor

protected abstract KafkaConsumerService delegateKafkaConsumerServiceFor(PartitionReplicaIngestionContext topicPartitionReplicaRole)

getConsumerServices

protected List<KafkaConsumerService> getConsumerServices()