Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

rusoto_kines: calling next on EventStream<rusoto_kinesis::SubscribeToShardEventStreamItem> fails after the stream is re-sharded #1963

Open
RichardChester opened this issue Nov 29, 2021 · 1 comment

Comments

@RichardChester
Copy link

After reducing the number of shards I keep getting a parse error when calling next on the event stream. This error appears to be internal to rusoto as it is trying to parse the payload being sent into an SubscribeToShardEvent however the payload it's receiving is a ChildShard(which is optionally present in a SubscribeToShardEvent).

@RichardChester
Copy link
Author

I think that a new struct needs adding to the SubscribeToShardEventStreamItem as when you re-shard and it reaches the end of the stream the payload sent from kinesis doesn't match any of the options. for it to work you would need to add a SubscribeToShardEventStreamItem::ChildShard and you know if you receive it when calling next on the event stream that there has been a re-shard and you may need to connect to the new shard

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant