All Classes and Interfaces
Class
Description
Used to consume incoming
PushReplicationEvents for a given destination broker and
(eventually) to build an AppendRecords out of them.Used to consume incoming
PushReplicationEvents for a given partition replica and
(eventually) to build a AppendRecordsRequestData.PartitionData out of them.A
MultiBufferRecords that can send the buffers of multiple memory records in a
single Send.A wrapper on top of the HdrHistogram API.
Describes the desired thread safety guarantees of the internally maintained HdrHistogram
ValueRecorder implementation.A compound stat providing various metrics based on an internally maintained
HdrHistogram.Used for proactively replicating (pushing) records for partitions led by this broker to its
follower brokers.
Manages the buffering, tracking and pushing of records written to partition replicas that
should be replicated via push replication.
A generic event representing a partition replica change that should be processed for the
purposes of push replication.
A payload carrying a single offset value.
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.Enumerates the different types of push replication events.
Identifies a push replication session for some partition replica.
A tracker that allows calculating the total memory taken by the ref-counted objects it
tracks.
Enumerates the valid values for the
ReplicationConfig.REPLICATION_MODE_PROP config property.The per-partition-replica state maintained for push replication.
The different replication modes in which a partition replica can be in.
Manages replication mode transitions for push replication.