When connecting to security protected Kafka instances, you need to specify additional parameters, KafkaConfig doesn't currently allow this, only bootstrap server can be defined.

N.b. a pull-req has been created for this issue (see GitHub)