Hi There; �
I am using spark latest 3.1.1 and try to connect via mqtt with structured streaming. Seems to me the mqtt does not exist under pyspark.streaming anymore. Does anyone know where does this module go and load it with the python application. � Appreciate answer. � Regards, � Jian Xu