especially want to look for shard consistency during stream as metadata changes.
especially want to look for shard consistency during stream as metadata changes.