From 35b8f5b5d8b0888806d5d6c9ec02910327c3a671 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 29 Mar 2015 16:38:47 -0700 Subject: [PATCH] Use bootstrap_servers interface in tests --- test/test_consumer_integration.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index d3df56a..17a8ac9 100644 --- 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