Hi David, yes you can just use the provide KafkaBolt.
If the package is not found, I guess that you did not set up your development environment correctly. What do you use? An IDE? Some build tool like maven? -Matthias On 02/20/2016 02:13 PM, david kavanagh wrote: > Hello, > > I am using Storm as part of my fourth year project. I have a Storm > cluster running on some Ubuntu VM's > in an OpenStack environment. Kafka is setup and working fine on its own > VM. I am currently trying > to integrate the two so that a Storm Topology sends its output to a > Kafka Topic. I have been trying to understand > KafkaBolt but i am having difficulty implementing it. > > Reading the documentation > at http://storm.apache.org/documentation/storm-kafka.html , it seems to > me that > i can use a KafkaBolt class that has already been packaged. It is stated > in the documentation: > > "/You can create an instance of storm.kafka.bolt.KafkaBolt and attach it > as a component to your topology" / > > I have been trying to implement this but have had no success. No import > statement i have tried has worked. > i.e. > / > / > /import storm.kafka.bolt.KafkaBolt;/ > > The error being thrown up is: /error: package storm.kafka.bolt > does not exist/ > > I am new to Storm and Kafka and am aware that i may be getting the wrong > impression from the documentation. > Can i use import a KafkaBolt class or do i need to write my own > KafkaBolt class? My only reason for using Kafka is to > get the Storm Topology output to a Node.js application. I have searched > exhaustively online to find any information > on connecting Storms output to a node app and couldn't find anything > useful so Kafka seemed the only way to go. > If you could give me some information on sending a storm topologies > output to Kafka, or straight to a nodejs app > without Kafka, i would really appreciate it. Thank you in advance. > > Kind Regards > David Kavanagh
signature.asc
Description: OpenPGP digital signature
