compression

@JvmName(name = "slqsloqysglgkmjr")
suspend fun compression(value: Output<Either<String, DataflowEndpointKafkaCompression>>)
@JvmName(name = "uamwatagslnrksfq")
suspend fun compression(value: Either<String, DataflowEndpointKafkaCompression>?)
@JvmName(name = "ljrcgmpgeqjcdvmm")
fun compression(value: String)
@JvmName(name = "bbysrlbnadffkpuk")
fun compression(value: DataflowEndpointKafkaCompression)

Parameters

value

Compression. Can be none, gzip, lz4, or snappy. No effect if the endpoint is used as a source.