lizhimins commented on code in PR #9048:
URL: https://github.com/apache/rocketmq/pull/9048#discussion_r1884966726
##########
broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java:
##########
@@ -296,6 +308,76 @@ private void appendAck(final AckMessageRequestHeader
requestHeader, final BatchA
}
}
+ private void appendAckNew(final AckMessageRequestHeader requestHeader,
final BatchAck batchAck,
+ final RemotingCommand response, final Channel channel, String
brokerName) throws RemotingCommandException {
+
+ if (requestHeader != null && batchAck == null) {
+ String[] extraInfo =
ExtraInfoUtil.split(requestHeader.getExtraInfo());
+ brokerName = ExtraInfoUtil.getBrokerName(extraInfo);
Review Comment:
removed
--
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: commits-unsubscr...@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
