compression

val compression: Output<Either<String, KafkaMessageCompressionType>>? = null