kafka-streams-migration

使用Replicator的Kafka Streams迁移示例 关键点 如果Kafka Streams exactly-once ，则复制器必须配置为isolation.level=read_committed 迁移的应用程序需要使用auto.offset.reset=latest重新启动 为了一个接一个地迁移连接器，对于源连接器，必须从主题connect-configs和connect-offsets提取数据。 源连接器（例如JDBC Source或Filestream源）在Kafka Connect内部主题connect-offsets提交偏移connect-offsets 。 迁移过程 在源群集上： 停止生产者和源连接器 停止Kafka Streams应用程序 等待每个拓扑和连接器清除滞后。 复制Kafka Connect源连接器偏移量json负载 停止使用者和接收器连接器 迁移