Commit 1e3837a1 authored by Patrick Godwin's avatar Patrick Godwin fix typo in Reporter instantiation

parent d05877e4
Pipeline #77118 passed with stages
in 2 minutes and 50 seconds
......@@ -34,7 +34,7 @@ class Reporter(object):
self.port = port
self.producer = KafkaProducer(
bootstrap_servers=[':'.join([self.hostname, self.port])],
bootstrap_servers=[':'.join([self.hostname, str(self.port)])],
key_serializer=lambda m: json.dumps(m).encode('utf-8'),
value_serializer=lambda m: json.dumps(m).encode('utf-8'),
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment