java.lang.ClassNotFoundException: kafka.api.OffsetRequest

dibbhatt / kafka-spark-consumer

High Performance Kafka Connector for Spark Streaming.Supports Multi Topic Fetch, Kafka Security. Reliable offset management in Zookeeper. No Data-loss. No dependency on HDFS and WAL. In-built PID rate controller. Support Message Handler . Offset Lag checker.

Apache License 2.0

635 stars 318 forks source link

java.lang.ClassNotFoundException: kafka.api.OffsetRequest #44

Closed Hungsiro506 closed 7 years ago

Hungsiro506 commented 7 years ago

Hi, I got this problem when trying to run example. I'm using Spark 2.10, kafka 0.10_2.

dibbhatt commented 7 years ago

Can you share your Driver Code you wrote

Hungsiro506 commented 7 years ago

Thanks for your support, it was my fault. By the way, how can i fetch the messages by time duration instead of block size. For example, i need to count number of orders in every 5 mins. Thank so much.