diff options
| author | Mark Roberts <markroberts@kixeye.com> | 2014-02-26 21:38:58 -0800 |
|---|---|---|
| committer | Mark Roberts <markroberts@kixeye.com> | 2014-02-26 21:39:10 -0800 |
| commit | 888f206d5417e95f26de407b28fe935950aea2c9 (patch) | |
| tree | cc5a876116405e6b7a30caeb7fab4120c05e2e0c /load_example.py | |
| parent | 112158fa75879e2343c361c00a8aecb176dbb767 (diff) | |
| download | kafka-python-888f206d5417e95f26de407b28fe935950aea2c9.tar.gz | |
Update load_example
Diffstat (limited to 'load_example.py')
| -rwxr-xr-x | load_example.py | 4 |
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, ) |