Hi, Has anyone tried streaming API of Spark with Kafka? I am experimenting new Spark API to read from Kafka. KafkaUtils.createDirectStream(...)
Every now and then, I get following error "spark kafka.common.OffsetOutOfRangeException" and my spark script stops working. I have simple topic with just one partition. I would appreciate any clues on how to debug this issue. Thanks, LCassa