public class KafkaFetchFtpsRequest extends KafkaRequest
broker
Constructor and Description |
---|
KafkaFetchFtpsRequest(int uuid,
String topic,
int partition,
NodeConfig broker)
Constructs new FetchFtpsRequest.
|
getBroker, toString
getCreateTimestamp, getPartition, getTopic, getUuid, name
public KafkaFetchFtpsRequest(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 contact