Class | Description |
---|---|
BufferingAppendRecordsBuilder |
Used to consume incoming
PushReplicationEvent s for a given destination broker and
(eventually) to build an AppendRecords out of them. |
BufferingPartitionDataBuilder |
Used to consume incoming
PushReplicationEvent s 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 org.apache.kafka.common.network.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. |
RefCountingMemoryTracker<K> |
A tracker that allows calculating the total memory taken by the ref-counted objects it
tracks.
|
Enum | Description |
---|---|
PushReplicationEvent.Type |
Enumerates the different types of push replication events.
|