0

我正在使用 KinesisUtil 在 Spark 应用程序中使用 Kinesis 流。我正在使用的代码示例发出与 Kinesis Stream 上的分片数量一样多的“createStream”调用。

有没有办法让 KinesisUtil 连接到特定的分片？我正在实现一个需要特定 Spark 节点处理来自特定分片的事件的设计。

谢谢，兰吉特

4

0 回答 0