summaryrefslogtreecommitdiff
path: root/example.py
diff options
context:
space:
mode:
Diffstat (limited to 'example.py')
-rw-r--r--example.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/example.py b/example.py
index 6ec223c..286bfdb 100644
--- a/example.py
+++ b/example.py
@@ -4,7 +4,7 @@ from kafka import KafkaClient, FetchRequest, ProduceRequest
def produce_example(kafka):
message = kafka.create_message("testing")
- request = ProduceRequest("my-topic", 0, [message])
+ request = ProduceRequest("my-topic", -1, [message])
kafka.send_message_set(request)
def consume_example(kafka):