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

mongo source cdc + kafka sink connector这个组合支持吗?

在Flink CDC中mongo source cdc + kafka sink connector这个组合支持Exactly Once语义吗?

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

Flink CDC里官网这个实例中的kafkasink是在哪里实现的呢?

在使用 Flink CDC 进行数据流处理时,我注意到在Flink的源码中似乎没有看到对应 Kafka 的 sink 连接器实现。然而,官方示例中提到了 Kafka sink,我想请问这个 Kafka sink 是在哪里实现的?此外,在尝试编译并运行相关的 pull request 时,无法控制发送 schema change,且发送的Log里字段名称变成了f1,f2序列,没有按预期展示字段名称....

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

Flink CDC支持这种写法吗?将kafka的数据sink到postgresql和kafka行吗?

INSERT INTO my_postgres_sink, my_kafka_sink SELECT * FROM kafka_table;Flink CDC里支持这种写法吗?将kafka的数据sink到postgresql和kafka可以不?

问答 2023-09-28 来自:开发者社区

Flink CDC读取kafka中的订单和订单明细数据,同步到sink表后,这一般是什么问题啊?

Flink CDC读取kafka中的订单和订单明细数据,同步到sink表后,sink表的数据数量一直跳来跳去,一会几百条一会变成几十条,这一般是什么问题啊?感觉总是最后一次数据【新产生的一小部分流数据】,会把sink表中所有历史数据都清空掉用的mysql: CREATE TABLE sink_sale_order_detail_rt( order_item_id bigin...

问答 2023-09-13 来自:开发者社区

Flink CDC这个第六步一定要写kafka吗? 直接写sink库不写kakfa不行吗?

Flink CDC这个第六步一定要写kafka吗? 直接写sink库不写kakfa不行吗? 另外如果flink中断了, 不是有checkpoint吗? checkpoint不存储上一次的scn吗? 为何要依赖kafka?

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

Flink CDC 有人用过upsert-kafka做为sink端吗?

Flink CDC 有人用过upsert-kafka做为sink端吗。我用upsert-kafka做为sink端时,启了一个消费者去观察flink写入的那个topic,貌似没有实时捕获数据。只有重新启动flink sql-client,才能把新插入的数据捕获,但是历史的数据又会重新获取一遍?

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

请问下 使用Flink CDC 写入kafka 为什么没有sink的图呢?

请问下 使用Flink CDC 读取mysql Flink SQL 方式写入kafka的时候 为什么没有sink的图呢?

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

产品推荐

消息队列

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

+关注