Skip navigation links
G I O P R T V 

G

getNextPushOffset() - Method in interface io.confluent.kafka.replication.push.ReplicationState
The next offset from which to push for this partition replica.
getPushSessionId() - Method in interface io.confluent.kafka.replication.push.ReplicationState
The current push session ID for this partition replica or -1 if the replica is not currently in PUSH.
getReplicationMode() - Method in interface io.confluent.kafka.replication.push.ReplicationState
The replication mode of this partition replica.
getReplicationState(TopicIdPartition, Integer) - Method in interface io.confluent.kafka.replication.push.PushManager
Returns the current replication state for the given partition replica.

I

io.confluent.kafka.replication.push - package io.confluent.kafka.replication.push
 

O

onLeaderAppend(TopicIdPartition, Set<Integer>, long, AbstractRecords) - Method in interface io.confluent.kafka.replication.push.PushManager
Callback invoked initially with file records as part of transitioning to push replication and every time after this broker as the leader of the given partition appends memory records to its log (if the corresponding partition replica is transitioning or has already transitioned to push replication).

P

PushManager - Interface in io.confluent.kafka.replication.push
 

R

ReplicationState - Interface in io.confluent.kafka.replication.push
 
ReplicationState.Mode - Enum in io.confluent.kafka.replication.push
The different replication modes in which a partition replica can be in.

T

tryStartPush(TopicIdPartition, Set<Integer>) - Method in interface io.confluent.kafka.replication.push.PushManager
Starts push replication for the given partition replicas.
tryStartTransition(TopicIdPartition, Map<Integer, Long>) - Method in interface io.confluent.kafka.replication.push.PushManager
Moves the given partition replicas to the transitional state preparing them for push replication.
tryStopPush(TopicIdPartition, Set<Integer>) - Method in interface io.confluent.kafka.replication.push.PushManager
Stops push replication or transitioning to push replication for the given partition replicas.

V

valueOf(String) - Static method in enum io.confluent.kafka.replication.push.ReplicationState.Mode
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.kafka.replication.push.ReplicationState.Mode
Returns an array containing the constants of this enum type, in the order they are declared.
G I O P R T V 
Skip navigation links