IBMi Debezium result
25 views
Skip to first unread message
Haydar Miezanie Abdul Jamil
Jan 27, 2026, 4:13:50 AM (7 days ago) Jan 27
to debezium
Hi everyone, I’m wondering if the Debezium results on IBM i behave differently compared to other platforms. I couldn’t find the before/after values, and it seems the operation isn’t encoded yet.
{
"schema": {
"name": "CDC.TEST.DBZ.Value",
"optional": false,
"type": "struct",
"fields": [
{
"field": "B23CUSID",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "0",
"connect.decimal.precision": "11"
}
},
{
"field": "B23PNO",
"optional": false,
"type": "string"
},
{
"field": "B23FNAM",
"optional": false,
"type": "string"
},
{
"field": "B23NAM",
"optional": false,
"type": "string"
},
{
"field": "B23AGCD1",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "0",
"connect.decimal.precision": "14"
}
},
{
"field": "B23AGCD2",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "0",
"connect.decimal.precision": "14"
}
},
{
"field": "B23PWTH",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "2",
"connect.decimal.precision": "17"
}
},
{
"field": "B23PSUR",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "2",
"connect.decimal.precision": "17"
}
},
{
"field": "B23RBPR",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "2",
"connect.decimal.precision": "17"
}
},
{
"field": "B23PCNP",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "2",
"connect.decimal.precision": "17"
}
},
{
"field": "B23TRND",
"name": "org.apache.kafka.connect.data.Decimal",
"optional": false,
"type": "bytes",
"version": 1,
"parameters": {
"scale": "0",
"connect.decimal.precision": "8"
}
},
{
"field": "B23RTYP",
"optional": false,
"type": "string"
}
]
},
"payload": {
"B23PSUR": "BRR5gWY=",
"B23TRND": "ATTbTw==",
"B23PNO": "12345678",
"B23AGCD1": "O8vS+iKH",
"B23RBPR": "AA==",
"B23AGCD2": "AA==",
"B23PCNP": "AA==",
"B23FNAM": "",
"B23CUSID": "Ao5w",
"B23RTYP": "",
"B23NAM": "ADH UIZHJPJ",
"B23PWTH": "AA=="
}
}
jiri.p...@gmail.com
Jan 27, 2026, 4:14:53 AM (7 days ago) Jan 27
to debezium
Hi,
this looks like you have used ExtractNewRecordState SMT in your connector config.
Can you please share it?
Jiri
Haydar Miezanie Abdul Jamil
Jan 27, 2026, 4:48:38 AM (7 days ago) Jan 27
to debezium
yup correct
{
"name": "TEST",
"config": {
"connector.class": "io.debezium.connector.db2as400.As400RpcConnector",
"sanitize.field.names": "true",
"tasks.max": "1",
"database.hostname": "0.0.0.0",
"database.dbname": "",
"database.schema": "TEST",
"database.user": "USER",
"database.password": "USER",
"database.secure" : "false",
"database.port": "446",
"secure" : "false",
"topic.prefix": "RLS",
"poll.interval.ms": "2000",
"snapshot.mode": "initial",
"table.include.list": "DG4IBUDTA.LFPAREDT",
"transforms": "unwrap",
"schemas.enable":"false",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
"transforms.unwrap.delete.handling.mode": "rewrite",
"transforms.unwrap.drop.tombstones": "false",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.convertes.schemas.enable": "false",
"key.converter.schema.registry.url": "http://schema-registry:8088",
"value.converter.schema.registry.url": "http://schema-registry:8088",
"snapshot.max.threads": 4
}
}
Haydar Miezanie Abdul Jamil
Jan 27, 2026, 6:44:27 AM (7 days ago) Jan 27
to debezium
I also facing an issue with the journal receiver rotation. Restarting Debezium hasn’t resolved it so far.
2026-01-27T11:41:29,956 INFO Db2As400_Server||streaming Current position diagnostics '{behind=0, header=FirstHeader [totalBytes=0, offset=0, size=0, status=NOT_CALLED, nextPosition=JournalProcessedPosition [offset=5741, receiver=JournalReceiver[name=LFJRN10086, library=DG4IBUDTA], timeOfLastProcessed=1970-01-01T00:00:00Z, processed=true]], position=JournalProcessedPosition [offset=5741, receiver=JournalReceiver[name=LFJRN10086, library=DG4IBUDTA], timeOfLastProcessed=2026-01-20T10:08:34Z, processed=true], currentReceiver=JournalPosition[offset=5741, receiver=JournalReceiver[name=LFJRN10086, library=DG4IBUDTA]], success=true}' [io.debezium.connector.db2as400.As400RpcConnection]
Reply all
Reply to author
Forward
0 new messages