openstack/deb-python-kafka
Code Issues Proposed changes

Update README with new options

Browse Source
This commit is contained in:
Mahendra M
2013-06-20 15:03:29 +05:30
parent c2c555798e
commit 6158e29d27
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
README.md
View File

@@ -39,6 +39,21 @@ producer.send_messages("this method", "is variadic")
producer = SimpleProducer(kafka, "my-topic", async=True) producer = SimpleProducer(kafka, "my-topic", async=True)
producer.send_messages("async message") producer.send_messages("async message")
# To wait for acknowledgements
# ACK_AFTER_LOCAL_WRITE : server will wait till the data is written to
# a local log before sending response
# ACK_AFTER_CLUSTER_COMMIT : server will block until the message is committed
# by all in sync replicas before sending a response
producer = SimpleProducer(kafka, "my-topic", async=False,
req_acks=SimpleProducer.ACK_AFTER_LOCAL_WRITE,
acks_timeout=2000)
response = producer.send_messages("async message")
if response:
print(response[0].error)
print(response[0].offset)
# To consume messages # To consume messages
consumer = SimpleConsumer(kafka, "my-group", "my-topic") consumer = SimpleConsumer(kafka, "my-group", "my-topic")
for message in consumer: for message in consumer: