Kris20030907 commented on code in PR #10115:
URL: https://github.com/apache/rocketmq/pull/10115#discussion_r2866964721
##########
client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java:
##########
@@ -2257,6 +2258,28 @@ public void deleteSubscriptionGroup(final String addr,
final String groupName, f
throw new MQClientException(response.getCode(), response.getRemark());
}
+ public void deleteConsumerOffset(final String addr, final String group,
final String topic,
+ final long timeoutMillis)
+ throws RemotingException, InterruptedException, MQClientException {
+ DeleteConsumerOffsetRequestHeader requestHeader = new
DeleteConsumerOffsetRequestHeader();
+ requestHeader.setConsumerGroup(group);
+ requestHeader.setTopic(topic);
+ RemotingCommand request =
RemotingCommand.createRequestCommand(RequestCode.DELETE_CONSUMER_OFFSET,
requestHeader);
+
+ RemotingCommand response =
this.remotingClient.invokeSync(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(),
addr),
+ request, timeoutMillis);
+ assert response != null;
Review Comment:
This is just an optimization point. Without adding the `-ea` parameter, the
assert logic here will not take effect. People who are unaware of this feature
might be misled when troubleshooting, because IDEA automatically adds this
parameter, which may differ from the actual environment.
--
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]
