安装部署 环境准备 配置 依赖 启动 重启 初始化TubeMQ集群 安装部署 安装文件在inlong-tubemq-manager目录. 环境准备 安装并启动 MySQL 5.7+ 通过下述命令加载sql/apache_tube_manager.sql ，完成表结构及基础数据的初始化： # 通过用户名和密码，创建 DB 和表： ...

安装部署 配置 配置 Manager 和 Audit 地址 启动 检查 安装部署 所有的安装文件都在 inlong-dataproxy 目录下。 配置 配置 Manager 和 Audit 地址 配置文件：conf/common.properties ： # local IP proxy . local . ip = 127.0 ...

安装部署 配置 配置 Manager 和 Audit 地址 启动 检查 安装部署 所有的安装文件都在 inlong-dataproxy 目录下。 配置 配置 Manager 和 Audit 地址 配置文件：conf/common.properties ： # local IP proxy . local . ip = 127.0 ...

自主消费 Overview 自主消费 Overview 自主消费 是指直接从消息队列服务中 (TubeMQ or Pulsar) 消费数据, 你可以使用 Pulsar SDK Client 或者 TubeMQ SDK Client 进行消费， 获取到数据后，需要通过 解析 InLongMsg 获取原数据进行下一步处理。

自主消费 Overview 自主消费 Overview 自主消费 是指直接从消息队列服务中 (TubeMQ or Pulsar) 消费数据, 你可以使用 Pulsar SDK Client 或者 TubeMQ SDK Client 进行消费， 获取到数据后，需要通过 解析 InLongMsg 获取原数据进行下一步处理。

自主消费 Overview 自主消费 Overview 自主消费 是指直接从消息队列服务中 (TubeMQ or Pulsar) 消费数据, 你可以使用 Pulsar SDK Client 或者 TubeMQ SDK Client 进行消费， 获取到数据后，需要通过 解析 InLongMsg 获取原数据进行下一步处理。

自主消费 Overview 自主消费 Overview 自主消费 是指直接从消息队列服务中 (TubeMQ or Pulsar) 消费数据, 你可以使用 Pulsar SDK Client 或者 TubeMQ SDK Client 进行消费， 获取到数据后，需要通过 解析 InLongMsg 获取原数据进行下一步处理。

自主消费 Overview 自主消费 Overview 自主消费 是指直接从消息队列服务中 (TubeMQ or Pulsar) 消费数据, 你可以使用 Pulsar SDK Client 或者 TubeMQ SDK Client 进行消费， 获取到数据后，需要通过 解析 InLongMsg 获取原数据进行下一步处理。

自主消费 Overview 自主消费 Overview 自主消费 是指直接从消息队列服务中 (TubeMQ or Pulsar) 消费数据, 你可以使用 Pulsar SDK Client 或者 TubeMQ SDK Client 进行消费， 获取到数据后，需要通过 解析 InLongMsg 获取原数据进行下一步处理。

JAVA SDK API 1 基础对象接口介绍： 1.1 MessageSessionFactory（消息会话工厂）： 1.2 MasterInfo: 1.3 TubeClientConfig： 1.4 ConsumerConfig： 1.5 Message： 1.6 MessageProducer： 1.7 MessageConsumer： ...