Class StreamsGroup

java.lang.Object

io.confluent.kafkarest.entities.StreamsGroup

public abstract class StreamsGroup
extends Object

Represents a Kafka Streams Group.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamsGroup.Builder
static enum	StreamsGroup.State

Method Summary

Modifier and Type	Method	Description
static StreamsGroup.Builder	builder()
static StreamsGroup	fromStreamsGroupDescription(String clusterId, org.apache.kafka.clients.admin.StreamsGroupDescription description)
abstract String	getClusterId()
abstract int	getGroupEpoch()
abstract int	getMemberCount()
abstract com.google.common.collect.ImmutableList<StreamsGroupMember>	getMembers()
abstract StreamsGroup.State	getState()
abstract String	getStreamsGroupId()
abstract com.google.common.collect.ImmutableList<StreamsGroupSubtopology>	getSubtopologies()
abstract int	getSubtopologyCount()
abstract int	getTargetAssignmentEpoch()
abstract int	getTopologyEpoch()

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()

getGroupEpoch

public abstract int getGroupEpoch()

getTargetAssignmentEpoch

public abstract int getTargetAssignmentEpoch()

getTopologyEpoch

public abstract int getTopologyEpoch()

getMemberCount

public abstract int getMemberCount()

getSubtopologyCount

public abstract int getSubtopologyCount()

getMembers

public abstract com.google.common.collect.ImmutableList<StreamsGroupMember> getMembers()

getSubtopologies

public abstract com.google.common.collect.ImmutableList<StreamsGroupSubtopology> getSubtopologies()

builder

public static StreamsGroup.Builder builder()

fromStreamsGroupDescription

public static StreamsGroup fromStreamsGroupDescription(String clusterId,
 org.apache.kafka.clients.admin.StreamsGroupDescription description)