Update load_example

mahall · Feb 27, 2014 · 888f206 · 888f206
1 parent 112158f
commit 888f206
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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,
         )