Still trying to work around kafka/contrib/hadoop-consumer