Spark流-Kinesis-接收者数量和碎片之间的相关性
我们在火花中消耗了运动学流，并且流中有多个碎片。...
Kinesis的春季项目反应堆
我有一个微服务，它消耗Kinesis流中的数据，由于应用...
我可以将一个租用表用于多个KCL应用程序吗？
我们正在基于Kinesis / DynamoDB流构建服务，我们有...
如何在spring-cloud-stream-binder-kinesis中使用STSAssumeRoleSessionCredentialsProvider进行配置
我正在使用spring-cloud-stream-binder-kinesis，版...
在Kinesis，KCL中流中的最新位置如何工作？
我们正在基于Kinesis / DynamoDB流构建服务，并且关...
如何在不通过Kinesis Data Stream的情况下直接将KPLKinesis Producer Library集成到Kinesis firehose
我使用KPL开发了Java应用程序以将数据写入Kinesis数...
Elasticsearch-Kinesis Firehose由于数据类型不匹配而无法将数据传送到Elasticsearch
我有一个Kinesis传递流设置，该设置从Kinesis数据流...
收到n个元素后如何退出Akka流？
我是Akka的新手，我只是想抓住它。 作为一个实验，我...
Kinesis DStreams上的窗口与Pyspark中的结构流数据帧
我正在编写一个Spark Streaming应用程序，该程序从K...
Streams和Firehose的用例是什么？
我正在开发一个将读取和分析付款交易日志的应用程序...
当我们在运行时增加碎片时，Kinesis如何保证消息顺序？
我是Kinesis的新手，当我阅读Kinesis文档时，我意识...
Spring Cloud Kinesis Binder使用者组设置以避免重复记录的处理
我正在使用Spring Cloud Kinesis活页夹，在使用消费...
当Kinesis使用者运行并在本地环境上显示错误“无法对不存在的表执行操作”时，找不到DynamoDB表
我创建了一个在主要功能中运行的运动产生器，该函数...
Kinesis使用者异步检查点
我有一个基于KCL（2.x）的使用者，它以异步方式处理...