DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Add new fields memberEpoch and protocolisClassic. For classic group member, there is no member epoch, so using Optional for the new field. For isClassic field, if ConsumerGroupDescribeResponse#version is 0, set the field as Optional.empty(). If ConsumerGroupDescribeResponse#version is 1, set the field as Optional.of(value).
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
public class MemberDescription {
private final String memberId;
private final Optional<String> groupInstanceId;
private final String clientId;
private final String host;
private final MemberAssignment assignment;
private final Optional<MemberAssignment> targetAssignment;
private final Optional<Integer> memberEpoch;
private final booleanOptional<Boolean> isClassic;
// ...
/**
* The epoch of the group member.
*/
public Optional<Integer> memberEpoch() {
return memberEpoch;
}
/**
* The flag indicating whether a member is classic.
*/
public BooleanOptional<Boolean> isClassic() {
return isClassic;
}
} |
...