package  public ShareGroupDescription(String groupId, Collection<MemberDescription> members, ShareGroupState state, Node coordinator);
  public ShareGroupDescription(String groupId, Collection<MemberDescription> members, ShareGroupState state, Node coordinator, Set<AclOperation> authorizedOperations);

  /**
   * The id of the share group.
   */
  public String groupId();

org.apache.kafka.clients.admin;
 
/**
 * The result of the {@link Admin#describeShareGroups(Collection<String>, DescribeShareGroupsOptions)} call.
 * <p>
 * The API of this class is evolving, see {@link Admin} for details.
 */
@InterfaceStability.Evolving
public class DescribeShareGroupsResult {
    /**
     * A list of the members of Return a future which yields all ShareGroupDescription objects, if all the sharedescribes groupsucceed.
     */
    public KafkaFuture<Map<String, Collection<MemberDescription>ShareGroupDescription>> membersall(); {
    }

    /**
     * TheReturn sharea groupmap state,from orgroup UNKNOWNid ifto thefutures statewhich cannotyield begroup parseddescriptions.
     */
    public Map<String, ShareGroupStateKafkaFuture<ShareGroupDescription>> statedescribedGroups();

  /** {
   * The share group coordinator, or null if the coordinator is not known.
   */
  public Node coordinator();

  /**
   * The authorized operations for this group, or null if that information is not known.
   */
  public Set<AclOperation> authorizedOperations();
}

package    org.apache.kafka.client.admin;
 
/**
 * Specification of share group *offsets Returnsto alist futureusing that yields either an exception, or the full set of share group listings.
     */
    public KafkaFuture<Collection<ShareGroupListing>> all(){@link Admin#listShareGroupOffsets(Map<String, ListShareGroupOffsetsSpec>, ListShareGroupOffsetsOptions)}.
 * <p>
 * The API of this class is evolving, see {@link Admin} for details.
 */
@InterfaceStability.Evolving
public class ListShareGroupOffsetsSpec {
    }public ListShareGroupOffsetsSpec();

    /**
   * Set the * Returns a future which yields just the valid listings.
  topic partitions whose offsets are to be listed for a share group.
   */
  ListShareGroupOffsetsSpec  public KafkaFuture<Collection<ShareGroupListing>> valid() {
    }
 
   topicPartitions(Collection<TopicPartition> topicPartitions);

  /**
   * Returns * Returns a future which yields just the errors which occurred.
  the topic partitions whose offsets are to be listed for a share group.
   */
    public KafkaFuture<Collection<Throwable>> errorsCollection<TopicPartition> topicPartitions() {
    }
}

package org.apache.kafka.

package org.apache.kafka.clients.admin;
  
/**
 * The result of the {@link Admin#listGroups(ListGroupsOptions)} call.
 * <p>
 * The API of this class is evolving, see {@link Admin} for details.
 */
@InterfaceStability.Evolving
public class ListGroupsResult {
    /**
     * Returns a future that yields either an exception, or the full set of group listings.
     */
    public KafkaFuture<Collection<GroupListing>> all() {
    }
 
    /**
     * Returns a future which yields just the valid listings.
     */
    public KafkaFuture<Collection<GroupListing>> valid() {
    }
  
    /**
     * Returns a future which yields just the errors which occurred.
     */
    public KafkaFuture<Collection<Throwable>> errors() {
    }
}

package org.apache.kafka.client.admin;
 
import org.apache.kafka.common.ShareGroupState;
 
/**
 * A listing of a group in the cluster.
 * <p>
 * The API of this class is evolving, see {@link Admin} for details.
 */
@InterfaceStability.Evolving
public class GroupListing {
  public GroupListing(String groupId, GroupType type);
 
  /**
   * The id of the group.
   */
  public String groupId();
 
  /**
   * The group type.
   */
  public GroupType type();
}

package org.apache.kafka.client.admin;

import org.apache.kafka.common.GroupType;

/**
 * Options for {@link Admin#listGroups(ListGroupsOptions)}.
 *
 * The API of this class is evolving, see {@link Admin} for details.
 */
@InterfaceStability.Evolving
public class ListGroupsOptions extends AbstractOptions<ListGroupsOptions> {
    /**
     * If types is set, only groups of these types will be returned. Otherwise, all groups are returned.
     */
    public ListGroupsOptions types(Set<GroupType> states);

    /**
     * Return the list of types that are requested or empty if no types have been specified.
     */
    public Set<GroupType> types();
}

{
  "apiKey": TBD,
  "type": "request",
  "listeners": ["broker"],
  "name": "ShareGroupHeartbeatRequest",
  "validVersions": "0",
  "flexibleVersions": "0+",
  "fields": [

{
  "apiKey": TBD,
  "type": "request",
  "listeners": ["broker"],
  "name": "ShareGroupHeartbeatRequest",
  "validVersions": "0",
  "flexibleVersions": "0+",
  "fields": [
      { "name": "GroupId", "type": "string", "versions": "0+", "entityType": "groupId",
        "about": "The group identifier." },
      { "name": "MemberId", "type": "string", "versions": "0+",
        "about": "The member id generated by the coordinator. The member id must be kept during the entire lifetime of the member." },
      { "name": "MemberEpoch", "type": "int32", "versions": "0+",
        "about": "The current member epoch; 0 to join the group; -1 to leave the group." },
      { "name": "RackId", "type": "string", "versions": "0+",  "nullableVersions": "0+", "default": "null",
        "about": "null if not provided or if it didn't change since the last heartbeat; the rack ID of consumer otherwise." },
      { "name": "RebalanceTimeoutMsGroupId", "type": "int32string", "versions": "0+", "defaultentityType": -1"groupId",
        "about": "-1The if it didn't chance since the last heartbeat; the maximum time in milliseconds that the coordinator will wait on the member to revoke its partitions otherwisegroup identifier." },
      { "name": "SubscribedTopicNamesMemberId", "type": "[]string", "versions": "0+", "nullableVersions": "0+", "defaultversions": "null0+",
        "about": "null if it didn't change since the last heartbeat; the subscribed topic names otherwise." }
  ]
}

{
  { "nameapiKey": "MemberId"TBD,
  "type": "stringresponse",
  "versionsname": "0+ShareGroupHeartbeatResponse",
  "nullableVersionsvalidVersions": "0+",
  "defaultflexibleVersions": "null0+",
  // Supported   "about"errors:
 "The member// id generated by the coordinator. Only provided when the member joins with MemberEpoch == 0." },
    { "name": "MemberEpoch", "type": "int32", "versions": "0+",
      "about": "The member epoch." },- GROUP_AUTHORIZATION_FAILED
  // - NOT_COORDINATOR
  // - COORDINATOR_NOT_AVAILABLE
  // - COORDINATOR_LOAD_IN_PROGRESS
  // - INVALID_REQUEST
  // - UNKNOWN_MEMBER_ID
  // - GROUP_MAX_SIZE_REACHED
  "fields": [
    { "name": "HeartbeatIntervalMsThrottleTimeMs", "type": "int32", "versions": "0+",
      "about": "The heartbeatduration interval in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota." },
    { "name": "AssignmentErrorCode", "type": "Assignmentint16", "versions": "0+", "nullableVersions": "0+", "default": "null",
      "about": "nullThe iftop-level noterror provided;code, theor assignment otherwise.", "fields": [
   0 if there was no error" },
     { "name": "ErrorErrorMessage", "type": "int8string", "versions": "0+",
 "nullableVersions": "0+", "default": "null",
      "about": "The assignedtop-level error message, or null if there was no error." },
        { "name": "AssignedTopicPartitionsMemberId", "type": "[]TopicPartitionsstring", "versions": "0+",
 "nullableVersions": "0+", "default": "null",
      "about": "The partitions assigned tomember ID generated by the coordinator. Only provided when the member." }
joins with MemberEpoch == 0." ]},
   ],
 { "commonStructsname": [
    { "name"MemberEpoch", "type": "TopicPartitionsint32", "versions": "0+",
      "fieldsabout": [
"The member epoch." },
     { "name": "TopicIdHeartbeatIntervalMs", "type": "uuidint32", "versions": "0+",
          "about": "The heartbeat interval topicin IDmilliseconds." },
        { "name": "PartitionsAssignment", "type": "[]int32Assignment", "versions": "0+",
 "nullableVersions": "0+", "default": "null",
      "about": "Thenull partitions." }
    ]}
  ]
}

{
  "apiKey": NN,
  "type": "request",
  "listeners": ["broker"],
  "name": "ShareGroupDescribeRequest",
  "validVersions": "0",
  "flexibleVersions": "0+",
  "fields": [
    { "name": "ThrottleTimeMsGroupIds", "type": "int32[]string", "versions": "0+", "entityType": "groupId",
      "about": "The durationids in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.of the groups to describe" },
    { "name": "GroupsIncludeAuthorizedOperations", "type": "[]DescribedGroupbool", "versions": "0+",
      "about": "Whether to include authorized operations." }
  ]
}

{
  "apiKey": NN,
  "type": "response",
  Each described group.",
      "fields": [
        { "name": "ErrorCodeShareGroupDescribeResponse",
  "typevalidVersions": "int160",
  "versionsflexibleVersions": "0+",
  // Supported errors:
  // - GROUP_AUTHORIZATION_FAILED (version 0+)
  // - NOT_COORDINATOR (version 0+)
  // - COORDINATOR_NOT_AVAILABLE (version 0+)
  //  "about": "The describe error, or 0 if there was no error." },- COORDINATOR_LOAD_IN_PROGRESS (version 0+)
  // - INVALID_REQUEST (version 0+)
  // - INVALID_GROUP_ID (version 0+)
  // - GROUP_ID_NOT_FOUND (version 0+)
  "fields": [
        { "name": "ErrorMessageThrottleTimeMs", "type": "stringint32", "versions": "0+", "nullableVersions": "0+", "default
      "about": "null",
The duration in milliseconds for which the request was throttled "about": "The top-level error messagedue to a quota violation, or nullzero if there was no error the request did not violate any quota." },
        { "name": "GroupIdGroups", "type": "string[]DescribedGroup", "versions": "0+",
      "entityTypeabout": "groupIdEach described group.",
          "aboutfields": "The group ID string." },[
        { "name": "GroupStateErrorCode", "type": "stringint16", "versions": "0+",
          "about": "The group state string, or the empty string." },
        { "name": "GroupEpoch", "type": "int32", "versions": "0+",
          "about": "The group epochdescribe error, or 0 if there was no error." },
        { "name": "AssignmentEpochErrorMessage", "type": "int32string", "versions": "0+", "nullableVersions": "0+", "default": "null",
          "about": "The assignment epoch top-level error message, or null if there was no error." },
        { "name": "AssignorNameGroupId", "type": "string", "versions": "0+", "entityType": "groupId",
          "about": "The group selectedID assignorstring." },
        { "name": "MembersGroupState", "type": "[]Memberstring", "versions": "0+",
          "about": "The members.",
group state string, or the      "fields": [
    empty string." },
        { "name": "MemberIdGroupEpoch", "type": "stringint32", "versions": "0+",
              "about": "The membergroup IDepoch." },
            { "name": "InstanceIdAssignmentEpoch", "type": "stringint32", "versions": "0+", "nullableVersions": "0+", "default": "null",
              "about": "The memberassignment instance IDepoch." },
            { "name": "RackIdAssignorName", "type": "string", "versions": "0+", "nullableVersions": "0+", "default": "null",
              "about": "The member rackselected IDassignor." },
            { "name": "MemberEpochMembers", "type": "int32[]Member", "versions": "0+",
              "about": "The current member epoch." },members.",
          "fields": [
            { "name": "ClientIdMemberId", "type": "string", "versions": "0+",
              "about": "The clientmember ID." },
            { "name": "ClientHostInstanceId", "type": "string", "versions": "0+", "nullableVersions": "0+", "default": "null",
              "about": "The member clientinstance hostID." },
            { "name": "SubscribedTopicNamesRackId", "type": "[]string", "versions": "0+", "entityType"nullableVersions": "0+", "default": "topicNamenull",
              "about": "The subscribedmember topicrack namesID." },
            { "name": "AssignmentMemberEpoch", "type": "Assignmentint32", "versions": "0+",
              "about": "The current member assignmentepoch." },
          ]},
        { "name": "AuthorizedOperationsClientId", "type": "int32string", "versions": "0+", "default": "-2147483648",
          "about": "32-bit bitfield to represent authorized operations for this group." }
      ]
    }
  ],
  "commonStructs": [
    { "name": "TopicPartitions", "versions "about": "0+", "fields": [
The client ID." },
            { "name": "TopicIdClientHost", "type": "uuidstring", "versions": "0+",
              "about": "The topicclient IDhost." },
            { "name": "TopicNameSubscribedTopicNames", "type": "[]string", "versions": "0+", "entityType": "topicName",
              "about": "The subscribed topic namenames." },
            { "name": "PartitionsAssignment", "type": "[]int32Assignment", "versions": "0+",
              "about": "The current partitionsassignment." }
          ]},
        { "name": "AssignmentAuthorizedOperations", "type": "int32", "versions": "0+", "fieldsdefault": [
"-2147483648",
         { "nameabout": "TopicPartitions", "type32-bit bitfield to represent authorized operations for this group." }
      ]
    }
  ],
  "commonStructs": [
    { "name": "[]TopicPartitions", "versions": "0+",
        "aboutfields": "The assigned topic-partitions to the member." }, [
      { "name": "ErrorTopicId", "type": "int8uuid", "versions": "0+",
        "about": "The assignedtopic errorID." },
      { "name": "MetadataVersionTopicName", "type": "int32string", "versions": "0+", "entityType": "topicName",
        "about": "The assignortopic metadata versionname." },
      { "name": "MetadataBytesPartitions", "type": "bytes[]int32", "versions": "0+",
        "about": "The assignor metadata bytespartitions." }
    ]},
  ]
}

{
  "apiKey": NN,
  "type": "request",
  "listeners": ["broker"],
  provided or if it didn't change since the last fetch; the member id generated by the coordinator otherwise." },
    { "name": "AcquisitionTimeoutMsShareFetchRequest",
  "typevalidVersions": "int320",
  "versionsflexibleVersions": "0+",
  "defaultfields": -1,[
    {  "aboutname": "-1 if it didn't chance since the last fetch; the maximum time in milliseconds that the fetched records are acquired for the consumer." },
    { "name": "MaxWaitMs", "type": "int32", "versions": "0+GroupId", "type": "string", "versions": "0+", "nullableVersions": "0+", "default": "null", "entityType": "groupId",
      "about": "The maximum time in milliseconds to wait for the responsenull if not provided or if it didn't change since the last fetch; the group identifier otherwise." },
    { "name": "MinBytesMemberId", "type": "int32string", "versions": "0+", "nullableVersions": "0+",
      "about": "The minimum bytes to accumulate in the responsemember ID." },
    { "name": "MaxBytes", "type": "int32", "versionsname": "0+MaxWaitMs", "defaulttype": "0x7fffffffint32", "ignorableversions": true"0+",
      "about": "The maximum bytestime toin fetch.milliseconds to Seewait KIP-74 for cases where this limit may not be honoredthe response." },
    { "name": "SessionIdMinBytes", "type": "int32", "versions": "0+", "default": "0", "ignorable": true,
      "about": "The share session ID minimum bytes to accumulate in the response." },
    { "name": "SessionEpochMaxBytes", "type": "int32", "versions": "0+", "default": "-10x7fffffff", "ignorable": true,
      "about": "The maximum sharebytes sessionto epoch,fetch. which isSee usedKIP-74 for ordering requests in a session cases where this limit may not be honored." },
    { "name": "Topics", "type": "[]FetchTopic", "versions": "0+",
      "about": "The topics to fetch.", "fields": [
      { "name": "TopicId", "type": "uuid", "versions": "0+", "ignorable": true, "about": "The unique topic ID"},
      { "name": "Partitions", "type": "[]FetchPartition", "versions": "0+",
        "about": "The partitions to fetch.", "fields": [
        { "name": "PartitionIndex", "type": "int32", "versions": "0+",
          "about": "The partition index." },
        { "name": "CurrentLeaderEpoch", "type": "int32", "versions": "0+", "default": "-1", "ignorable": true,
          "about": "The current leader epoch of the partition." },
        { "name": "PartitionMaxBytes", "type": "int32", "versions": "0+",
          "about": "The maximum bytes to fetch from this partition.  See KIP-74 for cases where this limit may not be honored." },
        { "name": "AcknowledgementBatches", "type": "[]AcknowledgementBatch", "versions": "0+",
          "about": "Record batches to acknowledge.", "fields": [
          { "name": "StartOffset", "type": "int64", "versions": "0+",
            "about": "Start offset of batch of records to acknowledge."},
          { "name": "LastOffset", "type": "int64", "versions": "0+",
            "about": "Last offset (inclusive) of batch of records to acknowledge."},
          { "name": "GapOffsets", "type": "[]int64", "versions": "0+",
            "about": "Array of offsets in this range which do not correspond to records."},
          { "name": "AcknowledgeType", "type": "int8", "versions": "0+", "default": "0",
            "about": "The type of acknowledgement - 0:Accept,1:Release,2:Reject."}
        ]}
    ]},
    { "name": "ForgottenTopicsData", "type": "[]ForgottenTopic", "versions": "0+", "ignorable": false,
      "about": "In an incremental fetch request, the partitions to remove.", "fields": [
      { "name": "TopicId", "type": "uuid", "versions": "0+", "ignorable": true, "about": "The unique topic ID"},
      { "name": "Partitions", "type": "[]int32", "versions": "0+",
        "about": "The partitions indexes to forget." }
    ]}
  ]
}