Schema definition to process any JSON object

[ashish-gpt]

Hi Team,

I have below template and just want to check how I can remove/change schema definition so that it will start processing any JSON object and storing into Elastic.

env {

execution.parallelism = 1

job.mode = "STREAMING"

}

source {

Kafka {

   schema {

     fields {

       code = int

       data = string

       success = boolean

     }

   }

    topic = "QA_TEST"

    bootstrap.servers = "localhost:9093"

    consumer.group = "seatunnel_group"

}

}

sink {

Elasticsearch {

hosts = [https://localhost:9243/]

username = "xxxxx"

password = "xxxxx"

index = "vd-seatunnel-test"

tls_verify_certificate = false

tls_verify_hostname = false

schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"

data_save_mode = "APPEND_DATA"

}

}