Embedded Debezium with Vert.x and RxJava

This example shows how to use Embedded Debezium with Vert.x, RxJava, PostgreSQL and MySQL.

Architecture

There are four verticles:

db.DBVerticle periodically inserts row to certain table.
DebeziumRecordSenderVerticle reads record from the database and publish to certain address.
RecordReceiverVerticle subscribe to certain address and handle the received message.
MainVerticle deploys verticles.

In the example, the following verticles are deployed as child verticles of MainVerticle:

two db.DBVerticles add random rows to tables foo and bar, respectively.
one DebeziumRecordSenderVerticle is deployed.
two RecordReceiverVerticles print records based on tables' names.

Requirements

JDK 11 or later
Docker 19.03.8 or later
Gradle 6.1.1 or later
Vert.x 3.9.1
RxJava 2
Debezium 1.2.0.Final
PostgreSQL 12
MySQL 8

Start database

A database should be running before deploy the main verticle. In order to start a database, one of the following scripts can be used:

PostgreSQL
```
./start_postgres.sh  
```
MySQL
```
./start_mysql.sh  
```

Run in Intellij

In MainVerticle, run the main function. You need to configure to choose conf-postgres.json or conf-mysql.json as the argument.

Compile and run

./gradlew clean build

java -jar ./build/libs/embedded-debezium-vertx-rxjava-1.0-SNAPSHOT-all.jar -conf <config-file>

where <config-file> can be src/main/resources/conf-postgres.json or src/main/resources/conf-mysql.json depending on the database that is started before.

Expected output

INFO: Succeeded in deploying verticle
Receiver 1 is ready!
Receiver 2 is ready!
Receiver 1: Received news: foo
Receiver 2: Received news: bar
Receiver 1: Received news: foo
Receiver 2: Received news: bar