问答 2024-05-02 来自:开发者社区

消费hologres binlog的Java代码,有相关文档吗?

消费hologres binlog的Java代码,有相关文档吗?

问答 2024-05-01 来自:开发者社区

Flink CDC里同样的代码 有的binlog返回了 schema 有的没返回为什么?

Flink CDC里同样的代码 有的binlog返回了 schema 有的没返回为什么?

问答 2023-12-19 来自:开发者社区

Flink CDC这块应该就是监听binlog的客户端顶层代码了哇,其它非监听表也能进来的吗?

Flink CDC这块应该就是监听binlog的客户端顶层代码了哇,无主键表就是进不来断点,其它非监听表也能进来的?

问答 2023-11-21 来自:开发者社区

Flink CDC使用ds代码方式就是只一个线程读取binlog吗??

Flink CDC使用ds代码方式就是只一个线程读取binlog吗??

问答 2023-06-11 来自:开发者社区

大佬们,想请教个问题我Flink CDC代码以模式读取最新的binlog,挂掉之后想通过的方式进行?

大佬们,想请教个问题我Flink CDC代码以startupOptions(StartupOptions.latest())模式读取最新的binlog,挂掉之后想通过savepoint的方式进行断点续传的话,需要将lastest()改成initial()么?

问答 2023-05-29 来自:开发者社区

有些业务代码,是基于mysql binlog 的,现在迁移oceanbase 还能兼容吗?

有些业务代码,是基于mysql binlog 的,现在迁移oceanbase 还能兼容吗?

问答 2023-05-08 来自:开发者社区

canal客户端只返回了已更新的字段,binlog格式为row,也没有在代码作过滤操作

有十几二十个字段,但是afterColumnList只有更新过的字段,某些重要的字段并没有返回。 binlog格式为row canal订阅的格式 并没有做字段的过滤。 所以现在的问题是不知道什么地方过滤了。 原提问者GitHub用户JoyceeLin

问答 2023-05-03 来自:开发者社区

使用原生的mq发到kafka,binlog日志的数据为什么没有偏移量信息。。写代码的时候可以拿到偏移

如题,之前写过代码试过拿binlog日志,可以拿到该条binlog日志的偏移量。但是使用原生的mq发送到kafka里时候,只有数据操作的一些信息,没有这条信息在binlog的偏移量。 原提问者GitHub用户everior

问答 2022-08-26 来自:开发者社区

大家好!请问stream api 把binlog日志读取出来,后面是用到什么方式,需要自己代码批处理

大家好!请问stream api 把binlog日志读取出来,后面是用到什么方式,需要自己代码批处理下游的表吗,或者说怎么处理到下游的库表当中?

问答 2022-08-20 来自:开发者社区

新版的mysqlsource不支持指定binlog offset的原因是啥, 看代码 支持下貌似也没

新版的mysqlsource不支持指定binlog offset的原因是啥, 看代码 支持下貌似也没有太大问题吧

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等