From 478de24d5b4a9c73c2fc969f3fd7cf8ff0710ecb Mon Sep 17 00:00:00 2001 From: David Arthur Date: Fri, 28 Sep 2012 20:46:50 -0400 Subject: Adding some integration tests --- example.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'example.py') 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): -- cgit v1.2.1