- sendEndSessionRequest() - Method in class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.StopPayload
-
- sendEndSessionRequest - Variable in enum io.confluent.kafka.replication.push.PushSessionEndReason
-
- shouldWakeupPusherThread() - Method in enum 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
-
- socketSendBufferBytes() - Method in class io.confluent.kafka.replication.push.ReplicationConfig
-
- start() - Method in interface io.confluent.kafka.replication.push.Pusher
-
Starts the pusher thread.
- 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
-
- StopPayload(boolean) - Constructor for class io.confluent.kafka.replication.push.buffer.PushReplicationEvent.StopPayload
-
- STOPPING_PUSH_SESSIONS - 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 io.confluent.kafka.replication.push.ReplicationConfig.Mode
-