Class StreamsGroupData

java.lang.Object

io.confluent.kafkarest.entities.v3.Resource

io.confluent.kafkarest.entities.v3.StreamsGroupData

public abstract class StreamsGroupData
extends io.confluent.kafkarest.entities.v3.Resource

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamsGroupData.Builder

Nested classes/interfaces inherited from class io.confluent.kafkarest.entities.v3.Resource

io.confluent.kafkarest.entities.v3.Resource.Metadata, io.confluent.kafkarest.entities.v3.Resource.Relationship

Method Summary

Modifier and Type	Method	Description
static StreamsGroupData.Builder	builder()
static StreamsGroupData	fromJson(String kind, io.confluent.kafkarest.entities.v3.Resource.Metadata metadata, String clusterId, String streamsGroupId, StreamsGroup.State state, io.confluent.kafkarest.entities.v3.Resource.Relationship members, int memberCount, int groupEpoch, int targetAssignmentEpoch, int topologyEpoch, io.confluent.kafkarest.entities.v3.Resource.Relationship subtopologies, int subtopologyCount)
static StreamsGroupData.Builder	fromStreamsGroup(StreamsGroup streamsGroup)
abstract String	getClusterId()
abstract int	getGroupEpoch()
abstract int	getMemberCount()
abstract io.confluent.kafkarest.entities.v3.Resource.Relationship	getMembers()
abstract StreamsGroup.State	getState()
abstract String	getStreamsGroupId()
abstract io.confluent.kafkarest.entities.v3.Resource.Relationship	getSubtopologies()
abstract int	getSubtopologyCount()
abstract int	getTargetAssignmentEpoch()
abstract int	getTopologyEpoch()

Methods inherited from class io.confluent.kafkarest.entities.v3.Resource

getKind, getMetadata

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getClusterId

public abstract String getClusterId()

getStreamsGroupId

public abstract String getStreamsGroupId()

getState

public abstract StreamsGroup.State getState()

getMembers

public abstract io.confluent.kafkarest.entities.v3.Resource.Relationship getMembers()

getMemberCount

public abstract int getMemberCount()

getGroupEpoch

public abstract int getGroupEpoch()

getTargetAssignmentEpoch

public abstract int getTargetAssignmentEpoch()

getTopologyEpoch

public abstract int getTopologyEpoch()

getSubtopologies

public abstract io.confluent.kafkarest.entities.v3.Resource.Relationship getSubtopologies()

getSubtopologyCount

public abstract int getSubtopologyCount()

builder

public static StreamsGroupData.Builder builder()

fromStreamsGroup

public static StreamsGroupData.Builder fromStreamsGroup(StreamsGroup streamsGroup)

fromJson

public static StreamsGroupData fromJson(String kind,
 io.confluent.kafkarest.entities.v3.Resource.Metadata metadata,
 String clusterId,
 String streamsGroupId,
 StreamsGroup.State state,
 io.confluent.kafkarest.entities.v3.Resource.Relationship members,
 int memberCount,
 int groupEpoch,
 int targetAssignmentEpoch,
 int topologyEpoch,
 io.confluent.kafkarest.entities.v3.Resource.Relationship subtopologies,
 int subtopologyCount)