Debezium PostgresConnector to kafka topic

Hi all!

Just to bring a view of my current (POC).

I have a Postgres Database with a table, which contains multiple columns.
One of these columns is a Jsonb type.

I have a Debezium connect to capture the data changes of the database to send all of them to a Kafka Topic.

I have been trying to configure the connector using multiple different plugins.
The idea is to expand the Jsonb column to have all the key-value data in the Kafka topic also with the data from the rest of the columns.

This is my current Debezium connector configuration:
“name”: “basket-connector”,
“config”: {
“connector.class”: “io.debezium.connector.postgresql.PostgresConnector”,
“tasks.max”: “1”,
“database.hostname”: “postgres”,
“database.port”: “5432”,
“database.user”: “postgres”,
“database.password”: “postgres”,
“database.dbname” : “basket”,
“topic.prefix”: “consultancy.dbz”,
“table.include.list”: “public.basket_entity”,
“key.converter”: “io.confluent.connect.avro.AvroConverter”,
“key.converter.schema.registry.url”: “”,
“value.converter”: “io.confluent.connect.avro.AvroConverter”,
“value.converter.schema.registry.url”: “”,
“transforms”: “expand”,
“transforms.expand.type”: “com.redhat.insights.expandjsonsmt.ExpandJSON$Value”,
“transforms.expand.sourceFields”: “basket”


I hope someone could help me with this to solve the issue.


It’s not possible to “move up” any nested fields without overriding others. For example, what if there was a basket key within that JSONB value?

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.