unfortunately futurepool is not playing nice with Kafka 0.8. My original implementation was with  futurepool but that results in intermittent thread deadlocks. See https://github.com/twitter/util/issues/98 for more info