New fork, modified version, added hystrix command wrapper around fetch from Kafka