From 888f206d5417e95f26de407b28fe935950aea2c9 Mon Sep 17 00:00:00 2001 From: Mark Roberts Date: Wed, 26 Feb 2014 21:38:58 -0800 Subject: Update load_example --- load_example.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'load_example.py') 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, ) -- cgit v1.2.1