Class ShareConsumer

java.lang.Object

io.confluent.kafkarest.entities.ShareConsumer

public abstract class ShareConsumer
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ShareConsumer.Builder

Method Summary

Modifier and Type	Method	Description
static ShareConsumer.Builder	builder()
static ShareConsumer	fromMemberDescription(String clusterId, String consumerGroupId, org.apache.kafka.clients.admin.ShareMemberDescription description)
abstract com.google.common.collect.ImmutableList<io.confluent.kafkarest.entities.Partition>	getAssignedPartitions()
abstract String	getClientId()
abstract String	getClusterId()
abstract String	getConsumerGroupId()
abstract String	getConsumerId()
abstract String	getHost()
abstract Optional<String>	getInstanceId()

Methods inherited from class java.lang.Object

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

Method Details

getClusterId

public abstract String getClusterId()

getConsumerGroupId

public abstract String getConsumerGroupId()

getConsumerId

public abstract String getConsumerId()

getInstanceId

public abstract Optional<String> getInstanceId()

getClientId

public abstract String getClientId()

getHost

public abstract String getHost()

getAssignedPartitions

public abstract com.google.common.collect.ImmutableList<io.confluent.kafkarest.entities.Partition> getAssignedPartitions()

builder

public static ShareConsumer.Builder builder()

fromMemberDescription

public static ShareConsumer fromMemberDescription(String clusterId,
 String consumerGroupId,
 org.apache.kafka.clients.admin.ShareMemberDescription description)