Test new Kafka application with prod data with Kafka streams applications running on K8S

Or how to pipe messages from one kafka cluster to another cluster through kubectl and your local machine