python-3.x - 在 python 中使用 Kafka 消息时，获取“utf-32-be”编解码器无法解码位置 4-7 中的字节：代码点不在范围内（0x110000）

Question

我目前正在生产和使用 json kafka 消息。我能够生成 Kafka 消息。

producer.produce(topic=TOPIC, value=json_msg, on_delivery=delivery_report)

consume(TOPIC, GROUP_NAME, Msg, '')

但是在消费时，我收到以下错误

'utf-32-be' codec can't decode bytes in position 4-7: code point not in range(0x110000)

我的消费者和生产者指向正确的模式、注册表和服务器。我不确定如何调试此问题。我手动输入了我的 Json 消息，认为复制粘贴 json 是一个问题，但是 . 有谁知道可能出了什么问题？