io.confluent.kafka.replication.push.buffer

Class BufferingPartitionDataBuilder.PartitionRecords

java.lang.Object

org.apache.kafka.common.record.MultiBufferRecords

io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder.PartitionRecords

All Implemented Interfaces:

org.apache.kafka.common.record.BaseRecords, org.apache.kafka.common.record.TransferableRecords

Enclosing class:

BufferingPartitionDataBuilder

public static final class BufferingPartitionDataBuilder.PartitionRecords
extends org.apache.kafka.common.record.MultiBufferRecords

A MultiBufferRecords that can send the buffers of multiple memory records in a single org.apache.kafka.common.network.Send.

See Also:

MultiBufferRecords

Constructor Summary

Constructors

Constructor and Description
PartitionRecords(List<org.apache.kafka.common.record.MemoryRecords> memoryRecords)

Method Summary

Modifier and Type	Method and Description
ByteBuffer[]	buffers()
List<org.apache.kafka.common.record.MemoryRecords>	memoryRecords()
void	release()
int	sizeInBytes()

Methods inherited from class org.apache.kafka.common.record.MultiBufferRecords

toSend, writeTo

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionRecords

public PartitionRecords(List<org.apache.kafka.common.record.MemoryRecords> memoryRecords)

Method Detail

memoryRecords

public List<org.apache.kafka.common.record.MemoryRecords> memoryRecords()

buffers

public ByteBuffer[] buffers()

Specified by:

buffers in class org.apache.kafka.common.record.MultiBufferRecords

sizeInBytes

public int sizeInBytes()

release

public void release()