Details
-
Improvement
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
Spark-2.3.0
-
None
-
spark 2.3.1, python3.6
-
Patch
Description
When using spark-streaming-mqtt with pyspark to access rabbitmq, I found there are no username and password provied for python api;
These two params are important and necessary for rabbitmq especially when using rabbitmq virtual hosts, so I added a group of functions here;
Attachments
Issue Links
- links to