diff options
| author | Dana Powers <dana.powers@gmail.com> | 2015-03-29 18:09:03 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2015-03-29 18:09:03 -0700 |
| commit | bb1c11e199a91f50d227ac9d95ea0c81a3f1bbfc (patch) | |
| tree | ccb16a62c4da6d1b6e33801289fdbcfdf3c0713f /test | |
| parent | fd204dca174033e36899a0e20d2ce7ebccf11ddb (diff) | |
| parent | 35b8f5b5d8b0888806d5d6c9ec02910327c3a671 (diff) | |
| download | kafka-python-bb1c11e199a91f50d227ac9d95ea0c81a3f1bbfc.tar.gz | |
Merge pull request #341 from dpkp/kafka_consumer_docs
KafkaConsumer documentation
Diffstat (limited to 'test')
| -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 |