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 ? >
