Static shard distribution does perform rebalacing when resharding happens on a kinsis stream

[lengyuewuhua]

When I set up a static shard distribution for more than 1 instances by specifying both instanceIndex and instanceCount for a kinesis with a on-deman model enabled, when resharding happened in that kinese, the rebalacing does not happen at KinesisMessageDrivenChannelAdapter, but got stoped. And for those new created shards, no instances consume messages from them.

Configuration as below -
For Server1 -
spring:
cloud:
stream:
instanceCount: 2
instanceIndex: 0

For Server2 -
spring:
cloud:
stream:
instanceCount: 2
instanceIndex: 1

Logs -

2023-10-17 10:30:18,570 INFO [-kinesis-dispatcher-1] o.s.c.l.LogAccessor:Stopping the [ShardConsumer{shardOffset=KinesisShardOffset{iteratorType=LATEST,
sequenceNumber='null', timestamp=null, stream='test-kinesis', shard='shardId-000000000000', reset=false}, state=STOP}] on the checkpoint [9223372036854775807] because the shard has been CLOSED and exhausted.

[artembilan]

Looks like a duplication of: #212.

Please, confirm and consider to move your comments over there for the whole picture.

[lengyuewuhua]

Yes, it is same issue. I will comment there.

[artembilan]

Duplicate of #212.