Monitoring Kafka Cluster Replications using Streams Messaging Manager