Data Quality: Fetch shard id using AWS apis instead of configuring it in YAML Handle multiple shards in a streams