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

问题描述 投票:0回答:1

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

apache-flink
1个回答
1
投票

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

© www.soinside.com 2019 - 2024. All rights reserved.