Use bootstrap_servers interface in tests

2015-03-29 16:38:47 -07:00
parent 5652f59563
commit 35b8f5b5d8
1 changed files with 1 additions and 1 deletions
--- a/test/test_consumer_integration.py
+++ b/test/test_consumer_integration.py
@@ -69,7 +69,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
    def kafka_consumer(self, **configs):
        brokers = '%s:%d' % (self.server.host, self.server.port)
        consumer = KafkaConsumer(self.topic,
-                                 metadata_broker_list=brokers,
+                                 bootstrap_servers=brokers,
                                 **configs)
        return consumer