遇到以下错误：

SyntaxError: 代码的这一行存在无效语法错误 -> parsed_json = kstream.map(lambda (k,v): json.loads()) 箭头指向 (>k,a)，代码链接是 https://github.com/patilankita79/Location-based-Restaurants-Recommendation-System/blob/master/BigDataProject/Consumer.py

回答：

错误出在lambda函数的签名上。正确的写法是：

kstream.map(lambda k, v: json.loads(v))