If you're asking how to handle no messages in a batch window then I would add
an isEmpty check like:
dStream.foreachRDD(rdd => {
if (!rdd.isEmpty())
...
}
Or something like that.
David Newberger
-----Original Message-----
From: Yogesh Vyas [mailto:informy...@gmail.com]
Sent: Wednesday, June 15, 2016 6:31 AM
To: user
Subject: Handle empty kafka in Spark Streaming
Hi,
Does anyone knows how to handle empty Kafka while Spark Streaming job is
running ?
Regards,
Yogesh
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional
commands, e-mail: user-h...@spark.apache.org
