Hi Harsha, Thank you for the quick response. Please find the full context below. We have implemented/customized security feature on top of Kafka 0.8.2 version. Now, all the consumers should be able to pass those security configs. I have reviewed the storm code but i have few questions here.
*My analysis after reviewing the code*: *SimpleConsumer* class constructor in my Kafka customized version has security configs as parameters. DynamicPartitionConnections and StaticPartitionConnections classes in storm-kafka code are creating instances for SimpleConsumer. I can modify the instantiation of it so that it will create an instance of our customized SimpleConsumer. This changes would work i guess. *My Questions :* 1) Do you recommend the approach that i mentioned above ? 2) We are using Horton-works 2.1.7 version. Do i need to customize the storm code (which is 0.9.1 version of storm) in HW flavor or apache flavor ? On Thu, Jan 28, 2016 at 9:48 PM, Harsha <[email protected]> wrote: > Rajashekar, > Current storm kafka connector uses kafka's simpleconsumer > api. Only kafka's new consumer api has the security enabled. There is work > being done to port kafka connector to use new consumer api. > > Thanks, > Harsha > > > On Thu, Jan 28, 2016, at 02:04 PM, Rajasekhar wrote: > > > Hi, > *Backgroud* : > I am working on kafka-Storm project. Storm reads messages from secured > kafka cluster. > SSL security was implemented in Kafka broker. Consumers (In our case it is > Storm) has to provide the necessary information to get secured connection > to kafka broker. > > Client has to provide below details as configs. All these details in a > property file and config the property file as > kafka.client.security.properties. > > # Keystore file > keystore=<Location> > keystorePwd=<keystorepassword> > keyPwd=<keypassword> > > # Truststore file > truststore=<Location> > truststorePwd=<TrustStorePassword> > *Questions* : > My consumer is Trident Storm and i am trying to provide these details to > get a secured connection. > Do we have any build config to do this or any other possibility ? > > > > -- Thanks & Regards Rajasekhar
