public class KafkaTierPartitionStatusRequest extends KafkaRequest
broker
Constructor and Description |
---|
KafkaTierPartitionStatusRequest(int uuid,
String topic,
int partition,
NodeConfig broker,
List<NodeConfig> replicaBrokers,
int expectedStatus)
Creates new KafkaTierPartitionStatusRequest.
|
Modifier and Type | Method and Description |
---|---|
int |
getExpectedStatus() |
List<NodeConfig> |
getReplicaBrokerIDs() |
String |
toString() |
getBroker
getCreateTimestamp, getPartition, getTopic, getUuid, name
public KafkaTierPartitionStatusRequest(int uuid, String topic, int partition, NodeConfig broker, List<NodeConfig> replicaBrokers, int expectedStatus)
uuid
- unique integer ID for this requesttopic
- topic being operated uponpartition
- partition number being operated uponbroker
- broker to contactexpectedStatus
- expected status of tier partitionpublic List<NodeConfig> getReplicaBrokerIDs()
public int getExpectedStatus()
public String toString()
toString
in class KafkaRequest