Page History

{
  "apiKey": TBD,
  "type": "response",
 { "name": "MemberEpoch", "type": "int32", "versions": "0+",
      "about": "The member epoch." },
    { "name": "ShareGroupHeartbeatResponseHeartbeatIntervalMs",
  "validVersionstype": "0int32",
  "flexibleVersionsversions": "0+",
    // Supported errors:"about": "The heartbeat interval in milliseconds." },
  // - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - NOT_COORDINATOR (version 0+)  
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - UNKNOWN_MEMBER_ID (version 0+)
  // - GROUP_MAX_SIZE_REACHED (version 0+)
  { "name": "Assignment", "type": "Assignment", "versions": "0+", "nullableVersions": "0+", "default": "null",
      "about": "null if not provided; the assignment otherwise.", "fields": [
        { "name": "ThrottleTimeMsTopicPartitions", "type": "int32[]TopicPartitions", "versions": "0+",
          "about": "The durationpartitions in milliseconds for whichassigned to the request was throttled due to a quota violation, or zero if the request did not violate any quota." },
member." }
    ]}
  ],
  "commonStructs": [
    { "name": "TopicPartitions", "versions": "0+", "fields": [
        { "name": "ErrorCodeTopicId", "type": "int16uuid", "versions": "0+",
          "about": "The top-level error code, or 0 if there was no error" },
  topic ID." },
        { "name": "ErrorMessagePartitions", "type": "string[]int32", "versions": "0+",
 "nullableVersions": "0+", "default": "null",
      "about": "The top-level error message, or null if there was no error." },
    { "name": "MemberId", "type": "string", "versions": "0+", "nullableVersionspartitions." }
    ]}
  ]
}

{
  "apiKeyabout": NN,
  "type "The top-level error message, or null if there was no error." },
        { "name": "requestGroupId",
  "listenerstype": ["brokerstring"],
  "nameversions": "ShareGroupDescribeRequest0+",
  "validVersionsentityType": "0groupId",
          "flexibleVersionsabout": "0+"The group ID string." },
  "fields": [
      { "name": "GroupIdsGroupState", "type": "[]string", "versions": "0+", "entityType": "groupId",

          "about": "The ids of group state string, or the groups to describeempty string." },
        { "name": "IncludeAuthorizedOperationsGroupEpoch", "type": "boolint32", "versions": "0+",
          "about": "WhetherThe to include authorized operationsgroup epoch." },
    ]
}

{
  "apiKey": NN,
 { "typename": "responseAssignmentEpoch",
  "nametype": "ShareGroupDescribeResponseint32",
  "validVersionsversions": "0+",
  "flexibleVersions        "about": "0+"The assignment epoch." },
   // Supported errors:
  // - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - NOT_COORDINATOR (version 0+)
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - INVALID_GROUP_ID (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  "fields": [
    { "name": "AssignorName", "type": "string", "versions": "0+",
          "about": "The selected assignor." },
        { "name": "ThrottleTimeMsMembers", "type": "int32[]Member", "versions": "0+",
          "about": "The durationmembers.",
 in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota." },
"fields": [
            { "name": "GroupsMemberId", "type": "[]DescribedGroupstring", "versions": "0+",
              "about": "EachThe describedmember groupID." },
      "fields": [
        { "name": "ErrorCodeRackId", "type": "int16string", "versions": "0+", "nullableVersions": "0+", "default": "null",
              "about": "The describemember error, or 0 if there was no errorrack ID." },
            { "name": "ErrorMessageMemberEpoch", "type": "stringint32", "versions": "0+",
 "nullableVersions": "0+", "default": "null",
          "about": "The top-levelcurrent error message, or null if there was no errormember epoch." },
            { "name": "GroupIdClientId", "type": "string", "versions": "0+", "entityType": "groupId",

              "about": "The groupclient ID string." },
            { "name": "GroupStateClientHost", "type": "string", "versions": "0+",
              "about": "The groupclient statehost." string}, or
 the empty string." },
        { "name": "GroupEpochSubscribedTopicNames", "type": "int32[]string", "versions": "0+", "entityType": "topicName",
              "about": "The subscribed grouptopic epochnames." },
            { "name": "AssignmentEpochAssignment", "type": "int32Assignment", "versions": "0+",
              "about": "The current assignment epoch." }
          ]},
        { "name": "AssignorNameAuthorizedOperations", "type": "stringint32", "versions": "0+", "default": "-2147483648",
          "about": "The selected assignor32-bit bitfield to represent authorized operations for this group." },
      ]
    }
  ],
 { "namecommonStructs": "Members", [
    { "typename": "[]MemberTopicPartitions", "versions": "0+",
 "fields": [
       { "aboutname": "The members.",
          "fields": [
            { "name": "MemberId""TopicId", "type": "stringuuid", "versions": "0+",
              "about": "The membertopic ID." },
            { "name": "RackIdTopicName", "type": "string", "versions": "0+", "nullableVersionsentityType": "0+topicName", "default": "null",
              "about": "The membertopic rack IDname." },
            { "name": "MemberEpochPartitions", "type": "[]int32", "versions": "0+",
              "about": "The current member epochpartitions." },
        ]},
    { "name": "ClientIdAssignment", "type": "string", "versions": "0+",
              "about"fields": "The client ID." },
  [
          { "name": "ClientHostTopicPartitions", "type": "string[]TopicPartitions", "versions": "0+",
              "about": "The client host assigned topic-partitions to the member." },
            { "name": "SubscribedTopicNames", "type": "[]string", "versions": "0+", "entityType": "topicName",
              "about": "The subscribed topic names." },
            { "name": "Assignment", "type": "Assignment", "versions": "0+",
              "about": "The current assignment." }
          ]},
        { "name": "AuthorizedOperations", "type": "int32", "versions]}
  ]
}

{
  "apiKey": NN,
 { "name": "MaxBytes", "type": "int32", "versions": "0+", "default": "0x7fffffff", "ignorable": true,
      "about": "The maximum bytes to fetch.  See KIP-74 for cases where this limit may not be honored." },
    { "name": "Topics", "type": "[]FetchTopic", "versions": "0+",
      "about": "The topics to fetch.", "fields": [
      { "name": "TopicId", "type": "requestuuid",
  "listenersversions": ["broker0+"],
  "nameignorable": "ShareFetchRequest"true,
  "validVersionsabout": "0",
The unique "flexibleVersions": "0+"topic ID."},
  "fields": [
    { "name": "GroupIdPartitions", "type": "string[]FetchPartition", "versions": "0+", "nullableVersions": "0+", "default": "null", "entityType
        "about": "groupId",
The partitions    to fetch.", "aboutfields": "The[
  group identifier." },
    { "name": "MemberIdPartitionIndex", "type": "stringint32", "versions": "0+", "nullableVersions": "0+",

          "about": "The memberpartition IDindex." },
        { "name": "ShareSessionEpochPartitionMaxBytes", "type": "int32", "versions": "0+",
          "about": "The current share session epoch: 0 to open a share session; -1 to close it; otherwise increments for consecutive requests maximum bytes to fetch from this partition. 0 when only acknowledgement with no fetching is required. See KIP-74 for cases where this limit may not be honored." },
          { "name": "MaxWaitMsAcknowledgementBatches", "type": "int32[]AcknowledgementBatch", "versions": "0+",
          "about": "TheRecord batches maximum time in milliseconds to wait for the response." },
to acknowledge.", "fields": [
          { "name": "MinBytesFirstOffset", "type": "int32int64", "versions": "0+",
            "about": "TheFirst minimumoffset bytesof tobatch accumulateof inrecords theto responseacknowledge." },
    { "name": "MaxBytes     { "name": "LastOffset", "type": "int32int64", "versions": "0+",
            "about": "Last "defaultoffset (inclusive) of batch of records to acknowledge."},
          { "name": "AcknowledgeTypes", "type": "0x7fffffff[]int8", "ignorableversions": true"0+",
            "about": "TheArray of maximumacknowledge bytestypes to fetch.  See KIP-74 for cases where this limit may not be honored." - 0:Gap,1:Accept,2:Release,3:Reject."}
        ]}
      ]}
    ]},
    { "name": "TopicsForgottenTopicsData", "type": "[]FetchTopicForgottenTopic", "versions": "0+", "ignorable": false,
      "about": "The topicspartitions to fetch remove from this share session.", "fields": [
      { "name": "TopicId", "type": "uuid", "versions": "0+", "ignorable": true, "about": "The unique topic ID."},
      { "name": "Partitions", "type": "[]FetchPartitionint32", "versions": "0+",
        "about": "The partitions indexes to fetchforget.", "fields": [
        { "name }
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "response",
  { "name": "PartitionIndex", "type": "int32", "versions": "0+",
          "about": "The partition index." },
        { "name": "ShareFetchResponseErrorCode",
  "validVersionstype": "0int16",
  "flexibleVersionsversions": "0+",
    // Supported errors for ErrorCode and AcknowledgeErrorCode"about":
 "The //fetch - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - TOPIC_AUTHORIZATION_FAILED (version 0+)
  // - SHARE_SESSION_NOT_FOUND (version 0+)
  // - INVALID_SHARE_SESSION_EPOCH (version 0+) 
  // - UNKNOWN_TOPIC_OR_PARTITION (version 0+)
  // - NOT_LEADER_OR_FOLLOWER (version 0+)
  // - UNKNOWN_TOPIC_ID (version 0+)
  // - INVALID_RECORD_STATE (version 0+) - only for AcknowledgeErrorCode
  // - KAFKA_STORAGE_ERROR (version 0+)
  // - CORRUPT_MESSAGE (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - UNKNOWN_SERVER_ERROR (version 0+)
  "fields": [
error code, or 0 if there was no fetch error." },
        { "name": "ErrorMessage", "type": "string", "versions": "0+", "nullableVersions": "0+", "default": "null",
          "about": "The fetch error message, or null if there was no fetch error." },
        { "name": "AcknowledgeErrorCode", "type": "int16", "versions": "0+",
          "about": "The acknowledge error code, or 0 if there was no acknowledge error." },
        { "name": "ThrottleTimeMsAcknowledgeErrorMessage", "type": "int32string", "versions": "0+", "ignorablenullableVersions": true,
     "0+", "aboutdefault": "null"The,
 duration in milliseconds for which the request was throttled due to a quota violation"about": "The acknowledge error message, or zeronull if thethere requestwas didno not violate any quotaacknowledge error." }, 
        { "name": "ErrorCodeCurrentLeader", "type": "int16LeaderIdAndEpoch", "versions": "0+", "ignorablefields": true,
      "about": "The top-level response error code." },
[
          { "name": "ErrorMessageLeaderId", "type": "stringint32", "versions": "0+", "nullableVersions": "0+", "default": "null",

            "about": "The top-level error message, ID of the current leader or null-1 if therethe wasleader nois errorunknown." },
            { "name": "ResponsesLeaderEpoch", "type": "[]ShareFetchableTopicResponseint32", "versions": "0+",
            "about": "The latest responseknown leader topicsepoch." }
        ]},
 "fields": [
      { "name": "TopicIdRecords", "type": "uuidrecords", "versions": "0+", "ignorablenullableVersions": true"0+", "about": "The uniquerecord topic IDdata."},
        { "name": "PartitionsAcquiredRecords", "type": "[]PartitionDataAcquiredRecords", "versions": "0+",
        "about": "The topicacquired partitionsrecords.", "fields":  [
          { "name": "PartitionIndexFirstOffset", "type":  "int32int64", "versions": "0+",
 "about": "The earliest offset in this batch of  "about": "The partition indexacquired records." },
          { "name": "ErrorCodeLastOffset", "type": "int16int64", "versions": "0+",
          "about": "The fetchlast erroroffset code,of orthis 0batch ifof there was no fetch erroracquired records." },
          { "name": "ErrorMessageDeliveryCount", "type": "stringint16", "versions": "0+", "nullableVersionsabout": "0+", "default": "null",
      The delivery count of this batch of acquired records."}
    "about": "The fetch error message,]}
 or null if there was no]}
 fetch  error." ]},
        { "name": "AcknowledgeErrorCodeNodeEndpoints", "type": "int16[]NodeEndpoint", "versions": "0+",
          "about": "TheEndpoints acknowledgefor errorall code,current orleaders 0enumerated ifin therePartitionData waswith no acknowledge errorerror NOT_LEADER_OR_FOLLOWER." },
 "fields": [
      { "name": "AcknowledgeErrorMessageNodeId", "type": "stringint32", "versions": "0+", "nullableVersions": "0+", "default": "null",
          "aboutmapKey": "The acknowledge error message, or null if there was no acknowledge error." }, 
        { "name": "CurrentLeadertrue, "entityType": "brokerId", "typeabout": "LeaderIdAndEpoch", "versions": "0+", "fields": [The ID of the associated node." },
          { "name": "LeaderIdHost", "type": "int32string", "versions": "0+",
            "about": "The ID of the current leader or -1 if the leader is unknownnode's hostname." },
          { "name": "LeaderEpochPort", "type": "int32", "versions": "0+",
            "about": "The latest known leader epochnode's port." }
        ]},
        { "name": "RecordsRack", "type": "recordsstring", "versions": "0+", "nullableVersions": "0+", "aboutdefault": "The record data."}null",
        { "nameabout": "AcquiredRecords", "type": "[]AcquiredRecords", "versions": "0+", "about": "The acquired records.", "fields":  [
          {"name": "FirstOffset", "type":  "int64", "versions": "0+", "about": "The earliest offset in this batch of acquired records."},
          {The rack of the node, or null if it has not been assigned to a rack." }
    ]}
  ]
}

{
  "apiKey": NN,
     { "name": "AcknowledgementBatches", "type": "request[]AcknowledgementBatch",
  "listenersversions": ["broker0+"],
      "name": "ShareAcknowledgeRequest",
    "validVersionsabout": "0",
Record batches "flexibleVersions": "0+to acknowledge.",
  "fields": [
          { "name": "GroupIdFirstOffset", "type": "stringint64", "versions": "0+", "nullableVersions": "0+", "default": "null", "entityType": "groupId",
      "about": "The group identifier." },
    
            "about": "First offset of batch of records to acknowledge."},
          { "name": "MemberIdLastOffset", "type": "stringint64", "versions": "0+", "nullableVersions": "0+",

            "about": "The member ID." Last offset (inclusive) of batch of records to acknowledge."},
          { "name": "ShareSessionEpochAcknowledgeTypes", "type": "int32[]int8", "versions": "0+",
            "about": "TheArray currentof shareacknowledge sessiontypes epoch:- 0 to open a share session; -1 to close it; otherwise increments for consecutive requests." },
    { "name": "Topics", "type": "[]AcknowledgeTopic", "versions": "0+",
 :Gap,1:Accept,2:Release,3:Reject."}
        ]}
      ]}
    ]}
  ]
}

{
  "apiKeyname": NN"TopicId",
  "type": "responseuuid",
  "nameversions": "ShareAcknowledgeResponse0+",
  "validVersionsignorable": "0"true,
  "flexibleVersionsabout": "0+",
  // Supported errors:
  // - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - TOPIC_AUTHORIZATION_FAILED (version 0+)
  // - UNKNOWN_TOPIC_OR_PARTITION (version 0+)
  // - SHARE_SESSION_NOT_FOUND (version 0+)
  // - INVALID_SHARE_SESSION_EPOCH (version 0+) 
  // - NOT_LEADER_OR_FOLLOWER (version 0+)
  // - UNKNOWN_TOPIC_ID (version 0+)
  // - INVALID_RECORD_STATE (version 0+)
  // - KAFKA_STORAGE_ERROR (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - UNKNOWN_SERVER_ERROR (version 0+)
  "fields": [
The unique topic ID."},
      { "name": "Partitions", "type": "[]PartitionData", "versions": "0+",
        "about": "The topic partitions.", "fields": [
        { "name": "PartitionIndex", "type": "int32", "versions": "0+",
          "about": "The partition index." },
        { "name": "ErrorCode", "type": "int16", "versions": "0+",
          "about": "The error code, or 0 if there was no error." },
        { "name": "ThrottleTimeMsErrorMessage", "type": "int32string", "versions": "0+", "ignorablenullableVersions": true,
      "about"0+", "default": "Thenull",
 duration in milliseconds for which the request was throttled due to a quota violation"about": "The error message, or zeronull if thethere requestwas did not violate any quotano error." },
        { "name": "ErrorCodeCurrentLeader", "type": "int16LeaderIdAndEpoch", "versions": "0+", "ignorablefields": true,[
      "about": "The top level response error code." },
    { "name": "ErrorMessageLeaderId", "type": "stringint32", "versions": "0+", "nullableVersions": "0+", "default": "null",

            "about": "The top-level error message, ID of the current leader or null-1 if therethe wasleader nois errorunknown." },
           { "name": "ResponsesLeaderEpoch", "type": "[]ShareAcknowledgeTopicResponseint32", "versions": "0+",
            "about": "The latest known responseleader topicsepoch.", "fields": [
   }
        ]}
      ]}
    ]},
    { "name": "TopicIdNodeEndpoints", "type": "uuid[]NodeEndpoint", "versions": "0+", "ignorable": true,
      "about": "The unique topic ID."},Endpoints for all current leaders enumerated in PartitionData with error NOT_LEADER_OR_FOLLOWER.", "fields": [
      { "name": "PartitionsNodeId", "type": "[]PartitionDataint32", "versions": "0+",
        "aboutmapKey": true, "entityType"The topic partitions.: "brokerId", "fieldsabout": [
"The ID of the associated node." },
      { "name": "PartitionIndexHost", "type": "int32string", "versions": "0+",
          "about": "The partitionnode's indexhostname." },
        { "name": "ErrorCodePort", "type": "int16int32", "versions": "0+",
          "about": "The error code, or 0 if there was no errornode's port." },
        { "name": "ErrorMessageRack", "type": "string", "versions": "0+", "nullableVersions": "0+", "default": "null",
          "about": "The error messagerack of the node, or null if there was no error it has not been assigned to a rack." },
         { "name]}
  ]
}

{
  "apiKey": NN,
  "type": "response",
  { "name": "Partitions", "type": "[]AlterShareGroupOffsetsResponsePartition", "versions": "0+", "fields": [
        { "name": "AlterShareGroupOffsetsResponsePartitionIndex",
  "validVersionstype": "0int32",
  "flexibleVersionsversions": "0+",
  // Supported errors:
  // - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - NOT_COORDINATOR (version 0+)
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  // - GROUP_NOT_EMPTY (version 0+)
  // - KAFKA_STORAGE_ERROR (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - UNKNOWN_SERVER_ERROR (version 0+)
  "fields": [
    { "name": "ThrottleTimeMs", "type": "int32", "versions "about": "The partition index." },
        { "name": "ErrorCode", "type": "int16", "versions": "0+",
          "about": "The error code, or 0 if there was no error." },
        { "name": "ErrorMessage", "type": "string", "versions": "0+", "nullableVersions": "0+", "ignorable": true, "default": "null",
          "about": "The durationerror inmessage, millisecondsor fornull whichif the requestthere was throttledno due to a quota violation, or zero if the request did not violate any quota." },
    { "name": "Responses", "type":error." }
      ]}
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "request",
  "listeners": ["broker"],
  "name": "DeleteShareGroupOffsetsRequest",
  "validVersions": "0",
  "flexibleVersions": "0+",
  - NOT_COORDINATOR (version 0+)
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  // - GROUP_NOT_EMPTY (version 0+)
  // - KAFKA_STORAGE_ERROR (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - UNKNOWN_SERVER_ERROR (version 0+)
  "fields": [
    { "name": "GroupIdThrottleTimeMs", "type": "stringint32", "versions": "0+", "entityTypeignorable": "groupId"true,
            "about": "The group identifierduration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota." },
    { "name": "TopicsResponses", "type": "[]DeleteShareGroupOffsetsRequestTopicDeleteShareGroupOffsetsResponseTopic", "versions": "0+",
      "about": "The topicsresults tofor deleteeach offsets fortopic.",  "fields": [
      { "name": "TopicName", "type": "string", "versions": "0+", "entityType": "topicName",
        "about": "The topic name." },
      ]}
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "response",
 { "name": "TopicId", "type": "uuid", "versions": "0+", "ignorable": true,
        "about": "The unique topic ID." }
      { "name": "DeleteShareGroupOffsetsResponseErrorCode",
  "validVersionstype": "0int16",
  "flexibleVersionsversions": "0+",
      // Supported errors"about":
 "The //error - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - NOT_COORDINATOR (version 0+)
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  // - GROUP_NOT_EMPTY (version 0+)
  // - KAFKA_STORAGE_ERROR (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - UNKNOWN_SERVER_ERROR (version 0+)
  code, or 0 if there was no error." },
      { "name": "ErrorMessage", "type": "string", "versions": "0+", "nullableVersions": "0+", "ignorable": true, "default": "null",
        "about": "The error message, or null if there was no error." }
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "request",
  "listeners": ["broker"],
  "name": "DescribeShareGroupOffsetsRequest",
  "validVersionsdue to a quota violation, or zero if the request did not violate any quota." },
    { "name": "Responses", "type": "[]DescribeShareGroupOffsetsResponseTopic", "versions": "0+",
  "flexibleVersions      "about": "0+The results for each topic.",
   "fields": [
      { "name": "GroupIdTopicName", "type": "string", "versions": "0+", "entityType": "groupIdtopicName",
              "about": "The grouptopic identifiername." },
      { "name": "TopicsTopicId", "type": "[]DescribeShareGroupOffsetsRequestTopicuuid", "versions": "0+", "ignorable": true,
        "about": "The topics to describe offsets for.",  " unique topic ID." },
      { "name": "Partitions", "type": "[]DescribeShareGroupOffsetsResponsePartition", "versions": "0+", "fields": [
        { "name": "TopicNamePartitionIndex", "type": "stringint32", "versions": "0+",
 "entityType": "topicName",
        "about": "The topicpartition nameindex." },
        { "name": "PartitionsStartOffset", "type": "[]int32int64", "versions": "0+",
          "about": "The partitions share-partition start offset." },
      ]}
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "response",
  "name": "DescribeShareGroupOffsetsResponseErrorCode",
  "validVersionstype": "0int16",
  "flexibleVersionsversions": "0+",
  // Supported errors:
  // - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - NOT_COORDINATOR (version 0+)
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - UNKNOWN_SERVER_ERROR (version 0+)
  "fields": [
    { "name": "ThrottleTimeMs", "type": "int32", "versions "about": "The error code, or 0 if there was no error." },
        { "name": "ErrorMessage", "type": "string", "versions": "0+", "nullableVersions": "0+", "ignorable": true, "default": "null",
          "about": "The durationerror inmessage, millisecondsor fornull whichif the requestthere was throttledno due to a quota violation, or zero if the error." }
      ]}
    ]}
  ]
}

{
  "apiKeyname": NN"ErrorMessage",
  "type": "responsestring",
  "nameversions": "ReadShareGroupStateResponse0+",
  "validVersionsnullableVersions": "0+",
  "flexibleVersionsdefault": "0+null",
   // - NOT_COORDINATOR (version 0+)  
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  // - UNKNOWN_TOPIC_OR_PARTITION (version 0+)
  // - FENCED_LEADER_EPOCH (version 0+)
  // - INVALID_REQUEST (version 0+)
  "fields": [
    "about": "The error message, or null if there was no error." }
        { "name": "ResultsStateEpoch", "type": "[]ReadStateResultint32", "versions": "0+",
          "about": "The read results", "fields": [
 state epoch of the share-partition." },
        { "name": "TopicIdStartOffset", "type": "uuidint64", "versions": "0+",
          "about": "The topic identifier share-partition start offset, which can be -1 if it is not yet initialized." },
        { "name": "PartitionsStateBatches", "type": "[]PartitionResultStateBatch", "versions": "0+",
        "about" : "The results for the partitions.", "fields": [
          { "name": "PartitionFirstOffset", "type": "int32int64", "versions": "0+",
            "about": "The partition indexfirst offset of this state batch." },
          { "name": "ErrorCodeLastOffset", "type": "int16int64", "versions": "0+",
            "about": "The errorlast code,offset orof 0this if there was no errorstate batch." },
          { "name": "ErrorMessageDeliveryState", "type": "stringint8", "versions": "0+",
            "nullableVersionsabout": "0+", "default": "null",
          "about": "The error message, or null if there was no error." }
       The delivery state - 0:Available,2:Acked,4:Archived." },
          { "name": "StateEpochDeliveryCount", "type": "int32int16", "versions": "0+",
            "about": "The state epoch of the share-partitiondelivery count." },
        { "name": "StartOffset", "type": "int64", "versions": "0+",]}
      ]}
    ]}
  ]
}

{
  "apiKeyname": NN"Partition",
  "type": "requestint32",
  "listenersversions": ["broker0+"],
    "name": "WriteShareGroupStateRequest",
      "validVersionsabout": "0",
The partition "flexibleVersionsindex.": "0+"},
   "fields": [
    { "name": "GroupIdStateEpoch", "type": "stringint32", "versions": "0+",
          "about": "The group identifier state epoch of the share-partition." },
        { "name": "TopicsLeaderEpoch", "type": "[]WriteStateDataint32", "versions": "0+",
          "about": "The dataleader epoch forof the topicsshare-partition." },
 "fields": [
      { "name": "TopicIdStartOffset", "type": "uuidint64", "versions": "0+",
          "about": "The topic identifiershare-partition start offset, or -1 if the start offset is not being written." },
        { "name": "PartitionsStateBatches", "type": "[]PartitionDataStateBatch", "versions": "0+",
        "about":  "The data for the partitions.", "fields": [
          { "name": "PartitionFirstOffset", "type": "int32int64", "versions": "0+",
            "about": "The partition index first offset of this state batch." },
          { "name": "StateEpochLastOffset", "type": "int32int64", "versions": "0+",
            "about": "The statelast epochoffset of this thestate share-partitionbatch." },
          { "name": "LeaderEpochDeliveryState", "type": "int32int8", "versions": "0+",
            "about": "The leaderdelivery epochstate of the share-partition.- 0:Available,2:Acked,4:Archived" },
          { "name": "StartOffsetDeliveryCount", "type": "int64int16", "versions": "0+",
            "about": "The share-partition start offset, or -1 if the start offset is not being written." }, delivery count." }
        ]}
      ]}
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "response",
  "{ "name": "WriteShareGroupStateResponsePartition",
  "validVersionstype": "0int32",
  "flexibleVersionsversions": "0+",
  // - NOT_COORDINATOR (version 0+)  
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  // - UNKNOWN_TOPIC_OR_PARTITION (version 0+)
  // - FENCED_LEADER_EPOCH (version 0+)
  // - FENCED_STATE_EPOCH (version 0+)
  // - INVALID_REQUEST (version 0+)
  "fields": [
"about": "The partition index." },
        { "name": "ErrorCode", "type": "int16", "versions": "0+",
          "about": "The error code, or 0 if there was no error." },
        { "name": "ResultsErrorMessage", "type": "[]WriteStateResultstring", "versions": "0+",
      "aboutnullableVersions": "0+"The write results, "default": "null",
 "fields": [         "about": "The error message, or null if there was no error." }
      ]}
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "response",
  "name": "ErrorCode", "type": "int16", "versions": "0+",
          "about": "The error code, or 0 if there was no error." },
        { "name": "DeleteShareGroupStateResponseErrorMessage",
 "type": "validVersions"string", "versions": "0+",
  "flexibleVersionsnullableVersions": "0+", "default": "null",
  // - NOT_COORDINATOR (version 0+)  
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  // - COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  // - UNKNOWN_TOPIC_OR_PARTITION (version 0+)
  // - FENCED_STATE_EPOCH (version 0+)
  // - INVALID_REQUEST (version 0+)
  "fields": [
    { "name": "Results", "type": "[]DeleteStateResult", "versions": "0+",
      "about": "The delete results", "about": "The error message, or null if there was no error." }
      ]}
    ]}
  ]
}

{
  "typename": "dataState",
  "nameversions": "ShareGroupMemberMetadataValue0+",
  "validVersionstype": "0int8",
      "flexibleVersionsabout": "0+",
  "fields": [The member state. See MemberState for the possible values." },
    { "name": "RackIdAssignedPartitions", "versions": "0+", "nullableVersions": "0+", "type": "string[]TopicPartitions",
      "about": "The partitions assigned to (optionalor owned by) rackthis idmember." }
  ],
  "commonStructs": [
    { "name": "ClientIdTopicPartitions", "versions": "0+", "typefields": "string",[
      { "aboutname": "The client id." },
    { "nameTopicId", "type": "ClientHostuuid", "versions": "0+",
 "type": "string",
      "about": "The clienttopic hostId." },
      { "name": "SubscribedTopicNamesPartitions", "versionstype": "0+[]int32", "typeversions": "[]string0+",
        "about": "The partition list of subscribed topic names." Ids." }
    ]}
  ]
}