Also minor fix in setting properties, KafkaClient.scala lines 61 and 73:
the documentation for java.util.Properties suggests not to use putAll method because it is not type-safe (in fact, in my environment those two lines did not even compile). They suggest using setProperty method.