From d69f7d1d464d2194af993f3df64c79cfb0b48436 Mon Sep 17 00:00:00 2001 From: Majeed Dourandeesh Date: Mon, 31 Oct 2022 16:02:19 +0300 Subject: [PATCH] Update usage.rst add imort json and msgpack into consumer and producer --- docs/usage.rst | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/docs/usage.rst b/docs/usage.rst index 1cf1aa414..fb58509a7 100644 --- a/docs/usage.rst +++ b/docs/usage.rst @@ -8,6 +8,8 @@ KafkaConsumer .. code:: python from kafka import KafkaConsumer + import json + import msgpack # To consume latest messages and auto-commit offsets consumer = KafkaConsumer('my-topic', @@ -57,6 +59,8 @@ KafkaProducer from kafka import KafkaProducer from kafka.errors import KafkaError + import msgpack + import json producer = KafkaProducer(bootstrap_servers=['broker1:1234'])