@@ -866,7 +866,7 @@ StreamsGroup getOrCreateStreamsGroup(
866
866
* @param groupId The group ID.
867
867
*
868
868
* @return A StreamsGroup.
869
- * @throws GroupIdNotFoundException if the group does not exist
869
+ * @throws GroupIdNotFoundException if the group does not exist or is not a streams group.
870
870
*
871
871
* Package private for testing.
872
872
*/
@@ -1172,8 +1172,8 @@ ShareGroup getOrMaybeCreatePersistedShareGroup(
1172
1172
* @param groupId The group id.
1173
1173
* @param committedOffset A specified committed offset corresponding to this shard.
1174
1174
*
1175
- * @return A ConsumerGroup .
1176
- * @throws GroupIdNotFoundException if the group does not exist or is not a consumer group.
1175
+ * @return A ShareGroup .
1176
+ * @throws GroupIdNotFoundException if the group does not exist or is not a share group.
1177
1177
*/
1178
1178
public ShareGroup shareGroup (
1179
1179
String groupId ,
@@ -1588,7 +1588,7 @@ private static void throwIfStreamsGroupHeartbeatRequestIsInvalid(
1588
1588
}
1589
1589
} else if (request .memberEpoch () == LEAVE_GROUP_STATIC_MEMBER_EPOCH ) {
1590
1590
throwIfNull (request .instanceId (), "InstanceId can't be null." );
1591
- } else if (request .memberEpoch () < LEAVE_GROUP_STATIC_MEMBER_EPOCH ) {
1591
+ } else if (request .memberEpoch () < LEAVE_GROUP_STATIC_MEMBER_EPOCH ) {
1592
1592
throw new InvalidRequestException (String .format ("MemberEpoch is %d, but must be greater than or equal to -2." ,
1593
1593
request .memberEpoch ()));
1594
1594
}
@@ -3418,7 +3418,6 @@ private static void filterTopicDescribeAuthorizedTopics(
3418
3418
resolvedRegexes .forEach ((__ , topicNames ) -> topicNames .removeAll (deniedTopics ));
3419
3419
}
3420
3420
3421
-
3422
3421
/**
3423
3422
* Handle the result of the asynchronous tasks which resolves the regular expressions.
3424
3423
*
0 commit comments