使用python代码在kafka集群下报错

我的生产端应该没问题，也成功创建了一个主题sex。

但我的消费端不知道为什么消费不了，报这样的错。

这是我消费端的代码