问答 2024-07-10 来自:开发者社区

Flink CDC配置true以后下游kafka的canal-json内容里没有包怎么办?

Flink CDC3.1.1 Pipeline Connector Options sink.add-tableId-to-header-enabled 配置true以后下游kafka的canal-json内容里没有包括'namespace','schemaName','tableName' 相关信息,有哪位大佬遇到过吗?

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

在Flink CDC中怎么配置flink消费宿主机上的kafka服务呢?

在Flink CDC中flink on native k8s的方式提交flink任务,怎么配置flink消费宿主机上的kafka服务呢,Pod里面的hosts解析不到宿主机?

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

cdc抽取mysql整个实例的binlog,有没有方案通过配置的方式将这些库表拆开分发到kafka

cdc抽取mysql整个实例的binlog,有没有方案通过配置的方式将这些库表拆开分发到kafka

问答 2022-07-18 来自:开发者社区

各位老板 问一下 就是我们mysql cdc保存的是配置数据 然后kafka里面堆积的有历史

各位老板 问一下 就是我们mysql cdc保存的是配置数据 然后kafka里面堆积的有历史数据 那么如果我启动程序的话就会存在有些配置数据还没有读取到就先处理kafka里面的数据了 请问这个情况要怎么处理?

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注