...
| Code Block |
|---|
| language | java |
|---|
| title | ConsumerConfig.java |
|---|
|
public static final STRING MEMBER_NAME = "member_A"; // default empty String
|
Changes will be applied to join group request and offset commit request to include member name and other settings:
| Code Block |
|---|
JoinGroupRequest =>
GroupId => String
SESSION_TIMEOUT => INT32
REBALANCE_TIMEOUT => INT32
STATIC_REGISTRATION_TIMEOUT => INT32 // NEW
STATIC_EXPANSION_TIMEOUT => INT32 // NEW
MEMBER_NAME => INT32 // NEW
PROTOCOL_TYPE => STRING
GROUP_PROTOCOLS => ARRAY |
| Code Block |
|---|
| language | java |
|---|
| title | JoinGroupRequest.java |
|---|
|
public static Schema[] schemaVersions() {
return new Schema[] {JOIN_GROUP_REQUEST_V0, JOIN_GROUP_REQUEST_V1, JOIN_GROUP_REQUEST_V2, JOIN_GROUP_REQUEST_V3, JOIN_GROUP_REQUEST_V4};
} |
...