Index (replication 8.2.1-ce API)

A B C D E F G H I K L M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values

A

addHighWatermarkUpdate(PushSession, long) - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder: Updates the high watermark if the push session matches the initial push session and the new high watermark has a higher value
addLogStartOffsetUpdate(PushSession, long) - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder: Updates the log start offset if the push session matches the initial push session and the new log start offset has a higher value
addMemoryRecords(PushSession, MemoryRecords, long) - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder: Enqueues a new set of memory records to the request if the push session matches the initial push session and the size of the memory records doesn't bump the total bytes counter of the builder over its limit and potentially update the high watermark of the builder.
appendOffset() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.RecordsPayload

B

BufferingAppendRecordsBuilder - Class in io.confluent.kafka.replication.push.buffer: Used to consume incoming PushReplicationEvents for a given destination broker and (eventually) to build an AppendRecords out of them.
BufferingAppendRecordsBuilder(int, long, ReplicationConfig, RefCountingMemoryTracker<MemoryRecords>, Time, PushReplicationManagerMetrics) - Constructor for class io.confluent.kafka.replication.push.buffer.BufferingAppendRecordsBuilder
BufferingPartitionDataBuilder - Class in io.confluent.kafka.replication.push.buffer: Used to consume incoming PushReplicationEvents for a given partition replica and (eventually) to build a AppendRecordsRequestData.PartitionData out of them.
BufferingPartitionDataBuilder.MultiMemoryRecords - Class in io.confluent.kafka.replication.push.buffer: A MultiBufferRecords that can send the buffers of multiple memory records in a single Send.
buffers() - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder.MultiMemoryRecords
build() - Method in class io.confluent.kafka.replication.push.buffer.BufferingAppendRecordsBuilder: Creates an AppendRecordsRequestData from all the buffered data in the builder.

C

canTransitionTo(ReplicationState.Mode, long) - Method in class io.confluent.kafka.replication.push.ReplicationStateMetadata: Follower replication mode transition proposal requires the proposed session ID to be incremented when the leader requests a transition back to PULL.
clear() - Method in class io.confluent.kafka.replication.push.buffer.BufferingAppendRecordsBuilder: Clears all data buffered in the partitions builders of this request builder, including untracking all buffered MemoryRecords.
close() - Method in class io.confluent.kafka.replication.push.buffer.RefCountingMemoryTracker: Closing the tracker clears up its internal state.
close() - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
CONCURRENT_READS - Enum constant in enum class io.confluent.kafka.replication.push.metrics.HdrHistogram.ThreadSafetyMode: Used when writing to the histogram is done by a single thread, but reading from the histogram can be done concurrently.
CONCURRENT_READS_AND_WRITES - Enum constant in enum class io.confluent.kafka.replication.push.metrics.HdrHistogram.ThreadSafetyMode: Used when both reading from and writing to the histogram can be done concurrently.
CONFLUENT_REPLICATION_PREFIX - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
CONFLUENT_REPLICATION_PREFIX_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
count(long) - Method in class io.confluent.kafka.replication.push.metrics.HdrHistogram
countDown(K) - Method in class io.confluent.kafka.replication.push.buffer.RefCountingMemoryTracker: Decrements with 1 the ref count of the given ref-counted memory-occupying object.

D

destinationBrokerEpoch() - Method in class io.confluent.kafka.replication.push.buffer.BufferingAppendRecordsBuilder
destinationBrokerId() - Method in class io.confluent.kafka.replication.push.buffer.BufferingAppendRecordsBuilder: The ID of the destination broker for which this builder creates AppendRecords requests.

E

enablePushForInternalTopics() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
equals(Object) - Method in class io.confluent.kafka.replication.push.ReplicationStateMetadata
EVENT_PROCESSING_FAILURE_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
EVENT_PROCESSING_FAILURE_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
EVENT_QUEUE_PROCESSING_TIME_MS_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
EVENT_QUEUE_PROCESSING_TIME_MS_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
eventCreatedTimeMs() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent
eventQueueProcessingTimeMetric(String) - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics

F

FINAL_REPLICATION_SESSION_ID - Static variable in class io.confluent.kafka.replication.push.ReplicationStateMetadata: The final replication session ID.
FOLLOWERS_NOT_CATCHING_UP_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
FOLLOWERS_NOT_CATCHING_UP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
forHighWatermarkUpdate(TopicIdPartition, int, long, long) - Static method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent: Creates a new event of type PushReplicationEvent.Type.HWM_UPDATE with its payload being an PushReplicationEvent.OffsetPayload containing the updated high watermark.
forLogStartOffsetUpdate(TopicIdPartition, int, long, long) - Static method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent: Creates a new event of type PushReplicationEvent.Type.LSO_UPDATE with its payload being an PushReplicationEvent.OffsetPayload containing the updated log start offset.
forRecords(TopicIdPartition, int, AbstractRecords, long, long) - Static method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent: Creates a new event of type PushReplicationEvent.Type.MEMORY_RECORDS with its payload being a PushReplicationEvent.RecordsPayload containing the given records and offsets.
forStartPush(TopicIdPartition, PushSession, long) - Static method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent: Creates a new event of type PushReplicationEvent.Type.START_PUSH with its payload being the given PushSession.
forStopPush(TopicIdPartition, int, PushSessionEndReason, long) - Static method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent: Creates a new event of type PushReplicationEvent.Type.STOP_PUSH with its payload being a PushSessionEndReason.

G

getPusher(TopicIdPartition, int) - Method in class io.confluent.kafka.replication.push.PushManagerImpl

H

hashCode() - Method in class io.confluent.kafka.replication.push.ReplicationStateMetadata
HdrHistogram - Class in io.confluent.kafka.replication.push.metrics: A wrapper on top of the HdrHistogram API.
HdrHistogram(long, HdrHistogram.ThreadSafetyMode, long, int) - Constructor for class io.confluent.kafka.replication.push.metrics.HdrHistogram
HdrHistogram(HdrHistogram.ThreadSafetyMode, long, int) - Constructor for class io.confluent.kafka.replication.push.metrics.HdrHistogram
HdrHistogram.ThreadSafetyMode - Enum Class in io.confluent.kafka.replication.push.metrics: Describes the desired thread safety guarantees of the internally maintained HdrHistogram ValueRecorder implementation.
HWM_UPDATE - Enum constant in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type

I

id() - Method in interface io.confluent.kafka.replication.push.Pusher: An identifier of this pusher thread expected to be between 0 and N-1 where N is the total number of pusher threads on this broker.
incrementEventProcessingFailureCount() - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
incrementFollowersNotCatchingUpCount() - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
incrementPushSessionEndCount(PushSessionEndReason) - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
info(ReplicationModeChangeLogger.ReplicationLogContext, String) - Static method in class io.confluent.kafka.replication.push.ReplicationModeChangeLogger
initCount(K, int) - Method in class io.confluent.kafka.replication.push.buffer.RefCountingMemoryTracker: Starts tracking the given ref-counted memory-occupying object.
INITIAL - Static variable in class io.confluent.kafka.replication.push.ReplicationStateMetadata
INITIAL_REPLICATION_SESSION_ID - Static variable in class io.confluent.kafka.replication.push.ReplicationStateMetadata: The initial replication session ID.
INTELLIGENT_REPLICATION_FEATURE_ENABLE_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
INTELLIGENT_REPLICATION_FEATURE_ENABLE_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
INTELLIGENT_REPLICATION_FEATURE_ENABLE_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
io.confluent.kafka.replication.push - package io.confluent.kafka.replication.push
io.confluent.kafka.replication.push.buffer - package io.confluent.kafka.replication.push.buffer
io.confluent.kafka.replication.push.metrics - package io.confluent.kafka.replication.push.metrics
isActive() - Method in interface io.confluent.kafka.replication.push.PushManager
isActive() - Method in class io.confluent.kafka.replication.push.PushManagerImpl
isPushReplicationSupported(boolean, boolean) - Method in interface io.confluent.kafka.replication.push.PushManager
isPushReplicationSupported(boolean, boolean) - Method in class io.confluent.kafka.replication.push.PushManagerImpl
isRequestReady() - Method in class io.confluent.kafka.replication.push.buffer.BufferingAppendRecordsBuilder: Return whether the request is ready to send.

K

KafkaMetricHistogram - Class in io.confluent.kafka.replication.push.metrics: A compound stat providing various metrics based on an internally maintained HdrHistogram.

L

LEADER_REPLICATION_ERROR - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
leaderEpoch() - Method in class io.confluent.kafka.replication.push.PushSession
LINGER_MS_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
LINGER_MS_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
LINGER_MS_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
LINGER_MS_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
lingerMs() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
LSO_UPDATE - Enum constant in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type

M

matchesRequestData(long, AppendRecordsRequestData.PartitionData) - Method in class io.confluent.kafka.replication.push.PushSession
max(long) - Method in class io.confluent.kafka.replication.push.metrics.HdrHistogram
MAX_IN_FLIGHT_REQUESTS_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_IN_FLIGHT_REQUESTS_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_IN_FLIGHT_REQUESTS_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_IN_FLIGHT_REQUESTS_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_MEMORY_BUFFER_BYTES_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_MEMORY_BUFFER_BYTES_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_MEMORY_BUFFER_BYTES_DOC_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_MEMORY_BUFFER_BYTES_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_MEMORY_BUFFER_BYTES_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_PUSHERS_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_PUSHERS_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_PUSHERS_DOC_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_PUSHERS_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_PUSHERS_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_PARTITION_SIZE_BYTES_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_PARTITION_SIZE_BYTES_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_PARTITION_SIZE_BYTES_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_PARTITION_SIZE_BYTES_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_SIZE_BYTES_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_SIZE_BYTES_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_SIZE_BYTES_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_REQUEST_SIZE_BYTES_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_WAIT_MS_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_WAIT_MS_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_WAIT_MS_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
MAX_WAIT_MS_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
maxInFlightRequests() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
maxMemoryBufferBytes() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
maxPushers() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
maxRequestPartitionSizeBytes() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
maxRequestSizeBytes() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
maxWaitMs() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
mean(long) - Method in class io.confluent.kafka.replication.push.metrics.HdrHistogram
measurePercentile(long, double) - Method in class io.confluent.kafka.replication.push.metrics.HdrHistogram: Reads percentile data from the histogram.
MEMORY_BUFFER_EXHAUSTED - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
MEMORY_RECORDS - Enum constant in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type
memoryRecords() - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder.MultiMemoryRecords
METRIC_GROUP_NAME_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
METRIC_GROUP_NAME_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
METRIC_TYPE_NAME_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
METRIC_TYPE_NAME_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
metrics - Variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
min(long) - Method in class io.confluent.kafka.replication.push.metrics.HdrHistogram
mode() - Method in interface io.confluent.kafka.replication.push.ReplicationState: The replication mode of this partition replica.
mode() - Method in class io.confluent.kafka.replication.push.ReplicationStateMetadata
MultiMemoryRecords(List<MemoryRecords>) - Constructor for class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder.MultiMemoryRecords

N

NEW_CLUSTER_LINK - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
NEW_LEADER_EPOCH - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
NEW_REPLICA_EPOCH_OR_REPLICATION_SESSION - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
newLatencyHistogram(Function<String, MetricName>, long) - Static method in class io.confluent.kafka.replication.push.metrics.KafkaMetricHistogram: Creates a new histogram with the purpose of tracking latency values.
nextId(ReplicationState.Mode) - Method in class io.confluent.kafka.replication.push.ReplicationStateMetadata
NUM_PUSHERS_PER_BROKER_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
NUM_PUSHERS_PER_BROKER_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
NUM_PUSHERS_PER_BROKER_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
NUM_PUSHERS_PER_REMOTE_BROKER_DOC_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
NUM_PUSHERS_PER_REMOTE_BROKER_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
numPushersPerBroker() - Method in class io.confluent.kafka.replication.push.ReplicationConfig

O

offset() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.OffsetPayload
OffsetPayload(long) - Constructor for class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.OffsetPayload
onAppendRecordsResponse(long, long) - Method in class io.confluent.kafka.replication.push.PushSession: Called on a successful AppendRecords response for that partition replica.
onHighWatermarkUpdate(TopicIdPartition, int, long) - Method in interface io.confluent.kafka.replication.push.Pusher: Should be called whenever the high watermark for a push-replicated partition replica is updated.
onHighWatermarkUpdate(TopicIdPartition, Set<Integer>, long) - Method in interface io.confluent.kafka.replication.push.PushManager: Invoked every time the high watermark of the given partition is updated.
onHighWatermarkUpdate(TopicIdPartition, Set<Integer>, long) - Method in class io.confluent.kafka.replication.push.PushManagerImpl
onLeaderAppend(TopicIdPartition, int, long, AbstractRecords) - Method in interface io.confluent.kafka.replication.push.Pusher: Buffers the given records to be replicated with some subsequent AppendRecords request.
onLeaderAppend(TopicIdPartition, Set<Integer>, long, AbstractRecords) - Method in interface io.confluent.kafka.replication.push.PushManager: Invoked every time this broker as the leader of the given partition appends memory records to its log (if the corresponding partition replica has transitioned to push replication), as well as the first time after starting a push session with the FileRecords needed to have the follower catch up to the leader.
onLeaderAppend(TopicIdPartition, Set<Integer>, long, AbstractRecords) - Method in class io.confluent.kafka.replication.push.PushManagerImpl
onLogStartOffsetUpdate(TopicIdPartition, int, long) - Method in interface io.confluent.kafka.replication.push.Pusher: Should be called whenever the log start offset for a push-replicated partition replica is updated.
onLogStartOffsetUpdate(TopicIdPartition, Set<Integer>, long) - Method in interface io.confluent.kafka.replication.push.PushManager: Invoked every time the log start offset of the given partition is updated.
onLogStartOffsetUpdate(TopicIdPartition, Set<Integer>, long) - Method in class io.confluent.kafka.replication.push.PushManagerImpl
onPushSessionEnded() - Method in class io.confluent.kafka.replication.push.PushSession: Called when the push session has ended.

P

PARTITION_OFFLINE_OR_DELETED - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
payload() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent: The payload carried by this push replication event.
processEvent(PushReplicationEvent<?>, PushSession) - Method in class io.confluent.kafka.replication.push.buffer.BufferingAppendRecordsBuilder: Processes the given push replication event indicating whether it was successfully consumed in the returned boolean result.
PULL - Enum constant in enum class io.confluent.kafka.replication.push.ReplicationConfig.Mode
PULL - Enum constant in enum class io.confluent.kafka.replication.push.ReplicationState.Mode
PULL_PUSH - Enum constant in enum class io.confluent.kafka.replication.push.ReplicationConfig.Mode
PUSH - Enum constant in enum class io.confluent.kafka.replication.push.ReplicationState.Mode
PUSH_MANAGER_MEMORY_BYTES_USED - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
PUSH_REPLICATION_FEATURE_ENABLE_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
PUSH_REPLICATION_FEATURE_ENABLE_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
PUSH_REPLICATION_FEATURE_ENABLE_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
PUSH_SESSION_END_COUNT - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
Pusher - Interface in io.confluent.kafka.replication.push: Used for proactively replicating (pushing) records for partitions led by this broker to its follower brokers.
PushManager - Interface in io.confluent.kafka.replication.push: Manages the buffering, tracking and pushing of records written to partition replicas that should be replicated via push replication.
PushManagerImpl - Class in io.confluent.kafka.replication.push
PushManagerImpl(ReplicationConfig, Time, PushReplicationManagerMetrics, Function<Integer, KafkaClient>) - Constructor for class io.confluent.kafka.replication.push.PushManagerImpl
PushReplicationEvent<T> - Class in io.confluent.kafka.replication.push.buffer: A generic event representing a partition replica change that should be processed for the purposes of push replication.
PushReplicationEvent.OffsetPayload - Class in io.confluent.kafka.replication.push.buffer: A payload carrying a single offset value.
PushReplicationEvent.RecordsPayload - Class in io.confluent.kafka.replication.push.buffer: 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 - Enum Class in io.confluent.kafka.replication.push.buffer: Enumerates the different types of push replication events.
PushReplicationManagerMetrics - Class in io.confluent.kafka.replication.push.metrics
PushReplicationManagerMetrics(Metrics, Meter, ReplicationQuotaRecorder, boolean) - Constructor for class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
pushReplicationModeEnabled(ReplicationConfig.Mode) - Static method in class io.confluent.kafka.replication.push.ReplicationConfig
PushSession - Class in io.confluent.kafka.replication.push: Identifies a push replication session for some partition replica.
PushSession(int, long, long, Node) - Constructor for class io.confluent.kafka.replication.push.PushSession
PushSessionEndReason - Enum Class in io.confluent.kafka.replication.push

R

record(long) - Method in class io.confluent.kafka.replication.push.metrics.HdrHistogram: Writes to the histogram.
record(MetricConfig, double, long) - Method in class io.confluent.kafka.replication.push.metrics.KafkaMetricHistogram
recordFollowerNotCaughtUp(TopicIdPartition, Integer) - Method in interface io.confluent.kafka.replication.push.PushManager
recordFollowerNotCaughtUp(TopicIdPartition, Integer) - Method in class io.confluent.kafka.replication.push.PushManagerImpl
recordPartitionBytesOut(Uuid, int, long) - Method in interface io.confluent.kafka.replication.push.metrics.ReplicationQuotaRecorder
recordPartitionReplicationBytesOut(Uuid, int, long) - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
recordReplicationBytesOut(long) - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
records() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.RecordsPayload
RecordsPayload(AbstractRecords, long) - Constructor for class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.RecordsPayload
RefCountingMemoryTracker<K> - Class in io.confluent.kafka.replication.push.buffer: A tracker that allows calculating the total memory taken by the ref-counted objects it tracks.
RefCountingMemoryTracker(Function<K, Integer>, long, Consumer<RemovalNotification<K, AtomicInteger>>) - Constructor for class io.confluent.kafka.replication.push.buffer.RefCountingMemoryTracker
registerMemoryBytesUsedGauge(Gauge<Long>) - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
registerStoppingPushSessionSupplier(Supplier<Integer>) - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
release() - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder.MultiMemoryRecords
REPLICA_NOT_IN_ISR - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
REPLICA_REMOVED_FROM_ASSIGNMENT - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
REPLICA_SHUTDOWN - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
replicaEpoch() - Method in class io.confluent.kafka.replication.push.PushSession
replicaId() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent
replicaNode() - Method in class io.confluent.kafka.replication.push.PushSession
REPLICATION_MODE_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
REPLICATION_MODE_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
REPLICATION_MODE_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
ReplicationConfig - Class in io.confluent.kafka.replication.push
ReplicationConfig(Map<?, ?>, boolean) - Constructor for class io.confluent.kafka.replication.push.ReplicationConfig
ReplicationConfig.Mode - Enum Class in io.confluent.kafka.replication.push: Enumerates the valid values for the ReplicationConfig.REPLICATION_MODE_PROP config property.
ReplicationLogContext(TopicIdPartition, int, long, int, long) - Constructor for class io.confluent.kafka.replication.push.ReplicationModeChangeLogger.ReplicationLogContext
replicationMode() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
ReplicationModeChangeLogger - Class in io.confluent.kafka.replication.push
ReplicationModeChangeLogger() - Constructor for class io.confluent.kafka.replication.push.ReplicationModeChangeLogger
ReplicationModeChangeLogger.ReplicationLogContext - Class in io.confluent.kafka.replication.push
ReplicationQuotaRecorder - Interface in io.confluent.kafka.replication.push.metrics
replicationSessionId() - Method in class io.confluent.kafka.replication.push.PushSession
replicationSessionId() - Method in interface io.confluent.kafka.replication.push.ReplicationState: The current replication session ID for this partition replica.
replicationSessionId() - Method in class io.confluent.kafka.replication.push.ReplicationStateMetadata
replicationSessionIdSupportsPushTransition(long) - Static method in class io.confluent.kafka.replication.push.ReplicationStateMetadata
ReplicationState - Interface in io.confluent.kafka.replication.push: The per-partition-replica state maintained for push replication.
ReplicationState.Mode - Enum Class in io.confluent.kafka.replication.push: The different replication modes in which a partition replica can be in.
ReplicationStateMetadata - Class in io.confluent.kafka.replication.push: Manages replication mode transitions for push replication.
ReplicationStateMetadata(ReplicationState.Mode, long) - Constructor for class io.confluent.kafka.replication.push.ReplicationStateMetadata
REQUEST_NON_RETRIABLE_ERROR - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
REQUEST_RETRIABLE_ERROR - Enum constant in enum class io.confluent.kafka.replication.push.PushSessionEndReason
REQUEST_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
REQUEST_TIMEOUT_MS_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
REQUEST_TIMEOUT_MS_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
requestTimeoutMs() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
RETRY_TIMEOUT_MS_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
RETRY_TIMEOUT_MS_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
RETRY_TIMEOUT_MS_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
RETRY_TIMEOUT_MS_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
retryTimeoutMs() - Method in class io.confluent.kafka.replication.push.ReplicationConfig

S

sendEndSessionRequest - Variable in enum class io.confluent.kafka.replication.push.PushSessionEndReason
shouldWakeupPusherThread() - Method in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type
shutdown() - Method in interface io.confluent.kafka.replication.push.Pusher: Shuts this pusher down, terminating all its push replication processing.
shutdown() - Method in interface io.confluent.kafka.replication.push.PushManager: Shuts down the manager, cleaning up any used resources (buffered records, initialized pusher threads, etc.).
shutdown() - Method in class io.confluent.kafka.replication.push.PushManagerImpl
sizeInBytes() - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder.MultiMemoryRecords
SOCKET_SEND_BUFFER_BYTES_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
SOCKET_SEND_BUFFER_BYTES_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
SOCKET_SEND_BUFFER_BYTES_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
SOCKET_SEND_BUFFER_BYTES_PROP_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
socketSendBufferBytes() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
start() - Method in interface io.confluent.kafka.replication.push.Pusher: Starts the pusher thread.
START_PUSH - Enum constant in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type
startPush(TopicIdPartition, PushSession) - Method in interface io.confluent.kafka.replication.push.Pusher: Adds this partition replica with its push replication session metadata to the set of partitions for which this pusher will be sending AppendRecords requests.
startPush(TopicIdPartition, PushSession) - Method in interface io.confluent.kafka.replication.push.PushManager: Initiates push replication for the given partition replica with the given replication session identifiers (leader epoch + replica epoch + replication session ID).
startPush(TopicIdPartition, PushSession) - Method in class io.confluent.kafka.replication.push.PushManagerImpl
startup() - Method in interface io.confluent.kafka.replication.push.PushManager: Starts up the push manager, including the pusher threads.
startup() - Method in class io.confluent.kafka.replication.push.PushManagerImpl
stats() - Method in class io.confluent.kafka.replication.push.metrics.KafkaMetricHistogram
stdDeviation(long) - Method in class io.confluent.kafka.replication.push.metrics.HdrHistogram
STICKY_TOPIC_EXEMPTION_ENABLE_DEFAULT - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
STICKY_TOPIC_EXEMPTION_ENABLE_DOC - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
STICKY_TOPIC_EXEMPTION_ENABLE_PROP - Static variable in class io.confluent.kafka.replication.push.ReplicationConfig
STOP_PUSH - Enum constant in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type
STOPPING_PUSH_SESSIONS_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
STOPPING_PUSH_SESSIONS_NON_CCLOUD - Static variable in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics
stopPush(TopicIdPartition, int, PushSessionEndReason) - Method in interface io.confluent.kafka.replication.push.Pusher: Stops the push replication session for the given partition, optionally preparing an AppendRecords request signaling the stoppage.
stopPush(TopicIdPartition, Set<Integer>, PushSessionEndReason) - Method in interface io.confluent.kafka.replication.push.PushManager: Stops push replication for the given partition replicas.
stopPush(TopicIdPartition, Set<Integer>, PushSessionEndReason) - Method in class io.confluent.kafka.replication.push.PushManagerImpl
stopPushAndDiscardState(boolean) - Method in class io.confluent.kafka.replication.push.buffer.BufferingPartitionDataBuilder: Stops a push session for this partition replica.
stringValues() - Static method in enum class io.confluent.kafka.replication.push.ReplicationConfig.Mode

T

topicIdPartition() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent
toString() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.OffsetPayload
toString() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.RecordsPayload
toString() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent
toString() - Method in class io.confluent.kafka.replication.push.PushSession
toString() - Method in class io.confluent.kafka.replication.push.ReplicationModeChangeLogger.ReplicationLogContext
toString() - Method in class io.confluent.kafka.replication.push.ReplicationStateMetadata
totalBytes() - Method in class io.confluent.kafka.replication.push.buffer.RefCountingMemoryTracker
tryCompleteDelayedRequests() - Method in class io.confluent.kafka.replication.push.PushSession: Try to complete any pending requests in purgatory.
type() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent: The type of this push replication event.

U

UNKNOWN_REPLICATION_SESSION_ID - Static variable in class io.confluent.kafka.replication.push.ReplicationStateMetadata: An invalid replication session ID.
UNSAFE - Enum constant in enum class io.confluent.kafka.replication.push.metrics.HdrHistogram.ThreadSafetyMode: Used when both reading from and writing to the histogram is done by a single thread or is synchronized externally.
updateEventQueueProcessingTime(long) - Method in class io.confluent.kafka.replication.push.metrics.PushReplicationManagerMetrics

V

validPreviousModes() - Method in enum class io.confluent.kafka.replication.push.ReplicationState.Mode
valueOf(String) - Static method in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.replication.push.metrics.HdrHistogram.ThreadSafetyMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.replication.push.PushSessionEndReason: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.replication.push.ReplicationConfig.Mode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.kafka.replication.push.ReplicationState.Mode: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.Type: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.replication.push.metrics.HdrHistogram.ThreadSafetyMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.replication.push.PushSessionEndReason: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.replication.push.ReplicationConfig.Mode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.kafka.replication.push.ReplicationState.Mode: Returns an array containing the constants of this enum class, in the order they are declared.

A B C D E F G H I K L M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values