Replicate Data between Two Hazelcast Clusters with Hazelcast Platform Operator

package com.hazelcast;

import com.hazelcast.client.HazelcastClient;
import com.hazelcast.client.config.ClientConfig;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.map.IMap;

import java.util.Random;

public class Main {
    public static void main(String[] args) throws Exception {
        if(args.length != 2) {
            System.out.println("You need to pass two arguments. The first argument must be `fill` or `size`. The second argument must be `mapName`.");
        } else if (!((args[0].equals("fill") || args[0].equals("size")))) {
            System.out.println("Wrong argument, you should pass: fill or size");
        } else{
            ClientConfig config = new ClientConfig();
            config.getNetworkConfig().addAddress("<EXTERNAL-IP>");

            HazelcastInstance client = HazelcastClient.newHazelcastClient(config);
            System.out.println("Successful connection!");

            String mapName = args[1];
            IMap<String, String> map = client.getMap(mapName);

            if (args[0].equals("fill")) {
                System.out.printf("Starting to fill the map (%s) with random entries.\n", mapName);

                Random random = new Random();
                while (true) {
                    int randomKey = random.nextInt(100_000);
                    map.put("key-" + randomKey, "value-" + randomKey);
                    System.out.println("Current map size: " + map.size());
                }
            } else {
                System.out.printf("The map (%s) size: (%d)\n\n", mapName, map.size());
                client.shutdown();
            }
        }

    }
}
java

'use strict';

const { Client } = require('hazelcast-client');

const clientConfig = {
    network: {
        clusterMembers: [
            '<EXTERNAL-IP>'
        ]
    }
};

(async () => {
    try {
        if (process.argv.length !== 4) {
            console.error('You need to pass two arguments. The first argument must be `fill` or `size`. The second argument must be `mapName`.');
        } else if (!(process.argv[2] === 'fill' || process.argv[2] === 'size')) {
            console.error('Wrong argument, you should pass: fill or size');
        } else {
            const client = await Client.newHazelcastClient(clientConfig);
            const mapName = process.argv[3]
            const map = await client.getMap(mapName);
            await map.put('key', 'value');
            const res = await map.get('key');
            if (res !== 'value') {
                throw new Error('Connection failed, check your configuration.');
            }
            console.log('Successful connection!');
            if (process.argv[2] === 'fill'){
                console.log(`Starting to fill the map (${mapName}) with random entries.`);
                while (true) {
                    const randomKey = Math.floor(Math.random() * 100000);
                    await map.put('key' + randomKey, 'value' + randomKey);
                    const size = await map.size();
                    console.log(`Current map size: ${size}`);
                }
            } else {
                const size = await map.size();
                console.log(`The map (${mapName}) size: ${size}`);
            }
        }
    } catch (err) {
        console.error('Error occurred:', err);
    }
})();
javascript

package main

import (
	"context"
	"fmt"
	"math/rand"
	"os"

	"github.com/hazelcast/hazelcast-go-client"
)

func main() {
	if len(os.Args) != 3 {
		fmt.Println("You need to pass two arguments. The first argument must be `fill` or `size`. The second argument must be `mapName`.")
		return
	}
	if os.Args[1] != "fill" && os.Args[1] != "size" {
		fmt.Println("Wrong argument, pass `fill` or `size` instead.")
		return
	}

	config := hazelcast.Config{}
	cc := &config.Cluster
	cc.Network.SetAddresses("<EXTERNAL-IP>:5701")
	cc.Unisocket = true
	ctx := context.TODO()
	client, err := hazelcast.StartNewClientWithConfig(ctx, config)
	if err != nil {
		panic(err)
	}
	fmt.Println("Successful connection!")

	mapName := os.Args[2]
	m, err := client.GetMap(ctx, mapName)
	if err != nil {
		panic(err)
	}
	if os.Args[1] == "fill" {
		fmt.Printf("Starting to fill the map (%s) with random entries.\n", mapName)
		for {
			num := rand.Intn(100_000)
			key := fmt.Sprintf("key-%d", num)
			value := fmt.Sprintf("value-%d", num)
			if _, err = m.Put(ctx, key, value); err != nil {
				fmt.Println("ERR:", err.Error())
				continue
			}
			mapSize, err := m.Size(ctx)
			if err != nil {
				fmt.Println("ERR:", err.Error())
				continue
			}
			fmt.Println("Current map size:", mapSize)
		}
		return
	}
	mapSize, err := m.Size(ctx)
	if err != nil {
		fmt.Println("ERR:", err.Error())
		return
	}
	fmt.Printf("The map (%s) size: %v", mapName, mapSize)

}
go

import logging
import random
import sys

import hazelcast

logging.basicConfig(level=logging.INFO)

if len(sys.argv) != 3:
    print("You need to pass two arguments. The first argument must be `fill` or `size`. The second argument must be `mapName`.")
elif not (sys.argv[1] == "fill" or sys.argv[1] == "size"):
    print("Wrong argument, you should pass: fill or size")
else:
    client = hazelcast.HazelcastClient(
        cluster_members=["<EXTERNAL-IP>"],
        use_public_ip=True,
    )
    print("Successful connection!", flush=True)

    mapName = sys.argv[2]
    m = client.get_map(mapName).blocking()

    if sys.argv[1] == "fill":
        print(f'Starting to fill the map ({mapName}) with random entries.', flush=True)
        while True:
            random_number = str(random.randrange(0, 100000))
            m.put("key-" + random_number, "value-" + random_number)
            print("Current map size:", m.size())
    else:
        print(f'The map ({mapName}) size: {m.size()}')
python

using System;
using System.Threading.Tasks;
using Hazelcast;
using Microsoft.Extensions.Logging;

namespace Client
{
    public class Program
    {
        static async Task Main(string[] args)
        {
            if (args.Length != 2)
            {
                Console.WriteLine("You need to pass two arguments. The first argument must be `fill` or `size`. The second argument must be `mapName`.");
                return;
            }
            if (!(args[0] == "fill" || args[0] == "size"))
            {
                Console.WriteLine("Wrong argument, you should pass: fill or size");
                return;
            }

            var mapName = args[1];
            var options = new HazelcastOptionsBuilder()                
                .With(args)                
                .With((configuration, options) =>
                {
                    options.LoggerFactory.Creator = () => LoggerFactory.Create(loggingBuilder =>
                        loggingBuilder
                            .AddConsole());

                    options.Networking.UsePublicAddresses = true;
                    options.Networking.SmartRouting = false;
                    options.Networking.Addresses.Add("<EXTERNAL-IP>:5701");
                    
                })
                .Build();



            await using var client = await HazelcastClientFactory.StartNewClientAsync(options);
            
            Console.WriteLine("Successful connection!");
            Console.WriteLine("Starting to fill the map with random entries.");

            var map = await client.GetMapAsync<string, string>(mapName);
            var random = new Random();

            if (args[0] == "fill")
            {
                Console.WriteLine("Starting to fill the map with random entries.");
                while (true)
                {
                    var num = random.Next(100_000);
                    var key = $"key-{num}";
                    var value = $"value-{num}";
                    await map.PutAsync(key, value);
                    var mapSize = await map.GetSizeAsync();
                    Console.WriteLine($"Current map size: {mapSize}");
                }
            }
            else
            {
                var mapSize = await map.GetSizeAsync();
                Console.WriteLine($"Current map size: {mapSize}");
                await client.DisposeAsync();
            }
        }
    } 
}
cs

cd java
mvn package
java -jar target/*jar-with-dependencies*.jar fill <MAP-NAME>
bash

Successful connection!
Starting to fill the map (<MAP-NAME>) with random entries.
Current map size: 2
Current map size: 3
Current map size: 4
....
....
shell

cd nodejs
npm install
npm start fill <MAP-NAME>
bash

Successful connection!
Starting to fill the map (<MAP-NAME>) with random entries.
Current map size: 2
Current map size: 3
Current map size: 4
....
....
shell

cd go
go run main.go fill <MAP-NAME>
bash

Successful connection!
Starting to fill the map (<MAP-NAME>) with random entries.
Current map size: 2
Current map size: 3
Current map size: 4
....
....
shell

cd python
pip install -r requirements.txt
python main.py fill <MAP-NAME>
bash

Successful connection!
Starting to fill the map (<MAP-NAME>) with random entries.
Current map size: 2
Current map size: 3
Current map size: 4
....
....
shell

cd dotnet
dotnet build
dotnet run fill <MAP-NAME>
bash

Successful connection!
Starting to fill the map (<MAP-NAME>) with random entries.
Current map size: 2
Current map size: 3
Current map size: 4
....
....
shell

cd clients/java
mvn package
java -jar target/*jar-with-dependencies*.jar size <MAP-NAME>
bash

Successful connection!
Current map (<MAP-NAME>) size: 12
shell

cd clients/nodejs
npm install
npm start size <MAP-NAME>
bash

Successful connection!
Current map (<MAP-NAME>) size: 12
shell

cd clients/go
go run main.go size <MAP-NAME>
bash

Successful connection!
Current map (<MAP-NAME>) size: 12
shell

cd clients/python
pip install -r requirements.txt
python main.py size <MAP-NAME>
bash

Successful connection!
Current map (<MAP-NAME>) size: 12
shell

cd clients/dotnet
dotnet build
dotnet run size <MAP-NAME>
bash

Successful connection!
Current map (<MAP-NAME>) size: 12
shell