Merge pull request #564 from shichao-an/master
Add missing imports: KafkaError
This commit is contained in:
@@ -56,6 +56,7 @@ KafkaProducer
|
|||||||
.. code:: python
|
.. code:: python
|
||||||
|
|
||||||
from kafka import KafkaProducer
|
from kafka import KafkaProducer
|
||||||
|
from kafka.common import KafkaError
|
||||||
|
|
||||||
producer = KafkaProducer(bootstrap_servers=['broker1:1234'])
|
producer = KafkaProducer(bootstrap_servers=['broker1:1234'])
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user