diff --git a/example.py b/example.py index 1e4bd8b..3a2dc92 100644 --- 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")