文章 2024-10-14 来自:开发者社区

大数据-117 - Flink DataStream Sink 案例:写出到MySQL、写出到Kafka

点一下关注吧!!!非常感谢!!持续更新!!!目前已经更新到了:Hadoop(已更完)HDFS(已更完)MapReduce(已更完)Hive(已更完)Flume&...

大数据-117 - Flink DataStream Sink 案例:写出到MySQL、写出到Kafka
文章 2024-10-14 来自:开发者社区

大数据-116 - Flink DataStream Sink 原理、概念、常见Sink类型 配置与使用 附带案例1:消费Kafka写到Redis

点一下关注吧!!!非常感谢!!持续更新!!! 目前已经更新到了: Hadoop(已更完) HDFS(已更完) MapReduce(已更完) Hive(已更完) Flume(已更完) Sqoop(已更完) Zookeeper(已更完) HBase(已更完) Redis (已更完) Kafka(已更完) ...

大数据-116 - Flink DataStream Sink 原理、概念、常见Sink类型 配置与使用 附带案例1:消费Kafka写到Redis
问答 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-05-16 来自:开发者社区

实时计算 Flink版产品使用合集之支持sink到多分区的kafka ,还能保持有序吗

问题一:请教下Flink CDC SQL Server用户定义数据类型该怎么处理? 请教下Flink CDC SQL Server用户定义数据类型该怎么处理?目前错误提示IllegalArgumentException: The column "WARD_CODE" is referenced as PRIMARY KEY, but a matching column is n...

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

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

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 ,还能保持有序吗?

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

问答 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接收数据?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注