[Bug] [MySQL CDC] Cannot capture change data

[Jiangnanjiezi]

Search before asking

• [X] I had searched in the issues and found no similar issues.

What happened

When I use MySQL CDC to synchronize data to Kafka, I can only get initialized data. Subsequent the data changes, whether add or delet, cannot capture the changed data. The data in Kafka is not change。

SeaTunnel Version

2.3.5

SeaTunnel Config

env {
  parallelism = 1
  job.mode = "STREAMING"
  checkpoint.interval = 10000
}

source {
  MySQL-CDC {
    base-url = "jdbc:mysql://up01:3306/hive_data"
    username = "root"
    password = "123456"
    start.mode = "initial"
    server-time-zone = "Asia/Shanghai"
    exactly_once = "true"
    table-names = ["hive_data.shop_order"]
    table-names-config = [
      {
        table = "hive_data.shop_order"
        primaryKeys = ["id"]
      }
    ]

    format = compatible_debezium_json
    debezium = {
        snapshot.mode = "never"
        # include schema into kafka message
        key.converter.schemas.enable = false
        value.converter.schemas.enable = false
        # include ddl
        include.schema.changes = true
        # topic prefix
        database.server.name =  "mysql_cdc"
    }
  }
}

sink {
  kafka {
      topic = "test_topic"
      bootstrap.servers = "up01:9092"
      format = compatible_debezium_json
      kafka.request.timeout.ms = 60000
      semantics = EXACTLY_ONCE
      transaction_prefix = "sot"
      kafka.config = {
        acks = "all"
        request.timeout.ms = 60000
        buffer.memory = 33554432
      }
  }
}

Running Command

cd /export/server/apache-seatunnel-2.3.5/
./bin/seatunnel.sh --config ./config/job/shop_order_to_kafka.config -e local

Error Exception

none

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

Screenshots

No response

Are you willing to submit PR?

• [X] Yes I am willing to submit a PR!

Code of Conduct

• [X] I agree to follow this project's Code of Conduct

[zhilinli123]

Can you provide DDL