Skip to main content
Version: 1.6.0

Standalone

Environment Requirements

Prepare Message Queue

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

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

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, MySQL or PostgreSQL
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 Pulsar Example to create Data Stream.