public abstract class KafkaRequest extends MessageRequest
Modifier and Type | Field and Description |
---|---|
protected int |
brokerID
Broker ID to contact.
|
Constructor and Description |
---|
KafkaRequest(int uuid,
String topic,
int partition,
int brokerID)
Constructs a new KafkaRequest.
|
Modifier and Type | Method and Description |
---|---|
int |
getBrokerID() |
String |
toString() |
getCreateTimestamp, getPartition, getTopic, getUuid, name
public KafkaRequest(int uuid, String topic, int partition, int brokerID)
uuid
- unique integer ID for this requesttopic
- topic being operated uponpartition
- partition number being operated uponbrokerID
- broker ID to contact