[BUG] KafkaSource UnicodeDecodeError when consuming non-UTF-8 message keys, even with RAW_VALUE serialization_method #5853
Description
Mage version
v0.9.6
Describe the bug
Using RAW_VALUE method-
serde_config:
serialization_method: RAW_VALUE
Getting this error-
'key': message.key.decode() if message.key else None,
UnicodeDecodeError: 'utf-8' codec can't decode byte 0x83 in position 4: invalid start byte
To reproduce
No response
Expected behavior
No response
Screenshots
No response
Operating system
No response
Additional context
No response