diff --git a/mqtt/mqtt.js b/mqtt/mqtt.js
index 34e9ba55..66e6cf7e 100644
--- a/mqtt/mqtt.js
+++ b/mqtt/mqtt.js
@@ -227,7 +227,7 @@ aedes.on('connectionError', function (client, err) {
 function publishConnEvent(id, type) {
     var onPublish = function(err) {
         if (err) {
-            console.error(err);
+            logger.warn('event publish failed: %s', err);
         }
     };
     esclient.xadd(config.event_stream, '*',