Kinesis扇出

0

【以下的问题经过翻译处理】某位客户正在考虑使用Kinesis构建消息处理系统。这是一个相对低流量的系统（所以只需要一个分片），但低延迟（端到端不超过1秒）非常重要。目前，流中会有四个消费者。但是，预计未来会增加更多的消费者。

我们是否有关于将Kinesis流向多个消费者进行扇出的最佳实践指南？

Topics

Analytics Internet of Things (IoT)

Tags

Language

中文 (简体)

EXPERT

rePost Polyglot

asked 6 months ago27 views

1 Answer

Newest
Most votes
Most comments

Are these answers helpful? Upvote the correct answer to help the community benefit from your knowledge.

0

【以下的回答经过翻译处理】这是一个在 awslabs 上的项目，它使用 AWS Lambda 函数接收来自 Amazon Kinesis 流的消息，并将这些消息转移到另一个数据传输中。

https://github.com/awslabs/aws-lambda-fanout

EXPERT

rePost Polyglot

answered 6 months ago

Relevant content

怎样通过CloudFormation来给DocumentDB创建一些表和索引(how to create some table and index in DocumentDB by CloudFormation）
Accepted Answer
Dgk
asked 10 months ago
The AWS Lambda program sometimes fails to trigger, while other times it works correctly.
Accepted Answer
HaydenLuo
asked 7 months ago
sagemaker美国人口普查数据在中国宁夏区下载提示拒绝访问
LiuChuang
asked a year ago
多网络接口，多ip地址配置路由策略，从那个公网ip进入就从对应的ip出去。
rePost-User-8489725
asked a year ago
Why are my Kinesis Data Streams throttling?
AWS OFFICIALUpdated 2 months ago
How do I integrate Amazon Connect with Amazon Kinesis?
AWS OFFICIALUpdated a year ago
How can I troubleshoot Lambda Kinesis Firehose integration issues?
AWS OFFICIALUpdated a year ago
How do I add Amazon EC2 metadata when pushing logs to Kinesis using Kinesis Agent?
AWS OFFICIALUpdated 2 years ago
Amazon Kinesis Video Streams with WebRTC operation returned status code: 0x5600000f
EXPERT
golderic
published a year ago
Amazon Kinesis Video Streams with WebRTC operation returned status codes: 0x5a000003, 0x5a000005, 0x5a000012
EXPERT
golderic
published a year ago