Standalone

Environment Requirements

• MySQL 5.7+
• Apache Flink 1.13.x or 1.15.x
• Docker 19.03.1+
• On Linux or Mac

Prepare Message Queue

InLong Support the following Message Queue services now, you can choose one of them.

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

Download the Binary Package

You can get binary package from Download Page ,or you can build the InLong refer to How to Build.

note

Extract apache-inlong-[version]-bin.tar.gz and apache-inlong-[version]-sort-connectors.tar.gz, and make sure the inlong-sort/connectors/ directory contains sort-connector-[type]-[version].jar.

DB Dependencies

• If the backend database is MySQL, please download mysql-connector-java-8.0.28.jar and put it into the following directories:

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

• If the backend database is PostgreSQL, there’s no need for additional dependencies.

Configure

In conf/inlong.conf, configure the parameters according to the actual situation, mainly include:

# local IP
local_ip=
# message queue: pulsar or kafka
mq_type=pulsar
# Configure Database, requires MySQL
spring_datasource_hostname=
spring_datasource_port=3306
spring_datasource_username=root
spring_datasource_password=inlong
# the REST server address for Flink
flink_rest_address=
# the REST server Port for Flink
flink_rest_port=8081

Start

bin/inlong-daemon start standalone

Cluster Initialize

When all containers are successfully started, you can access the Inlong dashboard address http://localhost, and use the following default account to log in:

User: admin
Password: inlong

Create Cluster Tag

Click [Clusters]->[ClusterTags]->[Create] on the page to specify the cluster label name and person in charge:

caution

Since each component reports the ClusterTags as default_cluster by default, do not use other names.

Register Message Queue Cluster

• Option 1 : Apache Pulsar Click [Clusters]->[Clusters]->[Create] on the page to register Pulsar Cluster:

• Option 2 : Apache Kafka Click [Clusters]->[Clusters]->[Create] on the page to register Kafka Cluster:

note

The ClusterTags selects the newly created default_cluster, and then configuring the Message Queue cluster info.

Use

You can refer to Example to create a Data Stream.