Add Zookeeper-based state machine to coordinate DR functionality on the ...

...Producer cluster.
You can call `CoreUtils.getScheduledThreadPoolExecutor()`.