Flume Channel Test
Apache Flume has three main components - Source, Channel and Sink. A channel is a transient store that receives events from the source and buffers them until they are consumed by sinks. It acts as a bridge between the sources and the sinks. These channels are fully transactional, and they can work with any number of sources and sinks. Some examples of channels are the JDBC channel, the File system channel, the Memory channel, etc.
Given the channel is responsible for storing the data for intermediate duration and acts as a buffer for the critical data, it could lead to significant data loss in case the channel malfunctions or is unavailable. That is the reason it is absolutely important to monitor the channel to fully capture its operations and highlight if there is an issue or error because of which data loss may occur. The metrics and insights from monitoring can help administrators identify and act on potential problems even before they propagate into failure.
This test monitors every Flume channel and collects key metrics like write fails, fill percentage, etc. These metrics help administrators understand the current performance of the system and alerts when it requires intervention to fix the problems.
Target of the test : Apache Flume
Agent deploying the test : An internal agent
Outputs of the test : One set of results for each channel in Apache Flume agent being monitored.
Parameter | Description |
---|---|
Test period |
How often should the test be executed. |
Host |
The IP address of the target server that is being monitored. |
Port |
The port number through which the Apache Flume communicates. The default port is 8080. |
FLUME JMX Remote Port |
Specify the port at which the JMX listens for requests from remote hosts. Ensure that you specify the same port that you configured in theflume-env.ps1file, in JVM_OPTS variable. |
JMX Username, Password and Confirm Password |
These parameters appear only if the Mode is set to JMX. If JMX requires authentication only (but no security), then ensure that the user and password parameters are configured with the credentials of a user with read-write access to JMX. To know how to create this user, refer to Configuring the eG Agent to Support JMX Authentication. Confirm the password by retyping it in the Confirm Password text box. |
Measurement | Description | Measurement Unit | Interpretation |
---|---|---|---|
Channel fill capacity |
Indicates the capacity of this channel as configured in Flume agent configuration file. |
Number |
Channel capacity refers to the maximum number of events that a channel is configured to hold. |
Channel fill percentage |
Indicates the percentage of capacityof this channel utilized out of total available capacity. |
Percentage |
If the channel fill percentage is high, there is high chance of write failures to this channel in next few minutes, administrators should start thinking about reducing the load of the channel. |
Number of events currently present in a channel |
Indicates the total number of events currently existing in the channel. |
Batches/Sec |
If the number of events is high, it could be reaching the channel capacity. |
Event attempt to write |
Indicates the number of event that sources have attempted to write to this channel in a sec. |
Events/Sec |
A high rate is justified if most of the write attempts are successful. |
Event written and committed |
Indicates the number of events that sources have successfully written and committed to this channel in a sec. |
Events/Sec |
A high rate of successful rights to the sink is always preferred but administrators have to keep an eye on the rate over a number of measurements. |
Event read attempt from channel |
Indicates the number of events that sinks which are connected to this channel, have attempted to read in a sec. |
Events/Sec |
The number should be high which means most of the events are successfully written to the channel. |
Event successfully reads from channel |
Indicates the number of events that sinks which are connected to this channel, have successfully read in a sec. |
Events/Sec |
If there are frequent channel read fails, administrators should investigate the issue. |