'flinksql read custom format data with json

I am trying to read streaming data from Kafka, where streaming logs with the format as below

03-06-2022 02:56:130 INFO [...] [...] {"a": "abc", "b": 123}

I want to extract the JSON part from the logs, which is the {"a": "abc", "b": 123} part, and load it as a streaming table with columns a and b. Can anyone provide me with the appropriate config in the Flink SQL table?



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source