diff --git a/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java b/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java index 8e7d9d8..4ca76f5 100644 --- a/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java +++ b/java/e2e/src/main/java/org/apache/rocketmq/frame/BaseOperate.java @@ -148,7 +148,7 @@ protected static String getGroupId(String methodName) { // prepare consumer group CreateGroupRequest request = CreateGroupRequest.newBuilder() .setName(groupId) - .setMaxRetryAttempt(16) + .setMaxDeliveryAttempt(16) .setGroupType(GroupType.GROUP_TYPE_STANDARD) .build(); CreateGroupReply reply = createConsumerGroup(request).join(); @@ -161,7 +161,7 @@ protected static String getOrderlyGroupId(String methodName) { String groupId = String.format("GID_%s_%s", methodName, RandomUtils.getStringWithCharacter(6)); CreateGroupRequest request = CreateGroupRequest.newBuilder() .setName(groupId) - .setMaxRetryAttempt(16) + .setMaxDeliveryAttempt(16) .setGroupType(GroupType.GROUP_TYPE_FIFO) .build(); CreateGroupReply reply = createConsumerGroup(request).join();