Apache RocketMQ is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability. Many customers have used Apache RocketMQ as messaging middleware in their business process.
Now Apache RocketMQ can be monitored by Instana, the first and only fully automated Application Performance Management (APM) solution designed specifically for the challenges of managing microservice and cloud-native applications.
In this blog, we will describe the architecture of the Apache RocketMQ sensor in Instana.
Metrics architecture
The metrics part includes 2 discovery modules (`discovery-rocketmq`, `discovery-rocketmq-service`), an SDK module (`instana-rocketmq-sdk`), and a sensor module (`sensor-rocketmq`). The structure of Apache RocketMQ sensor is as follows:
discovery-rocketmq: The root discovery module. It discovers the Apache RocketMQ.
discovery-rocketmq-service: The Apache RocketMQ service discovery module. It fetches the configuration from the configuration yaml file, and sets all properties to inventory.
instana-rocketmq-sdk: The Apache RocketMQ SDK module. It includes Apache RocketMQ's SDK, and API to get properties and metrics from the Apache RocketMQ cluster.
In the `instana-rocketmq-sdk` module, more APIs can be added later, if needed.
sensor-rocketmq: The RocketMQ sensor module. This is the sensor that collects the metrics by using the RocketMQ SDK, and sends the metrics to the backend.
Discovery architecture
In RocketMQ sensor, two modules are defined for discovery. Because Instana needs to call RocketMQ SDK API to fetch the RocketMQ SDK cluster names and this is a long-running operation, you need to enable RocketMQ SDK first in the `discovery-rocketmq` module. Then, use the `discovery-rocketmq-service` module to call the RocketMQ SDK to fetch the cluster names.
Providers
The RocketMQ sensor includes two providers – brokers and topics. Additional providers can be added to suit customer requirements.
After the sensor is implemented with brokers, the user interface will be as follows:
That is the architecture of the Apache RocketMQ sensor. So which type of sensor can use this architecture? If a sensor is at the beginning of the discovery phase, and needs to call remote API or do other long-run operations, then the sensor can use this architecture.
#Agent