Hello,
I am using Storm as part of my fourth year project. I have a Storm cluster
running on some Ubuntu VM'sin an OpenStack environment. Kafka is setup and
working fine on its own VM. I am currently tryingto integrate the two so that a
Storm Topology sends its output to a Kafka Topic. I have been trying to
understandKafkaBolt 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 toget
the Storm Topology output to a Node.js application. I have searched
exhaustively online to find any informationon 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 RegardsDavid Kavanagh
