For anyone interested on the same while waiting for KMS support, just place the class on your own project *org.apache.beam.sdk.util.GcsUtil *
Look / modify the *enqueCopy *method and replace the *storageClient.objects().copy(....) *with a *storageClient.objects().rewrite(....) , add the corresponding callback *and it should works as expected. Cheers! On Wed, Feb 20, 2019 at 11:11 AM Juan Carlos Garcia <jcgarc...@gmail.com> wrote: > Hi Folks, > > Is there any discussion going on regarding the support to writes to GCP > bucket protected with KMS ? > > Thanks and regards, > -- > > JC > > -- JC
