asf - Revision 1917818: /kafka/trunk/contrib/hadoop-consumer/test