Skip to content

Commit 7165bc4

Browse files
majeeddlbradenneal1
authored andcommitted
Update usage.rst (dpkp#2334)
add imort json and msgpack into consumer and producer
1 parent f5cdb5c commit 7165bc4

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

docs/usage.rst

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ KafkaConsumer
88
.. code:: python
99
1010
from kafka import KafkaConsumer
11+
import json
12+
import msgpack
1113
1214
# To consume latest messages and auto-commit offsets
1315
consumer = KafkaConsumer('my-topic',
@@ -57,6 +59,8 @@ KafkaProducer
5759
5860
from kafka import KafkaProducer
5961
from kafka.errors import KafkaError
62+
import msgpack
63+
import json
6064
6165
producer = KafkaProducer(bootstrap_servers=['broker1:1234'])
6266

0 commit comments

Comments
 (0)