我正在运行下面的代码以从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).
目前没有回答
相关问题 更多 >
编程相关推荐