This is being worked on in [mp/kafka-updates](https://github.com/JuliaComputing/JuliaHub.jl/tree/mp/kafka-updates) branch. Posting this issue to keep track