Hello
I am facing an issue while setting up Confluent Replicator for cross-cluster replication between two Kafka clusters. The source cluster is on-prem; while the destination is hosted in a cloud environment. Despite following the official documentation, I encounter intermittent connection timeouts and replication lag. 
I have confirmed that the necessary network configurations (firewalls, security groups, etc.) are in place.
Both clusters can communicate, and I can produce and consume messages from the source & destination clusters independently. However; during replication, the process sometimes stalls & logs show recurring connection errors with no clear resolution. 
I have checked Cluster Replication - Confluent Community Java guide for reference but still need advice .
Has anyone faced similar challenges? Could this be related to specific configurations like offset translation, authentication issues (e.g., SASL/SSL) / even network latencies? 
Any troubleshooting tips would be greatly appreciated!
Thank you !