消费者示例 1 Consumer 示例 1.1 PullConsumer 1.2 PushConsumer 消费者示例 1 Consumer 示例 TubeMQ 提供了两种方式来消费消息： PullConsumer and PushConsumer。 1.1 PullConsumer public class PullConsume...

消费者示例 1 Consumer 示例 1.1 PullConsumer 1.2 PushConsumer 消费者示例 1 Consumer 示例 TubeMQ 提供了两种方式来消费消息： PullConsumer and PushConsumer。 1.1 PullConsumer public class PullConsume...

消费者示例 1 Consumer 示例 1.1 PullConsumer 1.2 PushConsumer 消费者示例 1 Consumer 示例 TubeMQ 提供了两种方式来消费消息： PullConsumer and PushConsumer。 1.1 PullConsumer public class PullConsume...

消费者示例 1 Consumer 示例 1.1 PullConsumer 1.2 PushConsumer 消费者示例 1 Consumer 示例 TubeMQ 提供了两种方式来消费消息： PullConsumer and PushConsumer。 1.1 PullConsumer public class PullConsume...

Kubernetes 部署 准备条件 使用 配置 安装 进入 InLong Dashboard 配置 卸载 开发 kind 快速开始 安装 Helm 安装 chart 开发与调试 故障排除 Kubernetes 部署 准备条件 Kubernetes 1.10+ Helm 3.0+ InLong Helm Chart Ap...

总览 介绍 模块 交互流程 数据模型 总览 介绍 InLong Manager 是 Apache InLong 项目的统一管理平台，平台提供各基础配置（如数据流配置、消费配置、集群管理等）的维护入口，用户可创建数据采集任务、查看指标数据等。 模块 模块 描述 manager-common 模块公共代码，如异常定义、工具类、枚举等 mana...

Bare Metal 部署 环境要求 准备消息队列 下载安装包 标准架构 安装 创建数据流 轻量化架构 安装 Bare Metal 部署 环境要求 MySQL 5.7+ or PostgreSQL Apache Flink 1.13.5 准备消息队列 InLong 当前支持以下消息队列，根据使用情况选择其一 即可。 InL...

消费者示例 1 Consumer 示例 1.1 PullConsumer 1.2 PushConsumer 消费者示例 1 Consumer 示例 TubeMQ 提供了两种方式来消费消息： PullConsumer and PushConsumer。 1.1 PullConsumer public class PullConsume...

部署 DataProxy 配置tube地址和端口号 环境准备 配置manager地址 启动 检查启动状态 将 DataProxy 配置添加到 InLong-Manager 部署 DataProxy 所有的安装文件都在 inlong-dataproxy 目录下。 配置tube地址和端口号 tubemq_master_list 是Tube...

安装部署 环境准备 添加依赖 修改配置 配置 Flink 插件 启动服务 集群初始化 创建集群标签 注册 MQ 集群 (可选) 开启OpenAPI认证 开启认证 配置认证 创建认证 Key 安装部署 环境准备 安装并启动 MySQL 5.7+ 初始化数据库 inlong-manager 目录下有 sql/apache_...