消息队列与中间件

TapData Cloud 为您提供了云端服务，适合需要快速部署、低前期投资场景，帮助您更好地专注于业务发展而非基础设施管理，注册账号即可领取免费的 Agent 实例，欢迎试用。TapData Enterprise 可部署在您的本地数据中心，适合对数据敏感性或网络隔离有严格要求的场景，可服务于构建实时数仓，实现实时数据交换，数据迁移等场景。

请选择要添加的消息队列与中间件数据源：

📄️ ActiveMQ

ActiveMQ 是一个开源的 Java 消息代理，支持多种行业标准协议，广泛应用于企业级消息传递，适用于异步处理、应用解耦、流量削峰（如秒杀活动）、日志处理及消息通讯等场景。本文将介绍如何在 TapData 中添加 ActiveMQ 数据源，轻松将其用作源或目标，构建高效数据管道，实现数据的实时同步。

📄️ AI Chat

http5002/openapi/swagger#/

📄️ BesChannels

致趣·百川 B2B 一站式营销云（BesChannels），专注B2B赛道，帮助B2B市场部获取更多线索、提高线索转化率，为销售输送更多商机。

📄️ Hazelcast

请遵循以下说明以确保在 Tapdata 中成功添加和使用 Hazelcast Cloud 数据库。

📄️ Kafka-Enhanced

Apache Kafka 是一个分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。Kafka-Enhanced 是一款升级版的 Kafka 连接器，支持标准、原生 Kafka、Flink、Canal、Debezium 数据结构进行数据传输，突破旧版 Kafka 连接器仅支持 JSON Object 的限制，可将非 JSON Object 结构数据加载到应用中进行处理，同时提供更可靠的断点续传机制。

📄️ Kafka

Apache Kafka 是一个分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。完成 Agent 部署后，您可以跟随本文教程在 Tapdata 中添加 Apache Kafka 数据源，后续可将其作为源或目标库来构建数据管道。

📄️ RabbitMQ

RabbitMQ 是开源轻量级消息代理，支持 AMQP 协议，适用于分布式系统异步通信、应用解耦及流量削峰（如订单峰值处理）等场景，结合 TapData，可帮助您快速构建高性能的实时数据管道，满足低延迟、高吞吐场景需求。

📄️ RocketMQ

RocketMQ 是一款高性能的队列模型消息中间件，支持顺序消息、延迟消息、批量消息等多种场景，广泛应用于金融、电商等高并发系统。 结合 Tapdata，可快速构建稳定的实时数据通道，帮助企业实现系统解耦与数据驱动，提升整体业务响应能力。