java - 我可以使用 Amazon Kinesis 连接器将流发送到两个目的地（两个发射器）吗？

Question

使用 Amazon Kinesis 连接器库，是否可以配置两个发射器？例如，我想从流中过滤和转换记录，然后使用 Redshift 发射器将结果存储在 Redshift 中，同时还将过滤和转换的记录发送到新的 Kinesis 流。

IKinesisConnectorPipeline 接口似乎只为单个发射器设计，但我会假设许多用户正在使用单个流执行多项操作，所以我想知道执行此操作的标准方法是什么。

Answer 1

每个管道/发射器只能有一个 Kinesis 应用程序（即消费者）。

它使添加新处理器变得简单，并且它们每个都有自己的检查点。