json type routine load job failed

[TCGOGOGO]

Steps to reproduce the behavior (Required)

just follow the example shown in official website
https://docs.starrocks.io/zh/docs/3.2/loading/RoutineLoad

Expected behavior (Required)

successfully data insert

Real behavior (Required)

Error message:

previous task aborted because of illegal json started with H

I also checked related code,

starrocks/be/src/exec/json_scanner.cpp

Line 786 in fd76273

return Status::DataQualityError(fmt::format("illegal json started with {}", c));

Warning log only shows invalid starting character, which in fact helpless for debugging. Hope more information of payload can be provided in exception situation
btw, below is the way I produce kafka message, json type message is ok checked by corresponding consumer

from kafka import KafkaProducer
from kafka.errors import KafkaError
from orjson import orjson

producer = KafkaProducer(bootstrap_servers=['xxxx'],
                         key_serializer=lambda m: bytes(m, encoding="utf-8") if m else None,
                         value_serializer=lambda m: orjson.dumps(m, option=orjson.OPT_NON_STR_KEYS))

try:
    data = {"commodity_id": "1", "customer_name": "Mark Twain", "country": "US","pay_time": 1589191487,"price": 875}
    producer.send('simon', data)
    producer.flush()
except KafkaError as e:
    print(e)

StarRocks version (Required)

3.2.8-759cc78