Hi,

I see a lot of conflicting into online about this, so hopefully the experts can 
help. I have a secure KafkaSpout (version 1.1.0 of both Storm and 
storm-kafka-client) that can’t find it’s jaas.conf. The cluster itself is 
secure, has jaas.conf, all of that works fine. I think what I need is to be 
able to pass in a –D JVM parameter into a spout to point it to the jaas.conf 
file, but I don’t see how to do it. If I print java.security.auth.login.config 
from inside my spout, it’s null. supervisor.childopts does not work. I also see 
that Flux exists, but that looks like it’s for sending application properties, 
not JVM properties.

It’s also possible that I’m just using KafkaSpout wrong. I see this page

https://github.com/apache/storm/blob/master/docs/storm-kafka-client.md

But it doesn’t say how to read from a secure topic, so I’m troubleshooting 
myself and missing jaas.conf is the first problem I see.

Thanks for any help you can give.

Dan

Reply via email to