'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 |
---|