如何用Apache Flink从JDBC接收器删除记录

Question

基于JSON中的值，从Kafka读取一些JSON数据。是否可以从JDBC接收器插入或删除记录？

Answer 1

您可以通过扩展RichSinkFunction编写自己的水槽。在open()方法中创建JDBC的连接，并在invoke()方法中执行CRUD语句。