Skip to content

Commit 586b37c

Browse files
RichardZhengkayZQKC
authored andcommitted
fix issue:
* [issue #700] Adjust the prompt and replace the Arrays.asList() with the Collections.singletonList()
1 parent d8aa3d6 commit 586b37c

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

km-biz/src/main/java/com/xiaojukeji/know/streaming/km/biz/group/impl/GroupManagerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,7 @@ public Result<Void> resetGroupOffsets(GroupOffsetResetDTO dto, String operator)
172172
}
173173

174174
if (!ConsumerGroupState.EMPTY.equals(description.state()) && !ConsumerGroupState.DEAD.equals(description.state())) {
175-
return Result.buildFromRSAndMsg(ResultStatus.KAFKA_OPERATE_FAILED, String.format("group处于%s, 重置失败(仅Empty情况可重置)", GroupStateEnum.getByRawState(description.state()).getState()));
175+
return Result.buildFromRSAndMsg(ResultStatus.KAFKA_OPERATE_FAILED, String.format("group处于%s, 重置失败(仅Empty | Dead 情况可重置)", GroupStateEnum.getByRawState(description.state()).getState()));
176176
}
177177

178178
// 获取offset

km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public ConsumerGroupDescription getGroupDescription(Long clusterPhyId, String gr
104104

105105
try {
106106
DescribeConsumerGroupsResult describeConsumerGroupsResult = adminClient.describeConsumerGroups(
107-
Arrays.asList(groupName),
107+
Collections.singletonList(groupName),
108108
new DescribeConsumerGroupsOptions().timeoutMs(KafkaConstant.ADMIN_CLIENT_REQUEST_TIME_OUT_UNIT_MS).includeAuthorizedOperations(false)
109109
);
110110

0 commit comments

Comments
 (0)