seatunnel icon indicating copy to clipboard operation
seatunnel copied to clipboard

v2 kafka json analysis

Open 365323507 opened this issue 2 years ago • 1 comments

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

365323507 avatar Oct 25 '22 03:10 365323507

schema {
  a1 = string
  b1 = {
    proxy = int
  }
}

TyrantLucifer avatar Oct 25 '22 11:10 TyrantLucifer