运行生产者或消费者时出现 Python Kafka SyntaxError答案

【问题标题】：Python Kafka SyntaxError while running a producer or a consumer运行生产者或消费者时出现 Python Kafka SyntaxError
【发布时间】：2019-07-28 21:37:49
【问题描述】：

我是 kafka 的新手，正在尝试使用链接 tutorial 创建一个简单的 hello world 应用程序。我让 zookeeper 运行，然后是 kafka-server-start 命令，但是当我执行生产者时，出现以下错误

Traceback (most recent call last):
  File "D:/Python/consumer.py", line 1, in <module>
    from kafka import KafkaConsumer
  File "D:\Python\venv\lib\site-packages\kafka\__init__.py", line 23, in <module>
    from kafka.producer import KafkaProducer
  File "D:\Python\venv\lib\site-packages\kafka\producer\__init__.py", line 4, in <module>
    from .simple import SimpleProducer
  File "D:\Python\venv\lib\site-packages\kafka\producer\simple.py", line 54
    return '<SimpleProducer batch=%s>' % self.async
                                                  ^
SyntaxError: invalid syntax

我尝试将 kafka-python 版本修改为 1.4.3，但似乎没有任何效果。任何指针将不胜感激以下是我的python文件：生产者.py：

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='localhost:9092')
producer.send('sample', b'Hello, World!')
producer.send('sample', key=b'message-two', value=b'This is Kafka-Python')

Consumer.py：

from kafka import KafkaConsumer
consumer = KafkaConsumer('sample')
for message in consumer:
    print (message)

我遵循的步骤是：
1.使用命令启动zookeeper

.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

2。 Zookeeper 启动后，我执行了命令

.\bin\windows\kafka-server-start.bat .\config\server.properties

3。当服务器启动时，我运行命令 python producer.py 后跟 consumer.py

谁能告诉我哪里出错了？谢谢！

【问题讨论】：

a python script fails to import kafka library while running inside docker的可能重复

标签： python apache-kafka apache-zookeeper

【解决方案1】：

您需要更改您的 python 版本 3.6。 3.7 存在一些兼容性问题。

查看a python script fails to import kafka library while running inside docker

【讨论】：