A lightweight high-level kafka replicator based on kafka-node