Я запускаю приведенный ниже код для извлечения данных от потребителя apache kafka в python.
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).