我试图阅读Kafka主题使用流和提取值是json格式。我在kafka主题中有以下json格式的消息，但没有用逗号分隔。
如何提取id和消息的值：

{
    "id":"20168374652257"
    "message":"testFromPubSub2018_09_18_22"
}

我尝试了下面的代码，但它给出了空值，因为它没有用逗号分隔：

val kafka_data =df.select($"value" cast "string" as "value").
      select(get_json_object($"value", "$.id").as("id"),
        get_json_object($"value", "$.message").as("message"))

提前谢谢