Package com.linkedin.davinci.kafka.consumer

Enum Class KafkaConsumerService.ConsumerAssignmentStrategy

java.lang.Object

java.lang.Enum<KafkaConsumerService.ConsumerAssignmentStrategy>

com.linkedin.davinci.kafka.consumer.KafkaConsumerService.ConsumerAssignmentStrategy

All Implemented Interfaces:

Serializable, Comparable<KafkaConsumerService.ConsumerAssignmentStrategy>, Constable

Enclosing class:

KafkaConsumerService

public static enum KafkaConsumerService.ConsumerAssignmentStrategy
extends Enum<KafkaConsumerService.ConsumerAssignmentStrategy>

This consumer assignment strategy specify how consumers from consumer pool are allocated. Now we support two basic strategies with topic-wise and partition-wise for supporting consumer shared in topic and topic-partition granularity, respectively. Each strategy will have a specific extension of KafkaConsumerService.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Enum

Enum.EnumDesc<E extends Enum<E>>

Enum Constant Summary

Enum Constants

Enum Constant	Description
PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY
STORE_AWARE_PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY
TOPIC_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY

Method Summary

Modifier and Type	Method	Description
static KafkaConsumerService.ConsumerAssignmentStrategy	valueOf(String name)	Returns the enum constant of this class with the specified name.
static KafkaConsumerService.ConsumerAssignmentStrategy[]	values()	Returns an array containing the constants of this enum class, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, describeConstable, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Details

TOPIC_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY

public static final KafkaConsumerService.ConsumerAssignmentStrategy TOPIC_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY

PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY

public static final KafkaConsumerService.ConsumerAssignmentStrategy PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY

STORE_AWARE_PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY

public static final KafkaConsumerService.ConsumerAssignmentStrategy STORE_AWARE_PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY

Method Details

values

public static KafkaConsumerService.ConsumerAssignmentStrategy[] values()

Returns an array containing the constants of this enum class, in the order they are declared.

Returns:

an array containing the constants of this enum class, in the order they are declared

valueOf

public static KafkaConsumerService.ConsumerAssignmentStrategy valueOf(String name)

Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum class has no constant with the specified name

NullPointerException - if the argument is null