openstack
/
deb-python-kafka
Code Issues Proposed changes

Use fixture hostname (dont assume localhost)

This commit is contained in:
Dana Powers 2017-06-17 07:10:03 -07:00
parent 7b4237733d
commit 6be1b4baff
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/test_consumer_group.py
View File

@ -16,7 +16,7 @@ from test.testutil import random_string
def get_connect_str(kafka_broker):
return 'localhost:' + str(kafka_broker.port)
return kafka_broker.host + ':' + str(kafka_broker.port)
@pytest.fixture

2
test/test_producer.py
View File

@ -35,7 +35,7 @@ def test_end_to_end(kafka_broker, compression):
elif platform.python_implementation() == 'PyPy':
return
connect_str = 'localhost:' + str(kafka_broker.port)
connect_str = ':'.join([kafka_broker.host, str(kafka_broker.port)])
producer = KafkaProducer(bootstrap_servers=connect_str,
retries=5,
max_block_ms=10000,