Package com.linkedin.davinci.kafka.consumer

Class KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy

java.lang.Object

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

com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy

Enclosing class:

KafkaConsumerServiceDelegator

public class KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy
extends KafkaConsumerServiceDelegator.ConsumerPoolStrategy

Field Summary

Fields

Modifier and Type	Field	Description
protected final KafkaConsumerService	defaultConsumerService

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

consumerServices

Constructor Summary

Constructors

Constructor	Description
DefaultConsumerPoolStrategy()

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

Field Details

defaultConsumerService

protected final KafkaConsumerService defaultConsumerService

Constructor Details

DefaultConsumerPoolStrategy

public DefaultConsumerPoolStrategy()

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