Category Archives: Storm

Integrating Kafka and Storm

Intro This article focuses on integrating Storm and Kafka Data is not encrypted in this case Create client_jaas file (under /usr/hdp/current/storm-client/conf/) KafkaClient{ required useTicketCache=true renewTicket=true serviceName=”kafka”; }; Client{ required useTicketCache=true renewTicket=false serviceName=”zk”; }; StormClient{ required … Continue reading

Posted in Kafka, Storm | Tagged , , | Leave a comment

Apache Storm

Architecture / Components Nimbus and Supervisor daemons are designed to be fail-fast (process self-destructs whenever any unexpected situation is encountered) stateless (all state is kept in Zookeeper or on disk) Nimbus and Supervisor daemons must be run under supervision using … Continue reading

Posted in Storm, Uncategorized | Tagged , | Leave a comment