lianetm commented on code in PR #16054:
URL: https://github.com/apache/kafka/pull/16054#discussion_r1626016857
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java:
##########
@@ -166,4 +166,20 @@ void validateOffsetFetch(
* @return true if the state includes, false otherwise.
*/
boolean isInStates(Set<String> statesFilter, long committedOffset);
+
+ /**
+ * Returns true if the member exists.
+ *
+ * @param memberId The member id.
+ *
+ * @return A boolean indicating whether the member exists or not.
+ */
+ boolean hasMember(String memberId);
+
+ /**
+ * Returns number of members in the group.
+ *
+ * @return The number of members.
+ */
+ int numMembers();
Review Comment:
nit: `memberCount` clearer maybe? (I instantly think of partitionCount used
elsewhere, sounds clearer to me)
--
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]
