asf - Revision 1400000: /incubator/kafka/branches/0.7/contrib/hadoop-consumer/src/main/java