Class StreamsGroupMember

java.lang.Object

io.confluent.kafkarest.entities.StreamsGroupMember

public abstract class StreamsGroupMember
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamsGroupMember.Builder

Method Summary

Modifier and Type	Method	Description
static StreamsGroupMember.Builder	builder()
static StreamsGroupMember	fromMemberDescription(String clusterId, String streamsGroupId, org.apache.kafka.clients.admin.StreamsGroupMemberDescription description)
abstract StreamsGroupMemberAssignment	getAssignment()
abstract String	getClientId()
abstract String	getClusterId()
abstract Optional<String>	getInstanceId()
abstract boolean	getIsClassic()
abstract int	getMemberEpoch()
abstract String	getMemberId()
abstract String	getProcessId()
abstract String	getStreamsGroupId()
abstract StreamsGroupMemberAssignment	getTargetAssignment()
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()

getMemberId

public abstract String getMemberId()

getInstanceId

public abstract Optional<String> getInstanceId()

getClientId

public abstract String getClientId()

getMemberEpoch

public abstract int getMemberEpoch()

getTopologyEpoch

public abstract int getTopologyEpoch()

getProcessId

public abstract String getProcessId()

getAssignment

public abstract StreamsGroupMemberAssignment getAssignment()

getTargetAssignment

public abstract StreamsGroupMemberAssignment getTargetAssignment()

getIsClassic

public abstract boolean getIsClassic()

builder

public static StreamsGroupMember.Builder builder()

fromMemberDescription

public static StreamsGroupMember fromMemberDescription(String clusterId,
 String streamsGroupId,
 org.apache.kafka.clients.admin.StreamsGroupMemberDescription description)