compression

@JvmName(name = "wffspwxnusagkqvi")
suspend fun compression(value: Output<Either<String, DataflowEndpointKafkaCompression>>)
@JvmName(name = "bnngkqceduumsjqu")
suspend fun compression(value: Either<String, DataflowEndpointKafkaCompression>?)
@JvmName(name = "sjpjmkhjchiisniw")
fun compression(value: String)
@JvmName(name = "jahgbqumrvpyiyqy")
fun compression(value: DataflowEndpointKafkaCompression)

Parameters

value

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