Class CdcrReplicator

  • All Implemented Interfaces:
    Runnable

    public class CdcrReplicator
    extends Object
    implements Runnable
    The replication logic. Given a CdcrReplicatorState, it reads all the new entries in the update log and forward them to the target cluster. If an error occurs, the replication is stopped and will be tried again later.
    • Constructor Detail

      • CdcrReplicator

        public CdcrReplicator​(org.apache.solr.handler.CdcrReplicatorState state,
                              int batchSize)
    • Method Detail

      • run

        public void run()
        Specified by:
        run in interface Runnable