Can  you just add one more line to explain what this code effectively does? And a link to the documentation/code of ConsumerConsole.scala (which is from Kafka I guess) would be great. These are just for future ease, so the people who are not that experienced with Kafka (sadly, me) can understand whats going on.