public class Message extends Object
Constructor and Description |
---|
Message(int uuid,
String topic,
int partition)
Constructs new Request.
|
Modifier and Type | Method and Description |
---|---|
Date |
getCreateTimestamp() |
int |
getPartition() |
String |
getTopic() |
org.apache.kafka.common.TopicPartition |
getTopicPartition() |
int |
getUuid() |
String |
name() |
public Message(int uuid, String topic, int partition)
uuid
- unique integer ID for this requesttopic
- topic being operated uponpartition
- partition number being operated uponpublic int getUuid()
public Date getCreateTimestamp()
public String getTopic()
public int getPartition()
public String name()
public org.apache.kafka.common.TopicPartition getTopicPartition()