java - 如何使用 KCL 使用来自 Kinesis Data Streams 的记录

Question

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

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

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

标签： javaamazon-web-servicesamazon-kinesisamazon-kcl

Answer 1

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