Adding some integration tests

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):