summaryrefslogtreecommitdiff
path: root/example.py
diff options
context:
space:
mode:
authorMark Roberts <markroberts@kixeye.com>2014-02-26 21:36:22 -0800
committerMark Roberts <markroberts@kixeye.com>2014-02-26 21:36:22 -0800
commit112158fa75879e2343c361c00a8aecb176dbb767 (patch)
treeb09b03781394c553ad902ca4a941865b74a76125 /example.py
parent3b39d9d6589ee46ae4d31fb078f44019a2810983 (diff)
parentab89a44ecf9c93b116fcc8516cfc21749df74507 (diff)
downloadkafka-python-112158fa75879e2343c361c00a8aecb176dbb767.tar.gz
Merge branch 'master' into conn_refactor
Conflicts: example.py
Diffstat (limited to 'example.py')
-rwxr-xr-xexample.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/example.py b/example.py
index 43298e8..062761b 100755
--- a/example.py
+++ b/example.py
@@ -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: