Class BufferingPartitionDataBuilder.MultiMemoryRecords

java.lang.Object

org.apache.kafka.common.record.MultiBufferRecords

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

All Implemented Interfaces:

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

Enclosing class:

BufferingPartitionDataBuilder

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

A MultiBufferRecords that can send the buffers of multiple memory records in a single Send.

See Also:

• MultiBufferRecords

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

MultiMemoryRecords

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

Method Details

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()