大数据平台|nifi mysql CDC to mysql

  1. https://community.cloudera.com/t5/Community-Articles/Change-Data-Capture-CDC-with-Apache-NiFi-Part-1-of-3/ta-p/246623
  2. https://community.cloudera.com/t5/Community-Articles/Change-Data-Capture-CDC-with-Apache-NiFi-Part-2-of-3/ta-p/246519
  3. https://community.cloudera.com/t5/Community-Articles/Change-Data-Capture-CDC-with-Apache-NiFi-Part-3-of-3/ta-p/246482
【大数据平台|nifi mysql CDC to mysql】UpdateAttribute 根据数据生成update、insert、delete,并设置schema.name为当前表名。
JsonPathReader中字段可设置为能用到的所有的。
AvroSchemaRegistry设置某一个表的字段,会根据Schema Name进行匹配。

    推荐阅读