[9964] destination-mqtt: fixed build tests failures (#13099)

* [9964] destination-mqtt: fixed build tests failures
airbytehq · May 24, 2022 · d6f4ef4 · d6f4ef4
1 parent 44a43f0
commit d6f4ef4
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 2 deletions.
diff --git a/...tination-mqtt/src/main/java/io/airbyte/integrations/destination/mqtt/MqttDestination.java b/...tination-mqtt/src/main/java/io/airbyte/integrations/destination/mqtt/MqttDestination.java
@@ -5,6 +5,7 @@
 package io.airbyte.integrations.destination.mqtt;
 
 import com.fasterxml.jackson.databind.JsonNode;
+import com.google.common.base.Charsets;
 import com.google.common.collect.ImmutableMap;
 import io.airbyte.commons.json.Jsons;
 import io.airbyte.integrations.BaseConnector;
@@ -49,7 +50,7 @@ public AirbyteConnectionStatus check(final JsonNode config) {
               COLUMN_NAME_EMITTED_AT, System.currentTimeMillis(),
               COLUMN_NAME_DATA, Jsons.jsonNode(ImmutableMap.of("test-key", "test-value"))));
 
-          final MqttMessage message = new MqttMessage(payload.toString().getBytes());
+          final MqttMessage message = new MqttMessage(payload.toString().getBytes(Charsets.UTF_8));
           message.setQos(mqttConfig.getQos());
           message.setRetained(mqttConfig.isRetainedMessage());
 

diff --git a/...ation-mqtt/src/main/java/io/airbyte/integrations/destination/mqtt/MqttRecordConsumer.java b/...ation-mqtt/src/main/java/io/airbyte/integrations/destination/mqtt/MqttRecordConsumer.java
@@ -5,6 +5,7 @@
 package io.airbyte.integrations.destination.mqtt;
 
 import com.fasterxml.jackson.databind.JsonNode;
+import com.google.common.base.Charsets;
 import com.google.common.collect.ImmutableMap;
 import io.airbyte.commons.json.Jsons;
 import io.airbyte.commons.lang.Exceptions;
@@ -86,7 +87,7 @@ protected void acceptTracked(final AirbyteMessage airbyteMessage) {
           MqttDestination.COLUMN_NAME_EMITTED_AT, recordMessage.getEmittedAt(),
           MqttDestination.COLUMN_NAME_DATA, recordMessage.getData()));
 
-      final MqttMessage message = new MqttMessage(payload.toString().getBytes());
+      final MqttMessage message = new MqttMessage(payload.toString().getBytes(Charsets.UTF_8));
       message.setRetained(config.isRetainedMessage());
       message.setQos(config.getQos());
 

diff --git a/docs/integrations/destinations/mqtt.md b/docs/integrations/destinations/mqtt.md
@@ -76,3 +76,10 @@ You should now have all the requirements needed to configure MQTT as a destinati
 More info about this can be found in the [OASIS MQTT standard site](http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/mqtt-v3.1.1.html).
 
 _NOTE_: MQTT version 5 is not supported yet.
+
+
+## Changelog
+
+| Version | Date | Pull Request | Subject |
+| :--- | :--- | :--- | :--- |
+| 0.1.2 | 2022-05-24 | [13099](https://github.com/airbytehq/airbyte/pull/13099) | Fixed build's tests |