| 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.PartitionRecords |
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. |
| PushReplicationEvent.TransitionRecordsPayload | |
| 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.
|