Static

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

Properties

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