Como KinesisMessageDrivenChannelAdaptero balanceamento entre múltiplas instâncias é tratado atualmente? Eu gostaria que os shards fossem distribuídos de forma um pouco mais uniforme quando eu girasse outra instância para escalonamento.
Encontrei este ticket mais antigo https://github.com/spring-projects/spring-integration-aws/issues/99 . Parece que não há rebalanceamento.
Obrigado pela sua contribuição!
Não há gerenciamento de grupo de consumidores no AWS Kinesis e isso não é fácil de implementar a partir deste
KinesisMessageDrivenChannelAdaptercliente. Precisaríamos de algum outro aplicativo independente para coordenar esse comportamento. Isso já está fora dospring-integration-awsescopo.Atualmente funciona assim: primeiro a entrar - primeiro a vencer. Então, de fato pode ser uma situação em que todos os seus shards são consumidos por uma única instância.