In addition to Weibo, there is also WeChat
Please pay attention
WeChat public account
Shulou
2025-04-03 Update From: SLTechnology News&Howtos shulou NAV: SLTechnology News&Howtos > Internet Technology >
Share
Shulou(Shulou.com)06/02 Report--
This article will explain in detail how to use Apache SkyWalking for message link tracking and performance monitoring of Apache Pulsar. The content of the article is of high quality, so the editor shares it for you as a reference. I hope you will have some understanding of the relevant knowledge after reading this article.
⚙️ builds Pulsar agent plug-in
The Apache Pulsar agent plug-in will be officially released in SkyWalking 6.5.0. The latest version of SkyWalking is 6.4.0, so you need to build the Pulsar agent plug-in from the SkyWalking source code. 1. Download the SkyWalking source code and build the Pulsar agent plug-in.
$git clone https://github.com/apache/skywalking.git $cd skywalking $git submodule init $git submodule update $. / mvnw clean package-DskipTests2. Extract the apache-skywalking-apm-bin.tar.gz. After unzipping, all packages will be in the apm-dist/target folder. The Pulsar agent plug-in is in the agent/plugins folder. $tar-xf apache-skywalking-apm-bin.tar.gz Congratulations, you have successfully built the Pulsar agent plug-in. ⚙️ starts SkyWalking background service if you have installed SkyWalking background service, you can ignore this step; if not, please refer to (https://github.com/apache/skywalking/blob/master/docs/en/setup/backend/backend-ui-setup.md#deploy-backend-and-ui) for installation).
? Tip:
If you are running SkyWalking background service and Pulsar broker on the same machine, you need to change the network service port of SkyWalking or Pulsar broker (by default, they both use port 8080).
To change the network service port of Skywalking UI, see https://github.com/apache/skywalking/blob/master/docs/en/setup/backend/ui-setup.md.
If you need to change the network service port of Pulsar broker, you can change it by editing the conf/broker.conf configuration file.
⚙️ downloads the test case code settings and opens the Pulsar agent plug-in
This example uses the test cases of the Pulsar agent integration test, and you can also write test cases that meet your needs. 1. Download the SkyWalking integration test source code. After downloading the $git clone https://github.com/SkyAPMTest/agent-auto-integration-testcases.git, the code base contains the pulsar-scenario project. two。 Import the pulsar-scenario project to IDE. This example takes Intelli IDEA as an example. As shown in the following figure, the pulsar-scenario project is a Spring Boot application that contains a CaseController. 3. Set up the Pulsar agent plug-in.
Before starting the Spring Boot application, you need to set up the Pulsar agent plug-in. ? Tip: to set Java agent and its properties, see here. By default, pulsar-scenario projects use port 8082. The VM option in the following figure is:-javaagent:/apm-dist/target/apache-skywalking-apm-bin/agent/skywalking-agent.jar-DSW_AGENT_COLLECTOR_BACKEND_SERVICES=:11800-DSW_AGENT_NAME=pulsar-demo-Dservice.url=pulsar://:6650
⚙️ test and view the results in SkyWalking
Now that you have prepared the required environment, the next step is to simulate the request and view the results. After executing the following HTTP request, some message link tracking and monitoring data will be uploaded to SkyWalking. At this point, you can view it in SkyWalking UI. $curl http://localhost:8082/pulsar-scenario/case/pulsar-case
? Panel view
The panel shows 2 endpoint, 1 service, and 1 MQ.
? Topology view
The topology view shows the following information: the user sends a request to the service (that is, your test network application)
The service sends messages to and receives messages from Pulsar broker
? Link tracking View
The link tracking view displays the details of each request. Currently, the Pulsar agent plug-in supports three types of span: producer sending message span, recording producer sending message. Producer sends message callback span: record that the message has been sent.
Consumer receiving message span: records that the consumer receives the message.
On how to use Apache SkyWalking for message link tracking and performance monitoring of Apache Pulsar is shared here, I hope the above content can be of some help to you, can learn more knowledge. If you think the article is good, you can share it for more people to see.
Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.
Views: 0
*The comments in the above article only represent the author's personal views and do not represent the views and positions of this website. If you have more insights, please feel free to contribute and share.
Continue with the installation of the previous hadoop.First, install zookooper1. Decompress zookoope
"Every 5-10 years, there's a rare product, a really special, very unusual product that's the most un
Public static synchronized List getVerifyListInfo (byte [] b) {List signatureVerificat
© 2024 shulou.com SLNews company. All rights reserved.