Add a few basic KafkaConsumer tests

1 files changed, 6 insertions, 0 deletions

diff --git a/test/test_consumer.py b/test/test_consumer.py
index 9060919..b33e537 100644
--- a/test/test_consumer.py
+++ b/test/test_consumer.py
@@ -3,8 +3,14 @@ from mock import MagicMock
 from . import unittest
 
 from kafka.consumer import SimpleConsumer
+from kafka.consumer.new import KafkaConsumer
+from kafka.common import KafkaConfigurationError
 
 class TestKafkaConsumer(unittest.TestCase):
     def test_non_integer_partitions(self):
         with self.assertRaises(AssertionError):
             SimpleConsumer(MagicMock(), 'group', 'topic', partitions = [ '0' ])
+
+    def test_broker_list_required(self):
+        with self.assertRaises(KafkaConfigurationError):
+            KafkaConsumer()