Class StreamsGroupMemberAssignment

java.lang.Object

io.confluent.kafkarest.entities.StreamsGroupMemberAssignment

public abstract class StreamsGroupMemberAssignment
extends Object

Represents a Kafka Streams Group.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	StreamsGroupMemberAssignment.AssignmentType
static class	StreamsGroupMemberAssignment.Builder

Method Summary

Modifier and Type	Method	Description
static StreamsGroupMemberAssignment.Builder	builder()
static StreamsGroupMemberAssignment	fromMemberAssignment(String clusterId, String streamsGroupId, String memberId, org.apache.kafka.clients.admin.StreamsGroupMemberAssignment assignment)
abstract com.google.common.collect.ImmutableList<StreamsTask>	getActiveTasks()
abstract String	getClusterId()
abstract String	getMemberId()
abstract com.google.common.collect.ImmutableList<StreamsTask>	getStandbyTasks()
abstract String	getStreamsGroupId()
abstract com.google.common.collect.ImmutableList<StreamsTask>	getWarmupTasks()

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

getMemberId

public abstract String getMemberId()

getActiveTasks

public abstract com.google.common.collect.ImmutableList<StreamsTask> getActiveTasks()

getStandbyTasks

public abstract com.google.common.collect.ImmutableList<StreamsTask> getStandbyTasks()

getWarmupTasks

public abstract com.google.common.collect.ImmutableList<StreamsTask> getWarmupTasks()

builder

public static StreamsGroupMemberAssignment.Builder builder()

fromMemberAssignment

public static StreamsGroupMemberAssignment fromMemberAssignment(String clusterId,
 String streamsGroupId,
 String memberId,
 org.apache.kafka.clients.admin.StreamsGroupMemberAssignment assignment)