Package io.confluent.kafka.replication.push.buffer

package io.confluent.kafka.replication.push.buffer

Related Packages

Package	Description
io.confluent.kafka.replication.push
io.confluent.kafka.replication.push.metrics

Class	Description
BufferingAppendRecordsBuilder	Used to consume incoming PushReplicationEvents for a given destination broker and (eventually) to build an AppendRecords out of them.
BufferingPartitionDataBuilder	Used to consume incoming PushReplicationEvents for a given partition replica and (eventually) to build a AppendRecordsRequestData.PartitionData out of them.
BufferingPartitionDataBuilder.MultiMemoryRecords	A MultiBufferRecords that can send the buffers of multiple memory records in a single Send.
PushReplicationEvent<T>	A generic event representing a partition replica change that should be processed for the purposes of push replication.
PushReplicationEvent.OffsetPayload	A payload carrying a single offset value.
PushReplicationEvent.RecordsPayload	A payload carrying an AbstractRecords representing some records already appended on the partition replica leader, their append offset, and the high watermark value at the time of creating the records.
PushReplicationEvent.Type	Enumerates the different types of push replication events.
RefCountingMemoryTracker<K>	A tracker that allows calculating the total memory taken by the ref-counted objects it tracks.