Spring 云流 - 支持使用 Kinesis 重新平衡消费者
Spring cloud stream - support for rebalancing consumers with Kinesis
spring 云流是否也支持类似 Kafka 的运动再平衡？最近有人提交了这个问题 https://github.com/spring-projects/spring-integration-aws/issues/99
谢谢
AWS Kinesis 中根本没有确切的、类似 Kafka 的行为。在 Kafka 中，再平衡是在代理端执行的，所有消费者都会收到关于他们自己的分配的通知。
我们目前在 KinesisMessageDrivenChannelAdapter 中进行的是分片消费者之间的某种领导人选举。但是当新消费者加入组时，自动重新平衡的解决方案还不完整。
Kinesis Client Library 中有自动重新平衡之类的功能，并且已经有了 KclMessageDrivenChannelAdapter，但从 Spring Integration AWS 的角度来看，它还没有准备好发布。
spring 云流是否也支持类似 Kafka 的运动再平衡？最近有人提交了这个问题 https://github.com/spring-projects/spring-integration-aws/issues/99
谢谢
AWS Kinesis 中根本没有确切的、类似 Kafka 的行为。在 Kafka 中，再平衡是在代理端执行的，所有消费者都会收到关于他们自己的分配的通知。
我们目前在 KinesisMessageDrivenChannelAdapter 中进行的是分片消费者之间的某种领导人选举。但是当新消费者加入组时，自动重新平衡的解决方案还不完整。
Kinesis Client Library 中有自动重新平衡之类的功能，并且已经有了 KclMessageDrivenChannelAdapter，但从 Spring Integration AWS 的角度来看，它还没有准备好发布。