KDA（Flink）到S3

【以下的问题经过翻译处理】 一位客户正在构建一种流式解决方案，用于处理客户发送的消息。流中的数据来自多个客户 - 每个流中的JSON都有一个customerId，告诉你最初是哪个客户发送了数据。

他们想将这些数据存储在S3上，但是按customerId进行分区。我们可以使用多个Firehose（每个customerId一个）来实现这一点。在Flink中是否可以实现这一点 - 使用Flink从Kinesis流中提取并将数据发送到S3中基于customerId的多个目的地，我推测这是可能实现的 - 但我不确认是否容易，并且能否使用一些现有的库来解决？

谢谢。