Update load_example

1 files changed, 2 insertions, 2 deletions

diff --git a/load_example.py b/load_example.py
index 95f0c7f..1f8b418 100755
--- a/load_example.py
+++ b/load_example.py
@@ -12,7 +12,7 @@ class Producer(threading.Thread):
     big_msg = "1" * msg_size
 
     def run(self):
-        client = KafkaClient("localhost", 9092)
+        client = KafkaClient("localhost:9092")
         producer = SimpleProducer(client)
         self.sent = 0
 
@@ -25,7 +25,7 @@ class Consumer(threading.Thread):
     daemon = True
 
     def run(self):
-        client = KafkaClient("localhost", 9092)
+        client = KafkaClient("localhost:9092")
         consumer = SimpleConsumer(client, "test-group", "my-topic",
             max_buffer_size = None,
         )