diff --git a/mqtt-client/src/main/java/com/gojek/mqtt/connection/MqttConnection.kt b/mqtt-client/src/main/java/com/gojek/mqtt/connection/MqttConnection.kt
index 8d040836..f436c559 100644
--- a/mqtt-client/src/main/java/com/gojek/mqtt/connection/MqttConnection.kt
+++ b/mqtt-client/src/main/java/com/gojek/mqtt/connection/MqttConnection.kt
@@ -129,8 +129,9 @@ internal class MqttConnection(
             }
 
             val clientId: String = connectOptions.clientId
+            val username: String = connectOptions.username
             serverUri = getServerUri()
-            logger.d(TAG, "clientId : $clientId  serverUri $serverUri")
+            logger.d(TAG, "clientId : $clientId, username: $username,  serverUri $serverUri")
             if (mqtt == null) {
                 mqtt = getMqttAsyncClient(clientId, serverUri.toString())
                 mqtt!!.setCallback(getMqttCallback(messageReceiveListener))