{"type":"doc","content":[{"type":"paragraph","content":[{"text":"ClearBlade’s streaming MQTT Connectors along for setting standard bi-directional mappings between data flowing over ClearBlade Brokered MQTT topics to Third party cloud streaming services and middleware. ","type":"text"}]},{"type":"paragraph","content":[{"text":"This is ideal for sending MQTT messages into your cloud services or integrating data from other services directly with your ClearBlade application.","type":"text"}]},{"type":"paragraph","content":[{"text":"Currently supporting third party streaming offerings are","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Google Pub/Sub","type":"text","marks":[{"type":"strong"}]},{"text":" - supports offline caching up to 10k messages","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"AWS Kinesis","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Apache Kafka","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Apache Pulsar","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Azure Eventhub","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Technical Overview","type":"text"}]},{"type":"paragraph","content":[{"text":"To create a stream MQTT connect all that is required is to make a REST API call to the mqtt-connector endpoints and the system will immediately began honoring the configured mapping. ClearBlade recommends making this REST API call in a microservice that is triggered to run at IoT Enterprise environment start. ","type":"text"}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Environment Setup ","type":"text"}]},{"type":"paragraph","content":[{"text":"Generally MQTT Connectors are designed to be started as the IoT Enterprise comes online and begins to allow device connections. When the service runs at start up it will make an HTTP call to the platform The recommended way to implement this is ","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Create a new Code Service of type micro-service","type":"text"}]},{"type":"mediaSingle","attrs":{"layout":"center","width":451,"widthType":"pixel"},"content":[{"type":"media","attrs":{"width":451,"id":"ecc63807-2169-4fd3-8e25-ab64413d2ca1","collection":"contentId-3327524871","type":"file","height":405}}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Include the http library","type":"text"}]},{"type":"mediaSingle","attrs":{"layout":"center","width":454,"widthType":"pixel"},"content":[{"type":"media","attrs":{"width":454,"id":"5e9b8e83-f6d0-40a5-a833-679bcdb1fa04","collection":"contentId-3327524871","type":"file","height":214}}]},{"type":"paragraph","content":[{"text":" ","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Click save ","type":"text"}]}]}]},{"type":"paragraph"},{"type":"paragraph","content":[{"text":"Next: Follow the connector setup. Use the sample code below and the appropriate configuration settings for your enterprise streaming binding. ","type":"text"}]},{"type":"paragraph"},{"type":"orderedList","attrs":{"order":4},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"When you are done click “Save and Test” to apply your mapping.","type":"text"}]},{"type":"mediaSingle","attrs":{"layout":"center","width":152,"widthType":"pixel"},"content":[{"type":"media","attrs":{"width":152,"id":"7a091628-fa33-4862-92eb-814f8b242f22","collection":"contentId-3327524871","type":"file","height":50}}]}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Connector Setup","type":"text"}]},{"type":"paragraph","content":[{"text":"The triggered micro-service will need to make an API call to the IoT Enterprise platform with the necessary configuration. ","type":"text"}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"API: ","type":"text"}]},{"type":"paragraph","content":[{"text":"Create","type":"text","marks":[{"type":"strong"}]}]},{"type":"paragraph","content":[{"text":"URI: ","type":"text"},{"text":"/api/v/1/mqtt-connectors/{systemmKey}/name","type":"text","marks":[{"type":"code"}]}]},{"type":"paragraph","content":[{"text":"Method: POST","type":"text"}]},{"type":"paragraph","content":[{"text":"Headers: ","type":"text"},{"text":"'ClearBlade-UserToken': ","type":"text","marks":[{"type":"code"}]}]},{"type":"paragraph","content":[{"text":"Body: ","type":"text"},{"text":"{ \"type\": , \"credentials\":