Update kafkaconsumer.scala