Same issue we are facing in our Pyspark streaming .. Could you please let me know is it possible to handle in python mode spark as well ?  https://stackoverflow.com/questions/58755063/failed-to-find-leader-for-topics-java-lang-nullpointerexception-nullpointerexce?noredirect=1#comment103834465_58755063 ... View more