Package io.confluent.kafka.replication.push
package io.confluent.kafka.replication.push
-
ClassDescriptionUsed 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.Identifies a push replication session for some partition replica.Enumerates the valid values for the
ReplicationConfig.REPLICATION_MODE_PROPconfig 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.