We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f5cdb5c commit 7165bc4Copy full SHA for 7165bc4
docs/usage.rst
@@ -8,6 +8,8 @@ KafkaConsumer
8
.. code:: python
9
10
from kafka import KafkaConsumer
11
+ import json
12
+ import msgpack
13
14
# To consume latest messages and auto-commit offsets
15
consumer = KafkaConsumer('my-topic',
@@ -57,6 +59,8 @@ KafkaProducer
57
59
58
60
from kafka import KafkaProducer
61
from kafka.errors import KafkaError
62
63
64
65
producer = KafkaProducer(bootstrap_servers=['broker1:1234'])
66
0 commit comments