public class KafkaMessageBatch
extends java.lang.Object
KafkaMessages retrieved by a fetch operation| Constructor and Description |
|---|
KafkaMessageBatch(Partition partition,
java.util.List<KafkaMessage> messages,
long highWatermark) |
| Modifier and Type | Method and Description |
|---|---|
long |
getHighWatermark() |
java.util.List<KafkaMessage> |
getMessages() |
Partition |
getPartition() |
void |
setHighWatermark(long highWatermark) |
void |
setMessages(java.util.List<KafkaMessage> messages) |
void |
setPartition(Partition partition) |
public KafkaMessageBatch(Partition partition, java.util.List<KafkaMessage> messages, long highWatermark)
public Partition getPartition()
public void setPartition(Partition partition)
public java.util.List<KafkaMessage> getMessages()
public void setMessages(java.util.List<KafkaMessage> messages)
public long getHighWatermark()
public void setHighWatermark(long highWatermark)