public static final class BufferingPartitionDataBuilder.MultiMemoryRecords
extends org.apache.kafka.common.record.MultiBufferRecords
MultiBufferRecords
that can send the buffers of multiple memory records in a
single org.apache.kafka.common.network.Send
.MultiBufferRecords
Constructor and Description |
---|
MultiMemoryRecords(List<org.apache.kafka.common.record.MemoryRecords> memoryRecords) |
Modifier and Type | Method and Description |
---|---|
ByteBuffer[] |
buffers() |
List<org.apache.kafka.common.record.MemoryRecords> |
memoryRecords() |
void |
release() |
int |
sizeInBytes() |
public MultiMemoryRecords(List<org.apache.kafka.common.record.MemoryRecords> memoryRecords)
public List<org.apache.kafka.common.record.MemoryRecords> memoryRecords()
public ByteBuffer[] buffers()
buffers
in class org.apache.kafka.common.record.MultiBufferRecords
public int sizeInBytes()
public void release()