阿里云文档 2024-12-04

创建RabbitMQ Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务,将云消息队列 Kafka 版的数据导出至云消息队列 RabbitMQ 版。

阿里云文档 2024-12-04

创建SMQ Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务,将云消息队列 Kafka 版的数据导出至轻量消息队列(原 MNS)。

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

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

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

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

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

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-09-05 来自:开发者社区

Flink1.17.1 sink kafka, 总是输出 disconnected 的日志,正常吗?

Flink1.17.1 sink kafka, 总是输出 disconnected 的日志, 正常吗? INFO org.apache.kafka.clients.NetworkClient [] - [Producer clientId=producer-4] Node 107928 disconnected.

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

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

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

文章 2023-07-26 来自:开发者社区

Flink的sink实战之二:kafka

欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 本文是《Flink的sink实战》系列的第二篇,前文《Flink的sink实战之一:初探》对sink有了基本的了解,本章来体验将数据sink到kafka的操作; 版本和环境准备 本次实战的环境和版本如下: JDK:1.8.0_2...

Flink的sink实战之二:kafka
问答 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-07-25 来自:开发者社区

Flink中自定义的sink 如果kafka 已经发送消息了,这个是ck会不会被认为完成。但是最终?

Flink中自定义的sink 如果kafka 已经发送消息了,这个是ck会不会被认为完成。但是最终这个消息发送失败了?

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

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注