Python3.X 执行Python编写的生产者和消费者报错，报错信息如下：

Traceback (most recent call last):
File "mykit_kafka_producer.py", line 9, in <module>
from kafka import KafkaProducer
File "/usr/local/lib/python3.7/site-packages/kafka/__init__.py", line 23, in <module>
from kafka.producer import KafkaProducer
File "/usr/local/lib/python3.7/site-packages/kafka/producer/__init__.py", line 4, in <module>
from .simple import SimpleProducer
File "/usr/local/lib/python3.7/site-packages/kafka/producer/simple.py", line 54
return '<SimpleProducer batch=%s>' % self.async
^
SyntaxError: invalid syntax

原因

python3.7新增关键字：async、await；

kafka-python 用到了关键字async，由此带来兼容性问题

解决

使用Python 3.6版本即可正常运行。

注意：先安装 kafka ，然后安装 kafka-python

pip install kafka
pip install kafka-python