seatunnel
seatunnel copied to clipboard
v2 kafka json analysis
Search before asking
- [X] I had searched in the feature and found no similar feature requirement.
Description
source { Kafka { topic = "Log" bootstrap.servers = "hdp01:9092" schema = { fields { a1= "string" b1= } } result_table_name = test } }
How to configure schema
{ "a1": "cs", "b1": { "proxy": 100 } }
Usage Scenario
v2 kafka json
How to configure schema
{ "a1": "cs", "b1": { "proxy": 100 } }
Related issues
No response
Are you willing to submit a PR?
- [X] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct
schema {
a1 = string
b1 = {
proxy = int
}
}