public abstract class KafkaRequest extends MessageRequest
Constructor and Description |
---|
KafkaRequest(int uuid,
String topic,
int partition,
NodeConfig broker)
Constructs a new KafkaRequest.
|
Modifier and Type | Method and Description |
---|---|
NodeConfig |
getBroker() |
String |
toString() |
getCreateTimestamp, getPartition, getTopic, getTopicPartition, getUuid, name
public KafkaRequest(int uuid, String topic, int partition, NodeConfig broker)
uuid
- unique integer ID for this requesttopic
- topic being operated uponpartition
- partition number being operated uponbroker
- broker to contactpublic NodeConfig getBroker()