根据JSON中的值从Kafka读取一些JSON数据。是否可以从JDBC接收器插入或删除记录?
您可以通过扩展RichSinkFunction编写自己的接收器。在open()方法中通过JDBC创建连接,并在invoke()方法中执行CRUD语句。
RichSinkFunction
open()
invoke()