(rocketmq-clients) branch master updated: [Java] Fix opentelemetry-instrumentation-compatibility CI (#1185)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 652a140d [Java] Fix opentelemetry-instrumentation-compatibility CI 
(#1185)
652a140d is described below

commit 652a140da436ff1299f26f32a7fb8b404f395ab9
Author: qianye <wuxingcan....@alibaba-inc.com>
AuthorDate: Tue Jan 27 19:56:10 2026 +0800

    [Java] Fix opentelemetry-instrumentation-compatibility CI (#1185)
---
 .github/workflows/java_build.yml                                      | 4 ++--
 .../apache/rocketmq/client/java/example/SimpleConsumerExample.java    | 2 ++
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/.github/workflows/java_build.yml b/.github/workflows/java_build.yml
index 31d1649e..0376f239 100644
--- a/.github/workflows/java_build.yml
+++ b/.github/workflows/java_build.yml
@@ -64,7 +64,7 @@ jobs:
       # Replace the RocketMQ client version.
       - name: Replace RocketMQ Client Version
         run: |
-          sed -i 
's/org\.apache\.rocketmq:rocketmq-client-java:[^"]*/org.apache.rocketmq:rocketmq-client-java:${{
 steps.get_version.outputs.version }}/' 
instrumentation/rocketmq/rocketmq-client/rocketmq-client-5.0/testing/build.gradle.kts
+          sed -i 
's/org\.apache\.rocketmq:rocketmq-client-java:[^"]*/org.apache.rocketmq:rocketmq-client-java:${{
 steps.get_version.outputs.version }}/' 
instrumentation/rocketmq/rocketmq-client-5.0/testing/build.gradle.kts
       # Use JDK 17.
       - name: Use JDK 21
         uses: actions/setup-java@v3
@@ -75,4 +75,4 @@ jobs:
       # Build the rocketmq opentelemetry test.
       - name: Build OpenTelemetry Instrumentation Test
         run: |
-          ./gradlew 
:instrumentation:rocketmq:rocketmq-client:rocketmq-client-5.0:javaagent:test -i
+          ./gradlew 
:instrumentation:rocketmq:rocketmq-client-5.0:javaagent:test -i
diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java
index d18ddde0..8139749c 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java
@@ -72,6 +72,8 @@ public class SimpleConsumerExample {
             // Set the subscription for the consumer.
             .setSubscriptionExpressions(Collections.singletonMap(topic, 
filterExpression))
             .build();
+        // You can calculate the number of messages that need to be received 
each time
+        // and the invisible time based on the estimated processing time of 
each message.
         // Max message num for each long polling.
         int maxMessageNum = 16;
         // Set message invisible duration after it is received.