Package com.linkedin.davinci.kafka.consumer

Enum KafkaConsumerService.ConsumerAssignmentStrategy

java.lang.Object

java.lang.Enum<KafkaConsumerService.ConsumerAssignmentStrategy>

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

All Implemented Interfaces:

java.io.Serializable, java.lang.Comparable<KafkaConsumerService.ConsumerAssignmentStrategy>

Enclosing class:

KafkaConsumerService

public static enum KafkaConsumerService.ConsumerAssignmentStrategy
extends java.lang.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.

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(java.lang.String name)	Returns the enum constant of this type with the specified name.
static KafkaConsumerService.ConsumerAssignmentStrategy[]	values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

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

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

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 Detail

values

public static KafkaConsumerService.ConsumerAssignmentStrategy[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (KafkaConsumerService.ConsumerAssignmentStrategy c : KafkaConsumerService.ConsumerAssignmentStrategy.values())
    System.out.println(c);

Returns:

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

valueOf

public static KafkaConsumerService.ConsumerAssignmentStrategy valueOf(java.lang.String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (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:

java.lang.IllegalArgumentException - if this enum type has no constant with the specified name

java.lang.NullPointerException - if the argument is null