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

Reply via email to