Seatunnel connector kafka supports parsing data extracted through kafka connect source, especially data extracted from kafka connect jdbc and kafka connect debezium

How To Use

Kafka Sink Mysql

  1. env {
  2.     parallelism = 1
  3.     job.mode = "BATCH"
  4. }
  6. source {
  7.   Kafka {
  8.     bootstrap.servers = "localhost:9092"
  9.     topic = "jdbc_source_record"
  10.     result_table_name = "kafka_table"
  11.     start_mode = earliest
  12.     schema = {
  13.       fields {
  14.            id = "int"
  15.            name = "string"
  16.            description = "string"
  17.            weight = "string"
  18.       }
  19.     },
  20.     format = COMPATIBLE_KAFKA_CONNECT_JSON
  21.   }
  22. }
  25. sink {
  26.     Jdbc {
  27.         driver = com.mysql.cj.jdbc.Driver
  28.         url = "jdbc:mysql://localhost:3306/seatunnel"
  29.         user = st_user
  30.         password = seatunnel
  31.         generate_sink_sql = true
  32.         database = seatunnel
  33.         table = jdbc_sink
  34.         primary_keys = ["id"]
  35.     }
  36. }