python操作kafka报错 self.async

python操作kafka报错：return '' % self.async

return '' % self.async
                                              ^^^^^
SyntaxError: invalid syntax

原因：

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

解决办法：

方法1：

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

方法2：

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