标记有以下标签的问题： Amazon Kinesis Data Streams
内容语言: 中文 (简体)
Select up to 5 tags to filter
排序方式 最新
浏览下面列出的问题和回答，或者筛选和排序以缩小结果范围。
【以下的问题经过翻译处理】 Kinesis流中写入的数据记录的大小是否有上限？
【以下的问题经过翻译处理】 使用Kinesis增强型扇出时，可以订阅单独的分片。我想了解下当进行重新分片时，消费者会发生什么？
【以下的问题经过翻译处理】 我们计划使用IoT Core通过MQTT接收消息，其中负载将为二进制数据（更具体地说，是 protobuf格式）。将使用规则将数据转发到...
【以下的问题经过翻译处理】 我对最近宣布的Redshift...
【以下的问题经过翻译处理】 在EventBridge中，我有一个Event Bus和2个规则。在Kinesis中，我有一个Data Stream。
其中一个规则的目标是CloudWatch中的一个Log Group。第二个规则的目标是我在Kinesis中的Data Stream。这个规则有一个带有策略的角色，执行我Data Stream上需要的所有操作。
当我去我的Event...
【以下的问题经过翻译处理】 嗨，我正在实施的当前流水线涉及Kinesis Data Stream -> Kinesis Firehose -> S3，但是当将缓冲区间隔（S3和转换）设置为接近5分钟时，数据仍会快速出现在S3存储桶中。
为了我的目的，我需要将每5分钟的数据合并成一个大文件，推送到S3中，我认为Kinesis Firehose应该在从Kinesis Data Stream...
【以下的问题经过翻译处理】 我有一个 Fargate 容器在私有子网中运行，使用 KPL 写入我的 Kinesis 数据流。我没有任何延迟问题，但我的 NAT 网关费用非常高。通过在此处使用接口 VPC 端点而不是继续使用我当前的方式，我可以获得什么。我在考虑基于此 (<https://docs.aws.amazon.com/streams/latest/dev/vpc.html>)...
【以下的问题经过翻译处理】 我应该如何使用 KCL 处理 Java 中的实际记录？
我正在按照提供的指导 <https://docs.aws.amazon.com/streams/latest/dev/kcl2-standard-consumer-java-example.html>，我可以连接到数据流，我可以得到可用记录数，但是该示例未显示的是如何实际获取记录（Json...
【以下的问题经过翻译处理】 我们试图在生产者将数据发布到Kinesis数据流后，向EventBridge发送一个事件。然后，我们希望配置EventBridge API目标将事件发送到Salesforce并创建平台事件。
Kinesis -> EventBridge -> Rule + Bus + API目的地 -> Salesforce
1....
【以下的问题经过翻译处理】...