SKAUL05
diff --git a/‎iot/api-client/end_to_end_example/cloudiot_pubsub_example_mqtt_device.py
Copy file name to clipboardExpand all lines: iot/api-client/end_to_end_example/cloudiot_pubsub_example_mqtt_device.py
+1-1Lines changed: 1 addition & 1 deletion b/‎iot/api-client/end_to_end_example/cloudiot_pubsub_example_mqtt_device.py
Copy file name to clipboardExpand all lines: iot/api-client/end_to_end_example/cloudiot_pubsub_example_mqtt_device.py
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎iot/api-client/end_to_end_example/cloudiot_pubsub_example_server.py
Copy file name to clipboardExpand all lines: iot/api-client/end_to_end_example/cloudiot_pubsub_example_server.py
+1-1Lines changed: 1 addition & 1 deletion b/‎iot/api-client/end_to_end_example/cloudiot_pubsub_example_server.py
Copy file name to clipboardExpand all lines: iot/api-client/end_to_end_example/cloudiot_pubsub_example_server.py
+1-1Lines changed: 1 addition & 1 deletion
@@ -122,7 +122,7 @@ def on_subscribe(self, unused_client, unused_userdata, unused_mid,
 
     def on_message(self, unused_client, unused_userdata, message):
         """Callback when the device receives a message on a subscription."""
-        payload = message.payload
+        payload = message.payload.decode('utf-8')
         print('Received message \'{}\' on topic \'{}\' with Qos {}'.format(
             payload, message.topic, str(message.qos)))
 
 
@@ -152,7 +152,7 @@ def callback(message):
             subscribed topic.
             """
             try:
-                data = json.loads(message.data)
+                data = json.loads(message.data.decode('utf-8'))
             except ValueError as e:
                 print('Loading Payload ({}) threw an Exception: {}.'.format(
                     message.data, e))