Aias00 opened a new pull request, #10673:
URL: https://github.com/apache/rocketmq/pull/10673
### Summary
- Replace full logging in with a compact command summary.
- Preserve useful runtime diagnostics such as command type, nonce,
transaction ID, client type, and channel context.
- Add coverage to ensure message payloads are not included in telemetry
command summaries.
### Motivation
Closes #10672.
Proxy gRPC telemetry write failures can happen after a client disconnects or
when the telemetry stream is completed. The previous warning logs serialized
the full protobuf command, which can include message payloads for commands such
as and .
### Tests
- [INFO] Scanning for projects...
[INFO]
[INFO] -----------------< org.apache.rocketmq:rocketmq-proxy
>-----------------
[INFO] Building rocketmq-proxy 5.5.0 5.5.0
[INFO] from pom.xml
[INFO] --------------------------------[ jar
]---------------------------------
[WARNING] 1 problem was encountered while building the effective model for
org.javassist:javassist:jar:3.20.0-GA during dependency collection step for
project (use -X to see details)
[INFO]
[INFO] --- enforcer:1.4.1:enforce (enforce-ban-circular-dependencies) @
rocketmq-proxy ---
[INFO]
[INFO] --- checkstyle:3.2.0:check (validate) @ rocketmq-proxy ---
[INFO] 开始检查……
检查完成。
[INFO] You have 0 Checkstyle violations.
[INFO]
[INFO] --- jacoco:0.8.5:prepare-agent (default-prepare-agent) @
rocketmq-proxy ---
[INFO] argLine set to
-javaagent:/Users/aias/.m2/repository/org/jacoco/org.jacoco.agent/0.8.5/org.jacoco.agent-0.8.5-runtime.jar=destfile=/Users/aias/Work/github/rocketmq/proxy/target/jacoco.exec
[INFO]
[INFO] --- remote-resources:1.5:process (process-resource-bundles) @
rocketmq-proxy ---
[INFO]
[INFO] --- resources:3.0.2:resources (default-resources) @ rocketmq-proxy ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 1 resource
[INFO] Copying 3 resources
[INFO]
[INFO] --- flatten:1.7.2:flatten (flatten) @ rocketmq-proxy ---
[INFO] Generating flattened POM of project
org.apache.rocketmq:rocketmq-proxy:jar:5.5.0...
[INFO]
[INFO] --- compiler:3.5.1:compile (default-compile) @ rocketmq-proxy ---
[INFO] Nothing to compile - all classes are up to date
[INFO]
[INFO] >>> spotbugs:4.2.2:check (check) > :spotbugs @ rocketmq-proxy >>>
[INFO]
[INFO] --- spotbugs:4.2.2:spotbugs (spotbugs) @ rocketmq-proxy ---
[INFO] Fork Value is false
[java] JVM args ignored when same JVM is used.
[INFO] Done SpotBugs Analysis....
[INFO]
[INFO] <<< spotbugs:4.2.2:check (check) < :spotbugs @ rocketmq-proxy <<<
[INFO]
[INFO]
[INFO] --- spotbugs:4.2.2:check (check) @ rocketmq-proxy ---
[INFO] BugInstance size is 0
[INFO] Error size is 0
[INFO] No errors/warnings found
[INFO]
[INFO] --- resources:3.0.2:testResources (default-testResources) @
rocketmq-proxy ---
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 9 resources
[INFO] Copying 3 resources
[INFO]
[INFO] --- compiler:3.5.1:testCompile (default-testCompile) @ rocketmq-proxy
---
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 67 source files to
/Users/aias/Work/github/rocketmq/proxy/target/test-classes
[WARNING] bootstrap class path not set in conjunction with -source 8
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[114,49]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[193,49]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[206,49]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[233,49]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[262,45]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[288,41]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[316,41]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[476,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[505,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[534,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[563,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[592,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[621,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[650,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[679,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[708,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[736,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[769,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[798,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[827,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[856,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[885,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[915,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[944,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java:[973,57]
defaultString(java.lang.String,java.lang.String) in
org.apache.commons.lang3.StringUtils has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelTest.java:[63,42]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannelTest.java:[65,42]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManagerTest.java:[60,44]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManagerTest.java:[78,44]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManagerTest.java:[97,44]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManagerTest.java:[117,44]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManagerTest.java:[131,49]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidatorTest.java:[107,62]
randomAlphanumeric(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidatorTest.java:[109,62]
randomAlphanumeric(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivityTest.java:[112,35]
MapSortField in com.alibaba.fastjson2.JSONWriter.Feature has been deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannelTest.java:[35,51]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java:[119,42]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java:[193,57]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java:[215,57]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java:[275,61]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java:[313,61]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java:[380,57]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[WARNING]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerTest.java:[403,49]
randomAlphabetic(int) in org.apache.commons.lang3.RandomStringUtils has been
deprecated
[INFO]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivityTest.java:
Some input files use unchecked or unsafe operations.
[INFO]
/Users/aias/Work/github/rocketmq/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivityTest.java:
Recompile with -Xlint:unchecked for details.
[INFO]
[INFO] --- surefire:2.19.1:test (default-test) @ rocketmq-proxy ---
-------------------------------------------------------
T E S T S
-------------------------------------------------------
Running org.apache.rocketmq.proxy.grpc.v2.channel.GrpcClientChannelTest
20:26:00,811 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.classic.LoggerContext[default] -
This is logback-classic version 1.3.5-rocketmq
20:26:00,821 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.classic.LoggerContext[default] -
Found resource [rmq.logback-test.xml] at
[file:/Users/aias/Work/github/rocketmq/proxy/target/test-classes/rmq.logback-test.xml]
20:26:00,901 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler
- Processing appender named [CONSOLE]
20:26:00,901 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderModelHandler
- About to instantiate appender of type
[org.apache.rocketmq.logging.ch.qos.logback.core.ConsoleAppender]
20:26:00,927 |-WARN in
org.apache.rocketmq.logging.ch.qos.logback.core.ConsoleAppender[CONSOLE] - This
appender no longer admits a layout as a sub-component, set an encoder instead.
20:26:00,927 |-WARN in
org.apache.rocketmq.logging.ch.qos.logback.core.ConsoleAppender[CONSOLE] - To
ensure compatibility, wrapping your layout in LayoutWrappingEncoder.
20:26:00,927 |-WARN in
org.apache.rocketmq.logging.ch.qos.logback.core.ConsoleAppender[CONSOLE] - See
also http://logback.qos.ch/codes.html#layoutInsteadOfEncoder for details
20:26:00,927 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler
- Setting level of logger [org.apache.rocketmq] to ERROR
20:26:00,927 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler
- Setting additivity of logger [org.apache.rocketmq] to false
20:26:00,927 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler
- Attaching appender named [CONSOLE] to Logger[org.apache.rocketmq]
20:26:00,927 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.RootLoggerModelHandler
- Setting level of ROOT logger to ERROR
20:26:00,927 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler
- Attaching appender named [CONSOLE] to Logger[ROOT]
20:26:00,927 |-INFO in
org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.DefaultProcessor@6ee99964
- End of configuration.
20:26:00,928 |-INFO in
org.apache.rocketmq.common.logging.JoranConfiguratorExt@257ef9ed - Registering
current configuration as safe fallback point
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 1.654 sec -
in org.apache.rocketmq.proxy.grpc.v2.channel.GrpcClientChannelTest
Results :
Tests run: 2, Failures: 0, Errors: 0, Skipped: 0
[INFO]
[INFO] --- jacoco:0.8.5:report (report) @ rocketmq-proxy ---
[INFO] Loading execution data file
/Users/aias/Work/github/rocketmq/proxy/target/jacoco.exec
[INFO] Analyzed bundle 'rocketmq-proxy 5.5.0' with 203 classes
[WARNING] Classes in bundle 'rocketmq-proxy 5.5.0' do no match with
execution data. For report generation the same class files must be used as at
runtime.
[WARNING] Execution data for class
org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity does not
match.
[WARNING] Execution data for class
org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter
does not match.
[WARNING] Execution data for class
org/apache/rocketmq/proxy/processor/MessagingProcessor does not match.
[WARNING] Execution data for class
org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity$ReceiveMessageQueueSelector
does not match.
[INFO]
------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO]
------------------------------------------------------------------------
[INFO] Total time: 10.694 s
[INFO] Finished at: 2026-07-28T20:26:02-07:00
[INFO]
------------------------------------------------------------------------
Result: BUILD SUCCESS; 2 tests passed; checkstyle reported 0 violations. The
run emits existing JaCoCo instrumentation warnings under the local JDK, but
tests and build completed successfully.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
