В AWS Kinesis нет точного, похожего на Кафку поведения.В Kafka ребалансировка выполняется на стороне брокера, и все потребители получают уведомления о своих собственных назначениях.
То, что мы имеем в настоящее время на KinesisMessageDrivenChannelAdapter, - это своего рода выборы лидера между потребителями осколков.Но решение еще не полно с автоматической перебалансировкой, когда новый потребитель присоединяется к группе.
В Kinesis Client Library есть что-то вроде автоматического перебалансирования, и у него уже есть KclMessageDrivenChannelAdapter, но это не релизготов еще с точки зрения Spring Integration AWS.