Thanks for the patch. Committed to 0.8.
Uploaded kafka-737-v1.patch with the following changes:
1. disable shallow.iterator in the mirror_consumer properties file
2. change compression-codec = 2 to test snappy compression in testcase_5003
Those MirrorMaker System Test cases with compression enabled are failing. The shallow.iterator needs to be disabled in order to make compression work correctly.