Hello All
I am using an enhanced consumer to subscribe to a shard in kinesis using the subscribe_to_shard
method found in the rusoto_kinesis crate which returns an EventStream<rusoto_kinesis::SubscribeToShardEventStreamItem>
I have been using a while let Some(item) = subscription.next().await {
which returns a Result<SubscribeToShardEvent,RusotoError>
This has worked fine for a length of time but after re-sharding the stream it just returns a RusotoError::ParseError
as they payload it recives serializes into a ChildShard
whilst it is expecting a SubscribeToShardEvent
which usually contains ChildShard
as a field. I could use that ChildShard
object to subscribe to the newly created shard, which is how it should work, but I can't get at that object because the moment I call next()
on the event stream I just recive the error.
I have raised an issue on rusoto's GitHub but thought I'd also ask here to check that I haven't missed something and to confirm that the expected behaviour would be that after a re-shard I would receive a SubscribeToShardEvent
containing a ChildShard
object that I could use to subscribe to the newly created shard.
Thanks in advance
Rich