Class StreamsTask

java.lang.Object

io.confluent.kafkarest.entities.StreamsTask

public abstract class StreamsTask
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamsTask.Builder

Method Summary

Modifier and Type	Method	Description
static StreamsTask.Builder	builder()
static StreamsTask	fromTaskIds(String clusterId, String streamsGroupId, String memberId, org.apache.kafka.clients.admin.StreamsGroupMemberAssignment.TaskIds taskIds)
abstract String	getClusterId()
abstract String	getMemberId()
abstract com.google.common.collect.ImmutableList<Integer>	getPartitionIds()
abstract String	getStreamsGroupId()
abstract String	getSubtopologyId()

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

getSubtopologyId

public abstract String getSubtopologyId()

getPartitionIds

public abstract com.google.common.collect.ImmutableList<Integer> getPartitionIds()

builder

public static StreamsTask.Builder builder()

fromTaskIds

public static StreamsTask fromTaskIds(String clusterId,
 String streamsGroupId,
 String memberId,
 org.apache.kafka.clients.admin.StreamsGroupMemberAssignment.TaskIds taskIds)