DataflowEndpointKafkaPartitionStrategy

enum DataflowEndpointKafkaPartitionStrategy : Enum<DataflowEndpointKafkaPartitionStrategy> , ConvertibleToJava<DataflowEndpointKafkaPartitionStrategy>

Partition handling strategy. Can be default or static. No effect if the endpoint is used as a source.

Entries

Link copied to clipboard

Default: Assigns messages to random partitions, using a round-robin algorithm.

Link copied to clipboard

Static: Assigns messages to a fixed partition number that's derived from the instance ID of the dataflow.

Link copied to clipboard

TOPIC Option

Link copied to clipboard

PROPERTY Option

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard

Returns a representation of an immutable list of all enum entries, in the order they're declared.

Link copied to clipboard
val javaValue: DataflowEndpointKafkaPartitionStrategy
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open override fun toJava(): DataflowEndpointKafkaPartitionStrategy
Link copied to clipboard

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.)

Link copied to clipboard

Returns an array containing the constants of this enum type, in the order they're declared.