diff --git a/monasca_log_api/healthcheck/kafka_check.py b/monasca_log_api/healthcheck/kafka_check.py
index 590e25a0..d1dfc17f 100644
--- a/monasca_log_api/healthcheck/kafka_check.py
+++ b/monasca_log_api/healthcheck/kafka_check.py
@@ -14,10 +14,11 @@
 
 import collections
 
-import kafka.client as client
 from oslo_config import cfg
 from oslo_log import log
 
+from monasca_common.kafka_lib import client
+
 LOG = log.getLogger(__name__)
 CONF = cfg.CONF
 
diff --git a/monasca_log_api/tests/test_kafka_check.py b/monasca_log_api/tests/test_kafka_check.py
index c16f4d51..83db847b 100644
--- a/monasca_log_api/tests/test_kafka_check.py
+++ b/monasca_log_api/tests/test_kafka_check.py
@@ -12,10 +12,11 @@
 # License for the specific language governing permissions and limitations
 # under the License.
 
-import kafka.client as client
 import mock
 from oslotest import base as os_test
 
+from monasca_common.kafka_lib import client
+
 from monasca_log_api.healthcheck import kafka_check as kc
 from monasca_log_api.tests import base
 
diff --git a/requirements.txt b/requirements.txt
index 45d12ac3..c0209c24 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -13,6 +13,6 @@ oslo.log>=3.11.0 # Apache-2.0
 oslo.serialization>=1.10.0 # Apache-2.0
 oslo.utils>=3.18.0 # Apache-2.0
 PasteDeploy>=1.5.0 # MIT
-monasca-common>=1.0.0 # Apache-2.0
+monasca-common>=1.4.0 # Apache-2.0
 eventlet!=0.18.3,>=0.18.2 # MIT
 monasca-statsd>=1.1.0 # Apache-2.0