spark 2 and kafka consumer with ssl/kerberos

2017-03-30 Thread bilsch
(KerberosLogin.java:297) ... 21 more -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/spark-2-and-kafka-consumer-with-ssl-kerberos-tp28551.html Sent from the Apache Spark User List mailing list archive at Nabble.com

spark 2 and kafka consumer with ssl/kerberos

2017-03-30 Thread Bill Schwanitz
I'm working on a poc spark job to pull data from a kafka topic with kerberos enabled ( required ) brokers. The code seems to connect to kafka and enter a polling mode. When I toss something onto the topic I get an exception which I just can't seem to figure out. Any ideas? I have a full gist up