DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Add new fields memberEpoch and isClassicupgraded. For classic group member, there is no member epoch, so using Optional for the new field. For isClassic upgraded field, if ConsumerGroupDescribeResponse#version is 0, set the field as Optional.empty(). If ConsumerGroupDescribeResponse#version is 1, set the field as the value is like following:
- Classic Group -> Optional.empty
- Consumer Group -> Optional.empty if unknown
- Consumer Group -> Optional.of(false) if classic
- Consumer Group -> Optional.of(
...
- true)
...
- if consumer
| 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 Optional<Boolean> isClassicupgraded;
// ...
/**
* The epoch of the group member.
*/
public Optional<Integer> memberEpoch() {
return memberEpoch;
}
/**
* The flag indicating whether a member is classic.
*/
public Optional<Boolean> isClassicupgraded() {
return isClassicupgraded;
}
} |
RPCs
ConsumerGroupDescribeRequest
...