Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-4041

Document how to enable schema for JSON messages

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Done
    • Icon: Major Major
    • 1.7.0.Final
    • 1.6.1.Final
    • documentation
    • None

      the debezium version is 1.6

      my connector config is :

      curl -H "Content-Type:application/json" -XPOST 'http://10.244.1.50:8083/connectors' -d '{
      "name": "test",
      "config":

      { "connector.class": "io.debezium.connector.mysql.MySqlConnector", "snapshot.locking.mode": "minimal", "database.user": "root", "database.server.id": "300000", "database.history.kafka.topic": "history.test", "database.history.kafka.bootstrap.servers": "10.244.1.50:9092,10.244.1.51:9092,10.244.1.52:9092", "database.server.name": "test", "database.port": "3306", "include.schema.changes": "true", "database.hostname": "10.244.1.51", "database.password": "123321", "name": "test", "table.include.list": "test.persons", "database.include.list": "test", "snapshot.mode": "initial", "internal.implementation": "legacy", "connect.timeout.ms": "50000" }

      }'

       

      and the data result is :

      {{ "before": null, "after":

      { "id": 35, "name": "aa" }

      , "source": { "version": "1.6.1.Final", "connector": "mysql", "name": "test", "ts_ms": 1632652549000, "snapshot": "false", "db": "test", "sequence": null, "table": "persons", "server_id": 2008, "gtid": null, "file": "mysql-bin.000004", "pos": 5247737, "row": 0, "thread": null, "query": null }, "op": "c", "ts_ms": 1632652549833, "transaction": null}

       

      I want to konw ,why has no schema and payload?

      thanks

       

       

              jpechane Jiri Pechanec
              chenjun1201 jun chen (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Created:
                Updated:
                Resolved: