Typo in example.py

2013-04-02 19:54:41 -04:00
parent 1c5081e6b3
commit 2690a5da96
1 changed files with 1 additions and 1 deletions
--- a/example.py
+++ b/example.py
@@ -6,7 +6,7 @@ from kafka.producer import SimpleProducer

 def produce_example(client):
    producer = SimpleProducer(client, "my-topic")
-    producer.send_message("test")
+    producer.send_messages("test")

 def consume_example(client):
    consumer = SimpleConsumer(client, "test-group", "my-topic")