cdc sink云消息队列 Kafka 版的相关内容

问答 2024-05-20 来自：开发者社区

Flink CDC里遇到过SInk到Kafka的这个报错么？

Flink CDC里遇到过SInk到Kafka的这个报错么：Caused by: org.apache.kafka.common.errors.TimeoutException: Topic XXX not present in metadata after 60000 ms.

问答 2024-04-15 来自：开发者社区

flink cdc sql将一个source，sink到pg和kafka，这种场景支持吗?

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

Flink CDC里sink到kafka出现的报错怎么办？

Flink CDC里sink到kafka出现的报错怎么办？启动的时候应该是创建了topic

问答 2023-11-30 来自：开发者社区

Flink CDC支持sink到多分区的kafka ，还能保持有序吗？

问答 2023-11-07 来自：开发者社区

Flink CDC中sink到kafka，kafka有密码怎么处理？密码参数是啥？

问答 2023-09-19 来自：开发者社区

Flink CDC中sink如果异常了，如何处理？比如kafka宕机。数据会丢吗？

问答 2023-09-19 来自：开发者社区

Flink CDC两台服务器传输数据，在sink端部署kafka接收数据，是否可行？

问题1:Flink CDC两台服务器传输数据，相互间无法访问对方的数据库，但服务器ip可以ping通，无法使用flink sql模式同步如果我在source端使用flink cdc捕获数据，在sink端部署kafka接收数据，是否可行？类似于这种模式？问题2:采用这种模式？source端使用debezium解析日志，传输到kafka中，sink使用flink接收数据？

问答 2023-08-22 来自：开发者社区

Flink CDC有sink到kafka的方法吗？我看官方的就是要引入flink-connector

Flink CDC有sink到kafka的方法吗？我看官方的就是要引入flink-connector-kafk

问答 2023-07-26 来自：开发者社区

flink cdc source mysql sink kafka 报包冲突如何解决？

问题1：flink cdc source mysql sink kafka 报包冲突如何解决？问题2：这个也看不出问题。我cdc 2.4 flink 1.13.6

问答 2023-06-04 来自：开发者社区

大佬们请教一个Flink CDC重启生产者的问题，我通过检查点重启作业，但是sink的Kafka ？

大佬们请教一个Flink CDC重启生产者的问题，我通过检查点重启作业，但是sink的Kafka topic换了，就一直报错说生产者尝试使用producer id，但是当前没有给其分配对应的transactional id，这个怎么解决？我通过网上了解到的 producer启动时Kafka会为其分配一个唯一的producer id，这个transactional id是我们自己手动指定的？