search

pystorm / streamparse

Run Python in Apache Storm topologies. Pythonic API, CLI tooling, and a topology DSL.
http://streamparse.readthedocs.io/
Apache License 2.0
1.5k stars 218 forks source link

ClassNotFoundException when using KafkaSpout #383

Open VivaLaVile opened 7 years ago

VivaLaVile commented 7 years ago

Complete newbie to both Storm and Streamparse and only have a little bit of Java knowledge so I appreciate this could be a silly question. I'm currently trying to run a basic topology consisting of a Kafka Spout and a simple Bolt but I'm getting the following error when performing sparse run: sparseOutput.txt

Here's my topology: topology.txt

I've added my custom KafkaSpout class into the project with a path similar to the one in the kafka-jvm example, my src directory looks like this:

|-- src | |-- bolts | | |-- addExclamation.py | |-- spouts | |-- java | | |-- rta | | | |-- spouts | | | | |-- KSpout.java

My project.cl is as follows: project_cl.txt

I've explored the uber-JAR that sparse builds and can confirm that my KSpout.java exists in /java/rta/spouts/KSpout.java

What am I missing?