openstack
/
monasca-events-api
Code Issues Proposed changes

Added auto commit true

This commit is contained in:
Joe Keen 2015-08-05 10:51:09 -06:00
parent 3db98ede09
commit 6f76568024
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
demo/post_webhook.py
View File

@ -12,7 +12,7 @@ kc = kafka.client.KafkaClient("192.168.10.4:9092")
consumer = kafka.consumer.SimpleConsumer(kc,
"Foo",
"stream-notifications",
auto_commit=False)
auto_commit=True)
for raw_event in consumer:
event = json.loads(raw_event.message.value)