我正在开发一个应用程序,该应用程序使用(KCL)从AWS Kinesis读取和处理事件。我不希望事件生成器端受到延迟的影响,因此使用KinesisAsyncClient来发送事件。但是,为了使我的事件处理正常工作,我需要在我的生产者端以"order I called“的方式处理事件。此信息可作为每个Kinesis记录中的时间戳字段使用。除了切换到使用阻塞同步Kinesis之外,还有什么其他解决方案可以有效地对流事件进行排序吗
我正在接收Kinesis数据流中的cloudtrail日志。我正在调用一个流处理lambda函数,就像here描述的那样。然后将返回到流的最终结果存储到S3存储桶中。到目前为止,处理失败,并在S3存储桶中创建了以下错误文件: {"attemptsMade":4,"arrivalTimestamp":1619677225356,"errorCode":"Lambda.FunctionErrorStream Records
#log