Enum Constant and Description |
---|
BROKER_LIST
The option name for the broker list
|
CG
The option name indicating the name of the consumer group
|
CONFIG
The option name for extra producer configurations
|
CONSUME_RECORDS
The option name indicating the number of records to consume
|
CONSUME_TIMEOUT
The option name indicating the timeout value for the consumer
|
FROM_TOPIC
The option name indicating the name of the topic where the message will be consumed
|
HEADERS
The option name used to add Headers
|
MESSAGE
The option name for the message payload
|
OPERATION
The option name indicating the name of the operation to execute
|
PARTITION
The option name indicating the number of the topic partition
|
SHARDING_KEY
The option name used to add a sharding ket
|
TENANT_GROUP
The option name used to add a tenant group name
|
TO_TOPIC
The option name indicating the name of the topic
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getOptionName()
Gets and specific option name
|
static Options |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static Options[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final Options TO_TOPIC
public static final Options OPERATION
public static final Options BROKER_LIST
public static final Options MESSAGE
public static final Options CONFIG
public static final Options TENANT_GROUP
public static final Options SHARDING_KEY
public static final Options HEADERS
public static final Options FROM_TOPIC
public static final Options CONSUME_TIMEOUT
public static final Options CG
public static final Options CONSUME_RECORDS
public static final Options PARTITION
public static Options[] values()
for (Options c : Options.values()) System.out.println(c);
public static Options valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is nullpublic java.lang.String getOptionName()