Hi I am using spark stream 1.3 and using custom checkpoint to save kafka offsets.
1.Is doing Runtime.getRuntime().addShutdownHook(new Thread() { @Override public void run() { jssc.stop(true, true); System.out.println("Inside Add Shutdown Hook"); } }); to handle stop is safe ? 2.And I need to handle saving checkoinnt in shutdown hook also or driver will handle it automatically since it grcaefully stops stream and handle completion of foreachRDD function on stream ? directKafkaStream.foreachRDD(new Function<JavaRDD<byte[][]>, Void>() { } Thanks