JSON错误“期望值:第2行第11列(字符12)”

2024-05-16 14:52:08 发布

您现在位置:Python中文网/ 问答频道 /正文

我正在运行下面的代码以从python中的ApacheKafka使用者获取数据

from kafka import KafkaConsumer
import json

consumer = KafkaConsumer("DataEngFuelData", bootstrap_servers=['localhost:9092'], group_id=None,
                         auto_offset_reset='earliest')
try:
    for msg in consumer:
        decoded_msg = msg.value.decode('utf-8-sig')
        decoded_msgtmp = json.loads(decoded_msg)
        print(decoded_msgtmp)
        dictmsg = decoded_msgtmp['stations']
        print(dictmsg)

except Exception as e:      
    print(e)

但是,当程序执行json.loads()函数时,它给出了一个错误

Expecting value: line 2 column 11 (char 12).

Tags: 代码fromimportjsonconsumervalue使用者msg