0

我正在尝试使用类似于https://github.com/aws-samples/amazon-kinesis-learning的 Kinesis 客户端库来使用 Kinesis 数据流。但在这个例子中,他们安排了这个过程。我想在没有调度程序的情况下使用传入的记录。

我不想使用 DynamoDB、cloudWatch。期望一个简单的消费者在流中消费记录

有没有办法在没有调度程序的情况下使用java处理记录

4

1 回答 1

0

KCL 使用 DynamoDB 管理分片租约和检查点——这种功能/依赖性对于 KCL 提供的功能至关重要。如果您不想要这些,我不确定您为什么要首先使用 KCL。您可以使用 Lambda 来使用您的流,或直接调用 API - 这里有一些示例代码 - https://docs.amazonaws.cn/en_us/streams/latest/dev/developing-consumers-with-sdk.html

于 2020-07-27T05:35:20.970 回答