akkadotnet/akka.net

    private static void ShardingExample(ActorSystem system)
    {
        var sharding = ClusterSharding.Get(system);
        var shardRef = sharding.Start("product", Props.Create(() => new Product()), ClusterShardingSettings.Create(system),
            message =>
            {
                var productMessage = message as IProductMessage;
                return productMessage != null ? Tuple.Create(productMessage.Id.Value, message) : null;
            }, message => "0001");

        shardRef.Tell(new CreateProduct(ProductId.CreateAsin("ACME001"), "Jetpack"));
        shardRef.Tell(new CreateProduct(ProductId.CreateAsin("ACME002"), "Giant magnet"));



        var rand = new Random();
        for (int idx = 0; idx < 10; idx++)
        {
            var productId = ProductId.CreateAsin($"ACME00{rand.Next(1, 3)}");
            shardRef.Tell(new SubmitReview(productId, rand.Next(1, 6)));                               
        }
    }