跳到主要内容
版本：3.x

ActiveMQ

适用版本Cloud 功能TapData Cloud 为您提供了云端服务，适合需要快速部署、低前期投资场景，帮助您更好地专注于业务发展而非基础设施管理，注册账号即可领取免费的 Agent 实例，欢迎试用。企业版功能TapData Enterprise 可部署在您的本地数据中心，适合对数据敏感性或网络隔离有严格要求的场景，可服务于构建实时数仓，实现实时数据交换，数据迁移等场景。社区版功能TapData Community 是一个开源的数据集成平台，提供基础的数据同步和转换功能，可通过 Docker 一键部署，帮助您快速探索和实施数据集成项目。随着项目或企业发展，您可以平滑升级至 TapData Cloud 或 TapData Enterprise，以获得更多高级功能或服务支持。

请遵循以下说明以确保在 Tapdata 中成功添加和使用 ActiveMQ。

支持版本​

5.14.x

ACTIVEMQ 配置说明​

  • 队列名称为空，默认加载所有队列；如果需要指定，可以用逗号分隔。
  • MQ连接串（BrokerUrl）格式：tcp://[host]:[port]。

使用限制​

  • 仅支持 JSON Object 字符串的消息格式 (如 {"id":1, "name": "张三"})，后续会补充JSONBytes，XML等格式。
  • 可以不用提前创建好队列
  • PDK框架限制且topic方式不能很好的支持全量，topic暂时不可用。

识别数据类型​

  • OBJECT
  • ARRAY
  • NUMBER
  • INTEGER
  • BOOLEAN
  • STRING（长度200以下）
  • TEXT