The storm kafka jar is not on the storm classpath by default. This is because not everyone needs kafka and we already have enough problems with jar version mismatches. You should be pulling it into your uberjar yourself through maven.
- Bobby On 8/18/14, 7:44 PM, "Manu Zhang" <[email protected]> wrote: >Hi all, > >I'm running an storm trident topology that >uses TransactionalTridentKafkaSpout but the worker can not be initialized >since the spout class can not be found. > >It looks to me storm-kafka jar is not on the classpath. >I'm running storm trunk code and storm is built from storm-dist binary. > >Anything I need to configure to get it work ? > >Thanks, >Manu
