s.KerberosLogin.getServiceName(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 mail
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 a