Enum CloudPubSubSourceConnector.PartitionScheme (1.1.0)

public enum CloudPubSubSourceConnector.PartitionScheme extends Enum<CloudPubSubSourceConnector.PartitionScheme>

Defines the accepted values for the #KAFKA_PARTITION_SCHEME_CONFIG.

Static Fields

NameDescription
HASH_KEY
HASH_VALUE
KAFKA_PARTITIONER
ORDERING_KEY
ROUND_ROBIN

Static Methods

NameDescription
getEnum(String value)
valueOf(String name)
values()

Methods

NameDescription
toString()