Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Publish replication task to Kafka after reading from replicator queue #632

Merged
merged 2 commits into from
Mar 26, 2018
Merged

Publish replication task to Kafka after reading from replicator queue #632

merged 2 commits into from
Mar 26, 2018

Commits on Mar 26, 2018

  1. Publish replication task to Kafka after reading from replicator queue 

    Created QueueProcessorBase which has common logic used by both transfer
queue procesor and replication queue processor.

Created replicationQueueProcessor which processes replication task from
replicator queue and publishes it to Kafka.

Bootstrap logic for replicationQueueProcessor to host it within
historyEngine.  Also bootstrap logic to pass in kafka publisher to
history engine.

History engine changes to update replication state on
StartWorkflowExecution and UpdateWorkflowExecution by updating the
failover version from domain and writing it to mutable state.
    @samarabbas
    samarabbas committed Mar 26, 2018
    Configuration menu
    Copy the full SHA
    ae8b363 View commit details
    Browse the repository at this point in the history

  2. Address code review feedback

    @samarabbas
    samarabbas committed Mar 26, 2018
    Configuration menu
    Copy the full SHA
    56752cc View commit details
    Browse the repository at this point in the history