summaryrefslogtreecommitdiff
path: root/test/test_consumer_group.py
diff options
context:
space:
mode:
Diffstat (limited to 'test/test_consumer_group.py')
-rw-r--r--test/test_consumer_group.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_consumer_group.py b/test/test_consumer_group.py
index 885ae83..8f25e9f 100644
--- a/test/test_consumer_group.py
+++ b/test/test_consumer_group.py
@@ -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