We do the same, that is why we added in the createPairedByteArrayStream This returns a tuple including the topic of the message
-David From: Darshan Pandya <[email protected]> Reply-To: "[email protected]" <[email protected]> Date: Thursday, 2 November 2017 at 21:16 To: "[email protected]" <[email protected]> Subject: how to get topic name for a given message if you use wildcards to subscribe Hello folks, I am using the spark structured streaming connector to connect MQTT. I have made the changes to make it work with SSL using BC My solution requires me to connect to a hierarchy of topics with wildcards like /clientID/# When I get a message - how do i figure out the complete topic name it came from ? Thanks in advance. -- Sincerely, Darshan --------------------------------------------------------------------- Intel Electronics Ltd. This e-mail and any attachments may contain confidential material for the sole use of the intended recipient(s). Any review or distribution by others is strictly prohibited. If you are not the intended recipient, please contact the sender and delete all copies.
