THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public class FindCoordinatorRequest extends AbstractRequest { private static final String COORDINATOR_KEY_KEY_NAME = "coordinator_key"; private static final String COORDINATOR_TYPE_KEY_NAME = "coordinator_type"; private static final String COORDINATOR_GROUPIDS_KEY_NAME = "coordinator_groupIds" private static final Schema FIND_COORDINATOR_REQUEST_V0 = new Schema(GROUP_ID); private static final Schema FIND_COORDINATOR_REQUEST_V1 = new Schema( new Field("coordinator_key", STRING, "Id to use for finding the coordinator (for groups, this is the groupId, " + "for transactional producers, this is the transactional id)"), new Field("coordinator_type", INT8, "The type of coordinator to find (0 = group, 1 = transaction)")); /** * The version number is bumped to indicate that on quota violation brokers send out responses before throttling. */ private static final Schema FIND_COORDINATOR_REQUEST_V2 = FIND_COORDINATOR_REQUEST_V1; private static final Schema FIND_COORDINATOR_REQUEST_V3 = new Schema( new Field(COORDINATOR_GROUPIDS_KEY_NAME, new ArrayOf(DESCRIBE_GROUPS_RESPONSE_MEMBER_V0STRING), "All the coordinator ids " + "for this request")); ... private final Map<String, String> groupIds; // Use to store (coordinator_key, coordinator_type) pair ... |
...