nytlabs/stream_tools — pull request #9 by nikhan (2013-07-18 14:20:05+00:00)
Title: 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