For end to end integration testing, we would like to use an appraoch that allow us to boot a cluster, run our data pipeline which has several kafka stream application, collect the result, then shutdown the cluster.