基于json中的值从kafka读取一些json数据。是否可以从jdbc接收器插入或删除记录？
a0zr77ik1#
你可以写你自己的Flume通过扩展 RichSinkFunction . 通过jdbc在中创建连接 open() 方法，并在中执行crud语句 invoke() 方法。
RichSinkFunction
open()
invoke()
1条答案
按热度按时间a0zr77ik1#
你可以写你自己的Flume通过扩展
RichSinkFunction. 通过jdbc在中创建连接open()方法，并在中执行crud语句invoke()方法。