Great article! I have a couple of questions Is this template being used in production? If so what are the common challenges you faced? The LinkedBlockingQueue<RawBinlogEvent> in CaptureChangeMySQL is in memory. When running this processor in cluster and primary node changes from one node to another, don't we loose the number events already stored in the queue? ... View more