需支持更多的组件

[cmdares]

1、支撑Kafka读取和写入
2、支持主流数据库的Upsert操作，如：Mysql、Postgresql、Oracle
参考：
mysql https://blog.csdn.net/a544258023/article/details/94029334
postgresql https://stackoverflow.com/questions/34643200/spark-dataframes-upsert-to-postgres-table
oracle merge into语法（暂时没有找到相应实现，应该与mysql的实现方式类似）
希望团队可以扩展spark的这块逻辑，支持带有主键的Upsert的应用场景，目前这个需求在实践过程中还是较为常见的。
3、图库（janusgraph 、Neo4j）数据的写入和读取（Gremlin、Cepher）

[judy0131]

您好，感谢关注~
1.PiFlow已经支持Kafka读写
2.“Upsert操作”团队会考虑该需求。同时欢迎您加入，贡献代码~
3.目前支持Cepher读取和写入Neo4j