diff --git a/package.json b/package.json
index c2372e3..a61ff14 100644
--- a/package.json
+++ b/package.json
@@ -23,7 +23,7 @@
     "fs-extra": "^0.26.7",
     "jasmine": "^2.4.1",
     "jwt-simple": "^0.5.0",
-    "kafka-node": "^0.5.9",
+    "kafka-node": "^2.2.3",
     "lru-cache": "^4.0.1",
     "mqtt": "^1.7.4",
     "mqtt-router": "^0.5.0",