--- a/ceilometer/tests/publisher/test_kafka_broker_publisher.py
+++ b/ceilometer/tests/publisher/test_kafka_broker_publisher.py
@@ -15,13 +15,17 @@
 """Tests for ceilometer/publisher/kafka_broker.py
 """
 import datetime
+import testtools
 import uuid
 
 import mock
 from oslo_utils import netutils
 
 from ceilometer.event.storage import models as event
-from ceilometer.publisher.kafka_broker import KafkaBrokerPublisher
+try:
+    from ceilometer.publisher.kafka_broker import KafkaBrokerPublisher
+except ImportError:
+    kafka_publisher = None
 from ceilometer import sample
 from ceilometer.tests import base as tests_base
 
@@ -93,6 +97,7 @@
         ),
     ]
 
+    @testtools.skipIf(kafka_publisher is None, "Kafka not avaliable, skipping")
     def setUp(self):
         super(TestKafkaPublisher, self).setUp()
 
--- a/requirements.txt
+++ b/requirements.txt
@@ -9,7 +9,6 @@
 iso8601>=0.1.9
 jsonpath-rw>=1.2.0,<2.0
 jsonschema>=2.0.0,<3.0.0
-kafka-python>=0.9.2 # Apache-2.0
 keystonemiddleware>=1.5.0,<1.6.0
 lxml>=2.3
 msgpack-python>=0.4.0