mayc0202 commented on issue #78: URL: https://github.com/apache/doris-kafka-connector/issues/78#issuecomment-3043304369
> Can you provide a sample message for Kafka?
{
"schema": {
"type": "struct",
"fields": [
{
"type": "struct",
"fields": [
{
"type": "int64",
"optional": false,
"field": "id"
},
{
"type": "string",
"optional": true,
"default": "",
"field": "name"
},
{
"type": "string",
"optional": false,
"field": "email"
},
{
"type": "string",
"optional": true,
"default": "",
"field": "phone"
},
{
"type": "int16",
"optional": true,
"default": 0,
"field": "gender"
},
{
"type": "string",
"optional": false,
"field": "password"
},
{
"type": "int16",
"optional": true,
"default": 0,
"field": "age"
},
{
"type": "int64",
"optional": true,
"name":
"org.apache.kafka.connect.data.Timestamp",
"version": 1,
"default": 0,
"field": "create_time"
},
{
"type": "string",
"optional": true,
"name":
"io.debezium.time.ZonedTimestamp",
"version": 1,
"field": "update_time"
}
],
"optional": true,
"name": "SERVER275_.xqh_ddtt.app_user2.Value",
"field": "before"
},
{
"type": "struct",
"fields": [
{
"type": "int64",
"optional": false,
"field": "id"
},
{
"type": "string",
"optional": true,
"default": "",
"field": "name"
},
{
"type": "string",
"optional": false,
"field": "email"
},
{
"type": "string",
"optional": true,
"default": "",
"field": "phone"
},
{
"type": "int16",
"optional": true,
"default": 0,
"field": "gender"
},
{
"type": "string",
"optional": false,
"field": "password"
},
{
"type": "int16",
"optional": true,
"default": 0,
"field": "age"
},
{
"type": "int64",
"optional": true,
"name":
"org.apache.kafka.connect.data.Timestamp",
"version": 1,
"default": 0,
"field": "create_time"
},
{
"type": "string",
"optional": true,
"name":
"io.debezium.time.ZonedTimestamp",
"version": 1,
"field": "update_time"
}
],
"optional": true,
"name": "SERVER275_.xqh_ddtt.app_user2.Value",
"field": "after"
},
{
"type": "struct",
"fields": [
{
"type": "string",
"optional": false,
"field": "version"
},
{
"type": "string",
"optional": false,
"field": "connector"
},
{
"type": "string",
"optional": false,
"field": "name"
},
{
"type": "int64",
"optional": false,
"field": "ts_ms"
},
{
"type": "string",
"optional": true,
"name": "io.debezium.data.Enum",
"version": 1,
"parameters": {
"allowed":
"true,last,false,incremental"
},
"default": "false",
"field": "snapshot"
},
{
"type": "string",
"optional": false,
"field": "db"
},
{
"type": "string",
"optional": true,
"field": "sequence"
},
{
"type": "string",
"optional": true,
"field": "table"
},
{
"type": "int64",
"optional": false,
"field": "server_id"
},
{
"type": "string",
"optional": true,
"field": "gtid"
},
{
"type": "string",
"optional": false,
"field": "file"
},
{
"type": "int64",
"optional": false,
"field": "pos"
},
{
"type": "int32",
"optional": false,
"field": "row"
},
{
"type": "int64",
"optional": true,
"field": "thread"
},
{
"type": "string",
"optional": true,
"field": "query"
}
],
"optional": false,
"name": "io.debezium.connector.mysql.Source",
"field": "source"
},
{
"type": "string",
"optional": false,
"field": "op"
},
{
"type": "int64",
"optional": true,
"field": "ts_ms"
},
{
"type": "struct",
"fields": [
{
"type": "string",
"optional": false,
"field": "id"
},
{
"type": "int64",
"optional": false,
"field": "total_order"
},
{
"type": "int64",
"optional": false,
"field": "data_collection_order"
}
],
"optional": true,
"field": "transaction"
}
],
"optional": false,
"name": "SERVER275_.xqh_ddtt.app_user2.Envelope"
},
"payload": {
"before": {
"id": 9,
"name": "用户8",
"email": "[email protected]",
"phone": "13410008625",
"gender": 1,
"password": "55552cfb-a092-11ef-a4b7-0242ac110003",
"age": 68,
"create_time": 1672531200000,
"update_time": "2025-01-21T06:32:53Z"
},
"after": null,
"source": {
"version": "1.9.5.Final",
"connector": "mysql",
"name": "SERVER275_",
"ts_ms": 1751361914000,
"snapshot": "false",
"db": "xqh-ddtt",
"sequence": null,
"table": "app_user2",
"server_id": 223344,
"gtid": null,
"file": "mysql-bin.000242",
"pos": 993120582,
"row": 0,
"thread": 1423792,
"query": null
},
"op": "d",
"ts_ms": 1751364381975,
"transaction": null
}
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
