I have a kinesis streamer with EventBridge as the Producer and Firehose Data as the consumer. Firehose converts the event json in a parquet file, which can be queried in an athena table.