单机部署

环境要求

准备消息队列

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

下载安装包

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

单机部署 - 图1备注

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

DB 依赖

  1. inlong-agent/lib/
  2. inlong-audit/lib/
  3. inlong-manager/lib/
  4. inlong-tubemq-manager/lib/
  • 如果后端连接 PostgreSQL 数据库,不需要引入额外依赖。

配置

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

  1. # 本地机器 IP
  2. local_ip=
  3. # 消息队列服务: pulsar 或者 kafka
  4. mq_type=pulsar
  5. # 数据库配置,需要使用 MySQL
  6. spring_datasource_hostname=
  7. spring_datasource_port=3306
  8. spring_datasource_username=root
  9. spring_datasource_password=inlong
  10. # Flink REST server 地址
  11. flink_rest_address=
  12. # Flink REST server 端口
  13. flink_rest_port=8081

启动

  1. bin/inlong-daemon start standalone

集群初始化

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

  1. User: admin
  2. Password: inlong

创建集群标签

页面点击 [集群管理]->[标签管理]->[新建],指定集群标签名称和负责人: 单机部署 - 图2

单机部署 - 图3警告

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

注册 MQ 集群

  • 选择 1 : Apache Pulsar 页面点击 [集群管理]->[集群管理]->[新建集群],注册 Pulsar 集群: 单机部署 - 图4

  • 选择 2 : Apache Kafka 页面点击 [集群管理]->[集群管理]->[新建集群],注册 Kafka 集群: 单机部署 - 图5

单机部署 - 图6备注

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

使用

创建数据流可以参考 Example.