如何从Apache Kafka到合stream平台？

我有一个dockerized的Apache Kafka集群（每个vm运行一个docker容器，它又运行kafka和zookeeper一个实例），并且已经包含主题和消息。主要使用logstash作为生产者， logstash和node-kafka作为消费者。如何将系统转换为使用新发布的汇合平台而不停机？

REST API会为我节省很多时间，但在我看来， REST API需要运行Schema Registry 。首先，我怎么没有一个Schema Registry之前和之后生存，为什么我现在需要它？ Apache Kafka的数据会发生什么情况？

由于一切都必须容器化，有什么build议？多个Dockerfile或一个单一的Dockerfile的一切？目前我只有一个Dockerfile并使用supervisord启动kafka和zookeeper 。