We want to have multiple replicas for the source, so we need to shard data streams with either kafka or a database (postgres, redis).