阿里云文档 2026-08-12

创建Kafka Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务,将指定云消息队列 Kafka 版实例中的数据快速导入至另外的云消息队列 Kafka 版实例中。

阿里云文档 2026-04-23

创建RabbitMQ Source Connector

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

阿里云文档 2026-04-23

创建MQTT Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建流入任务,将云消息队列 MQTT 版中的数据快速导入至云消息队列 Kafka 版实例中。

阿里云文档 2026-04-23

创建SMQ Source Connector

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

阿里云文档 2025-09-10

创建DTS Source Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流入源为数据传输服务DTS的消息流入任务。

文章 2024-11-29 来自:开发者社区

使用kafka consumer加载数据加载异常并且报source table and destination table are not same错误解决办法

现象当服务器出现断电,磁盘写满等故障导致集群异常并手动恢复后,集群上运行的kafka consumer 任务可能出现停止加载的异常; 定位问题查看集群gcluster的express日志,如果发现出现无法加载的表报source table and destination table are not same的异常日志,可以尝试...

问答 2022-02-15 来自:开发者社区

直接通过kafka source table表名直接引用报错,提示hive catalog内没这张表

我这面在使用hivecatalog将kafka数据落地到hive,但现在有一个问题是,我不想保存kafka source table元数据(默认自动保存),通过创建视图或临时表的方式启动flink任务,这时候直接通过kafka source table表名直接引用报错,提示hive catalog内没这张表,这种情况我改怎么引用我的kafka未持久化表哪? *来自志愿者整理的flink邮件归档

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

产品推荐

消息队列

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

+关注