-
Bug
-
Resolution: Duplicate
-
Major
-
None
-
0.9.0.Beta1
-
None
The inner schema created is using the dbname ("database_name" in the example below) in the namespace instead if the logical server.name ("logical_cluster_name" in the example).
See:
{
"type": "record",
"name": "Envelope",
"namespace": "logical_cluster_name.dbo.table_name",
"fields": [
{
"name": "before",
"type": [
"null",
{
"type": "record",
"name": "Value",
"namespace": "logical_cluster_name.database_name.dbo.table_name",
"fields": [
{
"name": "intUserID",
"type": "int"
},
[...]
],
"connect.name": "logical_cluster_name.database_name.dbo.table_name.Value"
}
],
"default": null
},
{
"name": "after",
"type": [
"null",
"logical_cluster_name.database_name.dbo.table_name.Value"
],
"default": null
},
{
"name": "source",
"type": {
"type": "record",
"name": "Source",
"namespace": "io.debezium.connector.sqlserver",
"fields": [
{
"name": "version",
"type": [
"null",
"string"
],
"default": null
},
{
"name": "connector",
"type": [
"null",
"string"
],
"default": null
},
{
"name": "name",
"type": "string"
},
{
"name": "ts_ms",
"type": [
"null",
"long"
],
"default": null
},
{
"name": "change_lsn",
"type": [
"null",
"string"
],
"default": null
},
{
"name": "commit_lsn",
"type": [
"null",
"string"
],
"default": null
},
{
"name": "snapshot",
"type": [
"null",
"boolean"
],
"default": null
}
],
"connect.name": "io.debezium.connector.sqlserver.Source"
}
},
{
"name": "op",
"type": "string"
},
{
"name": "ts_ms",
"type": [
"null",
"long"
],
"default": null
}
],
"connect.name": "logical_cluster_name.dbo.table_name.Envelope"
}
This is also true of the schema for the key:
{
"type": "record",
"name": "Key",
"namespace": "logical_cluster_name.database_name.dbo.table_name",
"fields": [
{
"name": "intUserID",
"type": "int"
}
],
"connect.name": "logical_cluster_name.database_name.dbo.table_name.Key"
}
- duplicates
-
-
- Closed
-
