DataflowEndpointKafkaBatchingArgsBuilder

Functions

@JvmName(name = "bdubvbdhtojqvpwb")

suspend fun latencyMs(value: Output<Int>)

@JvmName(name = "kgymcmjxeyijhgdx")

suspend fun latencyMs(value: Int?)

@JvmName(name = "ndbunxjsbmtnkuao")

suspend fun maxBytes(value: Output<Int>)

@JvmName(name = "wbannlgdwmumsdgd")

suspend fun maxBytes(value: Int?)

@JvmName(name = "fblvdsexckbxoxfi")

suspend fun maxMessages(value: Output<Int>)

@JvmName(name = "vtkaeiegehmxhase")

suspend fun maxMessages(value: Int?)

@JvmName(name = "umgodfihxflybkwf")

@JvmName(name = "eeutvipauongkxah")

suspend fun mode(value: Either<String, OperationalMode>?)

@JvmName(name = "jeynkumwoanhqbrt")

suspend fun mode(value: Output<Either<String, OperationalMode>>)

@JvmName(name = "fscmqdwivhheeagc")

fun mode(value: String)