Hi,
If Firehouse already supports sinking records from a Kinesis stream to an
S3 bucket, then yes, Chesnay's suggestion would work.
You route each record to a specific Kinesis stream depending on some value
in the record using the KinesisSerializationSchema, and sink each Kinesis
stream to their
I'll need someone else to chime in here for a definitive answer (cc'd
Gordon), so I'm really just guessing here.
For the partitioning it looks like you can use a custom partitioner, see
FlinkKinesisProducer#setCustomPartitioner.
Have you looked at the KinesisSerializationSchema described in the
