recover from a dead open-replicator

occasionally a master will cut the CX from underneath us.  this allows
us to recover.

src/main/java/com/zendesk/maxwell/MaxwellBinlogEventListener.java

@@ -18,6 +18,7 @@ public void stop() {
 		mustStop.set(true);
 	}
 
+	@Override
 	public void onEvents(BinlogEventV4 event) {
 		while (mustStop.get() != true) {
 			try {

src/main/java/com/zendesk/maxwell/MaxwellParser.java

@@ -92,13 +92,23 @@ public void run() throws Exception {
 
 		for(;;) {
 			event = getEvent();
+
+			if ( !replicator.isRunning() ) {
+				LOGGER.warn("open-replicator stopped at position " + replicator.getBinlogFileName() + ":" + replicator.getBinlogPosition() + " -- restarting");
+				replicator.start();
+			}
+
 			if ( event == null )
 				continue;
 
 			if ( !skipEvent(event)) {
 				producer.push(event);
-				// TODO:  we need to tell the producer to only store a stop-event on table-maps
+				// TODO:  we need to tell the producer to only store a stop-event on table-maps; otherwise we can end up
+				// in the middle of multiple row events, which is a bug.
 			}
+
+			replicator.setBinlogFileName(event.getBinlogFilename());
+			replicator.setBinlogPosition(event.getHeader().getNextPosition());
 		}
 	}