python操作kafka报错:return '<SimpleProducer batch=%s>' % self.async

return '<SimpleProducer batch=%s>' % self.async
                                              ^^^^^
SyntaxError: invalid syntax

原因:

因为py3.7里面async已经变成了关键字。所以导致了不兼容。 

解决办法:

方法1:

使用最新的kafka版本,但是pyPI上的kafka还没有被替换成最新的,可以使用下面的方法升级kafka python
pip install kafka-python

方法2:

切换到3.6版本就可以了,等待后续升级完善

 

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐