单机部署

环境要求

• MySQL 5.7+
• Flink 1.13.5
• Docker 19.03.1+

准备消息队列

InLong 当前支持以下消息队列，根据使用情况选择其一即可。

• InLong TubeMQ
• Apache Pulsar 2.8.x
• Apache Kafka 2.x

下载安装包

可以从 下载页面 获取二进制包，或参考 如何编译 编译需要的版本。

备注

解压 apache-inlong-[version]-bin.tar.gz 和 apache-inlong-[version]-sort-connectors.tar.gz，并确保 inlong-sort/connectors/ 目录包含 sort-connector-[type]-[version].jar。

DB 依赖

• 如果后端连接 MySQL 数据库，请下载 mysql-connector-java-8.0.27.jar, 并将其放入以下目录：

inlong-agent/lib/
inlong-audit/lib/
inlong-manager/lib/
inlong-tubemq-manager/lib/

• 如果后端连接 PostgreSQL 数据库，不需要引入额外依赖。

配置

在conf/inlong.conf文件中根据实际情况配置参数，主要包括：

# 本地机器 IP
local_ip=
# 消息队列服务： pulsar 或者 kafka
mq_type=pulsar
# 数据库配置，MySQL 或者 PostgreSQL
spring_datasource_hostname=
spring_datasource_port=3306
spring_datasource_username=root
spring_datasource_password=inlong
# Flink REST server 地址
flink_rest_address=
# Flink REST server 端口
flink_rest_port=8081

启动

bin/inlong-daemon start standalone

集群初始化

当所有容器都成功启动后，可以访问 InLong Dashboard 地址http://localhost，并使用以下默认账号登录:

User: admin
Password: inlong

创建集群标签

页面点击 [集群管理]->[标签管理]->[新建]，指定集群标签名称和负责人：

警告

由于各个组件默认上报集群标签为 default_cluster，请勿使用其它名称。

注册 MQ 集群

• 选择 1 : Apache Pulsar 页面点击 [集群管理]->[集群管理]->[新建集群]，注册 Pulsar 集群：

• 选择 2 : Apache Kafka 页面点击 [集群管理]->[集群管理]->[新建集群]，注册 Kafka 集群：

备注

集群标签选择刚创建的 default_cluster，然后配置 MQ 集群信息。

使用

创建数据流可以参考 Pulsar Example.