1498658503 opened a new issue, #5276: URL: https://github.com/apache/seatunnel/issues/5276
### Search before asking - [X] I had searched in the [feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description kafka source如何解析复杂的json 例如： 我想获取META下的TYPE， BIZKEY，ARLINEID，AIRLINE这些字段存到table1中，存为一行 同时获取ROUTELST下的ROUTE是一个数组，把数组中的两个值存到另一个表table2里，存为两行数据 "MSG": { "META": { "SNDR": "NAOMS", "RCVR": "GOS", "SEQN": 128, "SENDTIME": "20230330 00:00:05", "TYPE": "DYNFLIGHT", "SUBTYPE": "RESPONSE" }, "DFLT": { "ID": 14209322, "CONNECTFLIGHT": { "ID": 477481309, "FLIGHTDATE": 20230329, "ARRFLIGHTID": 14209322, "DEPFLIGHTID": 14209463, "STAGEID": 400002, "STAGECODE": "DYN" }, "BIZKEY": "20230329-CZ6908-I-W/Z-202303291655", "ARLINEID": 57, "AIRLINE": "CZ", "FLIGHTNO": 6908, "FLIGHTDATE": 20230329, "STATUS": "ARR", "ABNSTATUSID": 100303, "ABNSTATUS": "DLY", "ABNRSN": "", "ROUTELST": { "ROUTE": [{ "ID": 477446855, "AIRPORTID": 436762, "AIRPORTIATA": "PKX", "REGIONID": 100001, "REGION": "DMST", "PLANLANDING": "", "ALTERLANDING": "", "REALLANDING": "", "PLANTAKEOFF": "20230329 12:40:00", "ALTERTAKEOFF": "", "REALTAKEOFF": "20230329 12:55:00", "ISALTERAIRPORT": 0, "ISEXECUTED": 0, "ROUTEORDER": 1 }, { "ID": 477446856, "AIRPORTID": 363, "AIRPORTIATA": "URC", "REGIONID": 100001, "REGION": "DMST", "PLANLANDING": "20230329 16:55:00", "ALTERLANDING": "20230329 16:50:00", "REALLANDING": "20230329 16:49:00", "PLANTAKEOFF": "", "ALTERTAKEOFF": "", "REALTAKEOFF": "", "ISALTERAIRPORT": 0, "ISEXECUTED": 0, "ROUTEORDER": 2 }] }, "HASVIP": 0, "BREAKCONN": 0, "DEPRESSDELAYALERT": 0, "NEEDDELAYCONFIRM": 0, "STAGE": 400002, "STAGECODE": "DYN", "FLIGHTSTATE": 100564, "FLIGHTSTATECODE": "PUBLISH", "NEEDPUBLIC": 1, "SEATLST": { "SEAT": { "SEATID": 85769, "SEATNAME": 29, "OCCUPYTYPE": "P", "SEATORDER": 1, "DRAGED": 0 } }, "ACRSLTIME": { "PLANOPENTIME": "20230329 17:04:00", "PLANENDTIME": "20230329 17:39:00", "REALOPENTIME": "20230329 17:04:00", "REALENDTIME": "20230329 17:39:00" }, "ACRSLLST": { "ACRSL": { "ACRSLID": 341977, "ACRSLNAME": 3, "BYAUTO": 0 } }, "DMSTBUILDING": "T3" } } } ### Usage Scenario _No response_ ### Related issues _No response_ ### Are you willing to submit a PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
