【Kafka】使用kafka-python发送消息时,出现assert type(value_bytes) in (bytes, bytearray, memoryview, type(None))

引起这问题是,send这个函数,给Kafka穿的不是二进制类型,换成二进制类型,调用.enocde()函数就将字符串类型变成了beytes类型。

Edit me