Allow KafkaClient to take in a list of brokers for bootstrapping

1 files changed, 1 insertions, 1 deletions

diff --git a/example.py b/example.py
index 3a2dc92..0cf5583 100644
--- a/example.py
+++ b/example.py
@@ -14,7 +14,7 @@ def consume_example(client):
         print(message)
 
 def main():
-    client = KafkaClient("localhost", 9092)
+    client = KafkaClient("localhost:9092")
     produce_example(client)
     consume_example(client)