Spring Cloud Stream 消费币配置

问题描述 投票:0回答:1

根据here的讨论,@sobychacko 建议创建一个新问题,链接到该讨论。那么,有人可以回答该帖子中发布的最后一个问题吗?

但在这种情况下,我们讨论的是单个消费者应用程序。如果我们有多个消费者应用程序实例怎么办

例如,如果有 10 个最终用户消费者容器部署到 k8s pod,那么 40 个 Kinesis 分片将如何分布在这 10 个最终用户消费者容器中?哪些属性决定了分片的分布方式?而且,一旦将分片分配给最终用户消费者容器,我们如何确保最终用户消费者容器不会不断切换分片?

为了给这个讨论添加更多背景,我发布了另一个不同的,但我认为相关的,stackoverflow 帖子 .

spring-cloud-stream spring-cloud-stream-binder spring-cloud-stream-binder-kinesis
1个回答
0
投票

根据您的其他问题:Spring Cloud Stream binder for AWS Kinesis and issues with getShardIterator,听起来您使用的是非常旧版本的 Kinesis Binder。中间有很多变化,所以在当前版本中这些分片的分布很可能与之前的“全部为第一个消费者”不同。

很难帮助您,因为我们不再支持旧版本。

© www.soinside.com 2019 - 2024. All rights reserved.