ApachePulsarJDBCsink:区分插入/更新/删除
创始人
2024-09-06 09:30:40
0

要区分插入/更新/删除操作,需要在Pulsar JDBC Sink Connector配置文件中使用hashtable选项来设置相关的属性。对于每个消息,通过指定的主键列来确定它是插入、删除还是更新操作。

以下是示例代码:

pulsar-sink.properties文件配置:

Connection information

jdbc.username=bob jdbc.password=1234 jdbc.url=jdbc:postgresql://localhost/test

Sink configuration

sink.topic=my-topic sink.processing.guarantees=AT_LEAST_ONCE sink.max.pending.records=1000 sink.batch.size=10 sink.batch.delay.ms=500 sink.converter.class=org.apache.pulsar.io.core.JacksonJsonConverter sink.converter.schema.type=avro sink.converter.schema.registry.url=http://localhost:8081

JDBC sink configuration

Use a hash table to specify the target table and the primary key column

jdbc.hash.table={"mytable": "id"}

Use the 'op' field to determine the operation (insert, update or delete)

jdbc.hash.column.op={"id": "insert"}

在上面的配置中,我们使用了hashtable选项来指定目标表和主键列。 jdbc.hash.column.op用来指定每个操作(插入,更新或删除),对于每个消息,它将操作与消息属性中的主键值匹配。在示例中,我们对所有的消息都执行插入操作。

注意,如果需要执行更新或删除操作,必须指定唯一的主键列。如果没有指定,将抛出异常。

相关内容

热门资讯

wpk辅助挂!aa poker... 1、wpk辅助挂!aa poker下载地址,(wEPOKE)从来有挂(详细辅助新2025版);详细教...
透视总结(德州ai人工智能)哈... 1、透视总结(德州ai人工智能)哈糖大菠萝怎么拿好牌(详细辅助新版2025教程)起初真的有挂2、进入...
透视最新(wpk德州透视辅助)... 透视最新(wpk德州透视辅助)德扑之星刷数据(详细辅助力荐教程)从来有挂1、打开德州poker外挂分...
wepower有外挂!微扑克俱... wepower有外挂!微扑克俱乐部24小时,(WepoKe)都是有挂(详细辅助高科技教程)1、很好的...
透视线上(德州免费辅助神器ap... 透视线上(德州免费辅助神器app)wepoke智能ai(详细辅助透牌教程)其实真的有挂1、每个玩家都...
智星德州菠萝开挂!德扑ai代打... 智星德州菠萝开挂新手教程相关信息汇总(需添加指定Q群1067239143获取下载链接);智星德州菠萝...
透视智能ai(wpk ai辅助... 透视智能ai(wpk ai辅助)微扑克ai辅助(详细辅助攻略教程)果然是有挂;人气非常高,ai更新快...
wpk德州透视辅助!wpk俱乐... wpk德州透视辅助!wpk俱乐部软件,(德州aapoker俱乐部)切实真的有挂(详细透视技巧教程)准...
透视总结(wepoke辅助机器... 透视总结(wepoke辅助机器人)微扑克wpk(详细辅助专业教程)确实存在有挂是一款可以让一直输的玩...
aapoker辅助!红龙扑克发... 1、aapoker辅助!红龙扑克发牌有问题,(Wepoke)真是是真的有挂(详细辅助曝光教程)(UU...