Merge pull request #11 from databricks-industry-solutions/fix/mqtt_require_tls

fix: require tls boolean value conversion error

Author: dmoore247

mqtt/src/python_datasource_connectors/mqtt_streaming.py

@@ -106,8 +106,7 @@ def __init__(self, schema, options):
         super().__init__()
         self.topic = self._parse_topic(options.get("topic", "#"))
         self.broker_address = options.get("broker_address")
-        str_tls = options.get("require_tls", True).lower()
-        self.require_tls = True if str_tls == "true" else False
+        self.require_tls = options.get("require_tls", True)
         self.port = int(options.get("port", 8883))
         self.username = options.get("username", "")
         self.password = options.get("password", "")