https://docs.hortonworks.com/HDPDocuments/HDP2/HDP-2.4.2/bk_storm-user-guide/content/stormkafka-secure-config.html
On Mon, Dec 19, 2016 at 4:49 PM, Ambud Sharma <[email protected]> wrote: > Not sure if this helps: > > On Thu, Dec 1, 2016 at 4:11 AM, Srinivas.Veerabomma < > [email protected]> wrote: > >> Hi, >> >> >> >> I need some help. Basically looking for some sample Storm code or some >> suggestions. >> >> >> >> My requirement is to develop a code in Apache Storm latest version to >> consume the data from Kafka topic (Kafka version : “0.9.0.1”). This >> kafka topic is SSL enabled and data is in Avro format. I was able to run >> the command – “kafka-avro-console-consumer” at the command line and consume >> the data. >> >> >> >> I also used the Kafka API code – “KafkaConsumer<String, Object> consumer = >> *new *KafkaConsumer<String, Object>(props);” and able to consume the data. >> In both the cases, I provided the required details such as : >> >> >> >> *bootstrap.servers* >> >> *group.id <http://group.id>* >> >> *client.id <http://client.id>* >> >> *security.protocol* >> >> *ssl.protocol* >> >> *ssl.truststore.location* >> >> *ssl.truststore.password* >> >> *ssl.keystore.location* >> >> *ssl.keystore.password* >> >> *key.deserializer* >> >> *value.deserializer* >> >> *schema.registry.url* >> >> >> >> >> >> With the above two options (using Command Line and using Kafka API), I was >> able to connect to SSL enabled Kafka topic and read the Avro data and >> de-serialize it successfully. I want to achieve the same thing using Apache >> Storm code. I did some research and unable to find any sample code. Please >> let me know if you have any sample code or what Storm Class to use to >> achieve this. Thanks. >> >> >> >> >> >> Regards >> >> *Srini Veerabomma | Big Data Business Intelligence, EDABI COE | **¤**Target >> India| GWS Center | Bangalore | Mobile : +91-94825-04323 >> <+91%2094825%2004323>* >> >> >> > >
