CODEWITHSUNDEEP
postgresqlapache-kafkadebezium
Stavros Koureas
Stavros Koureas

Reputation: 1482

Insert Debezium records in another database

I have PostgreSQL database in Azure. In addition I have a Debezium connector pointing to this database. This connector produces data from some selected tables when new data are inserted into those tables.

Using Kafkacat, I can see the upsert records enter image description here

Now I am looking a way where I can make a kafka consumer which will insert those records in another database while doing some slight modifications on each row.

Any idea?

Upvotes: 0

Views: 112

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191864

You can use Kafka Connect JDBC sink to write to another JDBC-compatible database.

Kafka Connect Transforms will allow you to do "slight modifications" on specific fields.

Upvotes: 2

Related Questions