diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-03-29 16:38:47 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-03-29 16:38:47 -0700 |
| commit | 35b8f5b5d8b0888806d5d6c9ec02910327c3a671 (patch) | |
| tree | ccb16a62c4da6d1b6e33801289fdbcfdf3c0713f /test/test_consumer_integration.py | |
| parent | 5652f595632bff728c7880de8892d8cb0a99cb45 (diff) | |
| download | kafka-python-35b8f5b5d8b0888806d5d6c9ec02910327c3a671.tar.gz | |
Use bootstrap_servers interface in tests
Diffstat (limited to 'test/test_consumer_integration.py')
| -rw-r--r-- | test/test_consumer_integration.py | 2 |
1 files changed, 1 insertions, 1 deletions
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 |