kafka_create_replicator function

Creates the replicator