Package com.linkedin.davinci.kafka.consumer

Class KafkaConsumerServiceDelegator.AAOrWCLeaderConsumerPoolStrategy

java.lang.Object

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

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

com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.AAOrWCLeaderConsumerPoolStrategy

Enclosing class:

KafkaConsumerServiceDelegator

public class KafkaConsumerServiceDelegator.AAOrWCLeaderConsumerPoolStrategy
extends KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy

Field Summary

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

defaultConsumerService

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

consumerServices

Constructor Summary

Constructors

Constructor	Description
AAOrWCLeaderConsumerPoolStrategy()

Method Summary

Modifier and Type	Method	Description
KafkaConsumerService	delegateKafkaConsumerServiceFor(PartitionReplicaIngestionContext topicPartitionReplicaRole)

Methods inherited from class com.linkedin.davinci.kafka.consumer.KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy

getConsumerServices

Methods inherited from class java.lang.Object

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

Constructor Details

AAOrWCLeaderConsumerPoolStrategy

public AAOrWCLeaderConsumerPoolStrategy()

Method Details

delegateKafkaConsumerServiceFor

public KafkaConsumerService delegateKafkaConsumerServiceFor(PartitionReplicaIngestionContext topicPartitionReplicaRole)

Overrides:

delegateKafkaConsumerServiceFor in class KafkaConsumerServiceDelegator.DefaultConsumerPoolStrategy