diff options
author | Mark Roberts <markroberts@kixeye.com> | 2014-02-26 21:36:22 -0800 |
---|---|---|
committer | Mark Roberts <markroberts@kixeye.com> | 2014-02-26 21:36:22 -0800 |
commit | 112158fa75879e2343c361c00a8aecb176dbb767 (patch) | |
tree | b09b03781394c553ad902ca4a941865b74a76125 /example.py | |
parent | 3b39d9d6589ee46ae4d31fb078f44019a2810983 (diff) | |
parent | ab89a44ecf9c93b116fcc8516cfc21749df74507 (diff) | |
download | kafka-python-112158fa75879e2343c361c00a8aecb176dbb767.tar.gz |
Merge branch 'master' into conn_refactor
Conflicts:
example.py
Diffstat (limited to 'example.py')
-rwxr-xr-x | example.py | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -9,7 +9,7 @@ class Producer(threading.Thread): daemon = True def run(self): - client = KafkaClient("localhost", 9092) + client = KafkaClient("localhost:9092") producer = SimpleProducer(client) while True: @@ -23,7 +23,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") for message in consumer: |