public class KafkaMessageBatch
extends java.lang.Object
KafkaMessage
s retrieved by a fetch operationConstructor 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)