Set host and port in ExternalService test fixture

So we can run tests against an already running Kafka instance

KAFKA_URI=tcp://localhost:9092 python -m test.test_integration

1 files changed, 2 insertions, 0 deletions

diff --git a/test/fixtures.py b/test/fixtures.py
index 946c64f..c771a58 100644
--- a/test/fixtures.py
+++ b/test/fixtures.py
@@ -74,6 +74,8 @@ def render_template(source_file, target_file, binding):
 class ExternalService(object):
     def __init__(self, host, port):
         print("Using already running service at %s:%d" % (host, port))
+        self.host = host
+        self.port = port
 
     def open(self):
         pass