当通过python3执行kafka时出现return '' % self.async的解决办法

1、出错信息如下:

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

如下图所示:

2、因为py3.7里面async已经变成了关键字。所以导致了不兼容,因此通过python -m pip install kafka-python进行版本升级,这里的python模式是3版本,如下图所示:

3、此时再次执行即可,如下图所示:


版权声明:本文为sunxiaoju原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。