java.lang.ClassNotFoundException: kafka.api.OffsetRequest
Ich erhalte die Fehlermeldung "java.lang.ClassNotFoundException kafka.api.OffsetRequest", während ich versuche, Kafka in unsere Storm-Topologie zu integrieren. Welche Versionen laufen und es funktioniert? Meine pom.xml
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-core</artifactId>
<version>0.9.2-incubating</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.storm</groupId>
<artifactId>storm-kafka</artifactId>
<version>0.9.2-incubating</version>
</dependency>