DataFlowEndpointKafkaBatchingArgs

data class DataFlowEndpointKafkaBatchingArgs(val latencyMs: Output<Int>? = null, val maxBytes: Output<Int>? = null, val maxMessages: Output<Int>? = null, val mode: Output<Either<String, OperationalMode>>? = null) : ConvertibleToJava<DataFlowEndpointKafkaBatchingArgs>

Kafka endpoint Batching properties

Constructors

Link copied to clipboard
constructor(latencyMs: Output<Int>? = null, maxBytes: Output<Int>? = null, maxMessages: Output<Int>? = null, mode: Output<Either<String, OperationalMode>>? = null)

Properties

Link copied to clipboard
val latencyMs: Output<Int>? = null

Batching latency in milliseconds.

Link copied to clipboard
val maxBytes: Output<Int>? = null

Maximum number of bytes in a batch.

Link copied to clipboard
val maxMessages: Output<Int>? = null

Maximum number of messages in a batch.

Link copied to clipboard
val mode: Output<Either<String, OperationalMode>>? = null

Mode for batching.

Functions

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