Necesito guardar eventos sin procesar de mi servidor en un archivo de parquet para poder consultar los datos. ¿Hay una manera fácil de escribir parquet en s3 directamente desde kinesis usando scala/java?

Idealmente, me gustaría usar kinesis firehose para hacer el trabajo pesado.

alguna idea ?