Getting `'utf-32-be' codec can't decode bytes in position 4-7: code point not in range(0x110000)` while consuming Kafka message in python

Viewed 244

I am currently producing and consuming json kafka messages. I am able to produce the Kafka message.

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

consume(TOPIC, GROUP_NAME, Msg, '')

But while consuming, I get the following error

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

My consumer and producer point to the correct schema, registry and servers. I am not sure how to debug this issue. I manually entered my Json message thinking copy pasting the json was an issue, but . Does anyone have any idea on what could be wrong?

0 Answers
Related