Class RemoveBrokerTask

java.lang.Object

io.confluent.kafkarest.entities.RemoveBrokerTask

public abstract class RemoveBrokerTask
extends Object

Method Summary

Modifier and Type	Method	Description
static RemoveBrokerTask	create(String clusterId, int brokerId, boolean shutdownScheduled, org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus brokerReplicaExclusionStatus, org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus, org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentStatus)
static RemoveBrokerTask	create(String clusterId, int brokerId, boolean shutdownScheduled, org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus brokerReplicaExclusionStatus, org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus, org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentStatus, short errorCode, String errorMessage)
abstract int	getBrokerId()
abstract org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus	getBrokerReplicaExclusionStatus()
abstract org.apache.kafka.clients.admin.BrokerShutdownStatus	getBrokerShutdownStatus()
abstract String	getClusterId()
abstract Optional<Short>	getErrorCode()
abstract Optional<String>	getErrorMessage()
abstract org.apache.kafka.clients.admin.PartitionReassignmentsStatus	getPartitionReassignmentStatus()
abstract boolean	getShutdownScheduled()

Methods inherited from class java.lang.Object

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

Method Details

getClusterId

public abstract String getClusterId()

getBrokerId

public abstract int getBrokerId()

getShutdownScheduled

public abstract boolean getShutdownScheduled()

getBrokerReplicaExclusionStatus

public abstract org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus getBrokerReplicaExclusionStatus()

getBrokerShutdownStatus

public abstract org.apache.kafka.clients.admin.BrokerShutdownStatus getBrokerShutdownStatus()

getPartitionReassignmentStatus

public abstract org.apache.kafka.clients.admin.PartitionReassignmentsStatus getPartitionReassignmentStatus()

getErrorCode

public abstract Optional<Short> getErrorCode()

getErrorMessage

public abstract Optional<String> getErrorMessage()

create

public static RemoveBrokerTask create(String clusterId,
 int brokerId,
 boolean shutdownScheduled,
 org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus brokerReplicaExclusionStatus,
 org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus,
 org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentStatus)

create

public static RemoveBrokerTask create(String clusterId,
 int brokerId,
 boolean shutdownScheduled,
 org.apache.kafka.clients.admin.BrokerReplicaExclusionStatus brokerReplicaExclusionStatus,
 org.apache.kafka.clients.admin.BrokerShutdownStatus brokerShutdownStatus,
 org.apache.kafka.clients.admin.PartitionReassignmentsStatus partitionReassignmentStatus,
 short errorCode,
 String errorMessage)