In large-scale data processing and real-time log ingestion scenarios, developers often need to pull data from various data sources, such as Kafka and MySQL, to Elasticsearch or OpenSearch. Key challenges in such efforts include network connectivity, task interruptions, and the complexity of multi-pipeline management. CSS provides a web-based configuration center for Logstash clusters, where you can test network connectivity between Logstash and both the data source and destination in one click, as well as start or hot-start pipelines. To ensure high availability and stability in complex scenarios, CSS also deploys a Keepalive mechanism supported by a daemon process.
Option | Start | Hot Start |
|---|---|---|
How It Works | When the cluster has no running pipelines, the system initializes the runtime environment and loads the configuration. | When the cluster already has running pipelines, a new pipeline is dynamically loaded without restarting the entire Logstash process, ensuring zero service interruptions. |
Batch Processing | Up to 50 configuration files can be started at once. | Only one configuration file can be started at a time. |
Keepalive | You can choose to enable or disable Keepalive. | The Keepalive setting is inherited from existing pipelines in the cluster. It cannot be modified. |
When to Use | The cluster has no Running pipelines. | The cluster already has Running pipelines. You use this option to add new pipelines without interrupting existing pipelines. |
Constraint | N/A |
|
There can be up to 50 Running configuration files in the pipeline list of a Logstash cluster.
Before starting a migration task, test the connectivity between Logstash and both the data source and destination. This helps prevent task failures caused by connectivity issues.
How a connectivity test works:
Prerequisites for the connectivity test
Depending on the locations of the Logstash cluster, data source, and destination, the following conditions must be met:
You can test a maximum of 10 IP addresses at a time. You can click Add to add more IP addresses and click Test at the bottom to test connectivity to multiple IP addresses at a time.
If Available is returned, the network is connected. If Unavailable is returned, troubleshoot by following What Should I Do If the Result of a Logstash Connectivity Test Is Unavailable?.
Start a Logstash pipeline to migrate data from the source to the destination.
Select Keepalive for long-term data streams in production environments. If the Logstash service stops due to an unexpected error, the system will automatically try to restart it.
Deselect Keepalive for one-time offline data migration tasks. Note that if the source has no data, enabling Keepalive may cause the pipeline to restart repeatedly, which may lead to errors.
After starting data migration pipelines, you can monitor them in the following ways:
In the pipeline list, locate the target pipeline, and click Metric Monitoring in the Operation column to go to the Cloud Eye console, where you can check the metrics to evaluate its status and performance.
When the Events data of a pipeline changes dynamically, the monitoring data changes accordingly. When a pipeline is being started or stopped, or the Events data is stable, the monitoring data remains unchanged.
For details about the metrics supported, see Logstash Pipeline Monitoring Metrics. For how to configure alarms, see Using Cloud Eye to Monitor Clusters.
Above the pipeline list, click Run Logs to check the logs of the Logstash process, which you can use to troubleshoot data parsing errors.
Above the pipeline list, click View to check the start and stop records of the pipelines. This helps track historical operations and facilitate troubleshooting.