test_writer->syncrhonizer->test_reader 

./test_writer --topic sync_in --key t --file foo.json
./synchronizer --topic sync_in --out-topic sync_out --channel synchronizer --lag 20 --key t
./test_reader --topic sync_out --channel test_reader --key t