Class ShareGroup

java.lang.Object
io.confluent.kafkarest.entities.ShareGroup
public abstract class ShareGroup extends Object
Represents a Kafka Share Group.

  • Method Details

    • getClusterId

      public abstract String getClusterId()

    • getShareGroupId

      public abstract String getShareGroupId()

    • getState

      public abstract ShareGroup.State getState()

    • getCoordinator

      public abstract io.confluent.kafkarest.entities.Broker getCoordinator()

    • getConsumers

      public abstract com.google.common.collect.ImmutableList<ShareConsumer> getConsumers()

    • getGroupEpoch

      public abstract int getGroupEpoch()

    • getTargetAssignmentEpoch

      public abstract int getTargetAssignmentEpoch()

    • getAuthorizedOperations

      public abstract Set<org.apache.kafka.common.acl.AclOperation> getAuthorizedOperations()

    • getAssignedTopicPartitions

      public abstract com.google.common.collect.ImmutableList<org.apache.kafka.common.TopicPartition> getAssignedTopicPartitions()

    • getAssignedTopicPartitionsWithOffsets

      public abstract com.google.common.collect.ImmutableList<TopicPartitionWithOffset> getAssignedTopicPartitionsWithOffsets()

    • builder

      public static ShareGroup.Builder builder()

    • fromShareGroupDescription

      public static ShareGroup fromShareGroupDescription(String clusterId, org.apache.kafka.clients.admin.ShareGroupDescription description)