Confluent Kafka Connect:新记录没有填充我的表特定主题



我设置了一个简单的Kafka连接过程,用于连接到Oracle CDB/PDB环境并检测其更改。

成功地设置了所有组件,没有任何错误-创建了表,用户可以查询,创建了主题等。然而,我面临着疾病控制与预防中心流程的一个问题;新记录没有填充我的表特定主题";。

此处的汇流故障排除指南中有一个关于此问题的条目:https://docs.confluent.io/kafka-connect-oracle-cdc/current/troubleshooting.html#new-记录没有填充我的表特定主题

但当我读到这篇文章时,我不确定,因为根据你的看法,它可以有多种解释:

新记录没有填充我的表特定主题
现有架构(表特定主题的(可能与重做日志主题不兼容(不兼容的重做架构或不兼容的重复主题本身?定于表或重做逻辑架构?(或使用不同的重做日志主题可能会解决此问题(<strong]不同的重做主题?为什么?>

因此,我在尝试让我的流程检测更改时运气不佳。寻求一些支持,以充分理解以上来自Confluent的解决方案。

在我们的案例中,原因是缺少redo.log.consumer.bootstrap.servers设置。此外,重做主题名称设置redo.log.topic.name也很重要。

假设:在"快照"模式下,连接器将初始数据带到表主题,然后开始拉取重做日志并将相关条目写入"重做"主题。同时,作为一个单独的任务,它启动一个使用者任务来读取重做主题,而该使用者任务实际上将CDC更改写入表主题。这就是为什么"redo.log.customer.*"设置与配置相关。

最新更新