Demonstrates capturing new order from PostgresSQL database using Camel Debezium PostgresSQL Connector and perform data enrichment using Camel components. Output the result into a file with JSON formatted data.
The simulator query custid
from PostgresSQL
's braindose.customer
table randomly and also reads SKU from sku.csv file randomly and simulate a new Order creation in the braindose.order
and braindose.customerorder
tables.
The PostgresSQL
is populated with initdb.sh after the PostgresSQL
database is initiated.
The camel project provide the Camel Debezium PostgresSQL Connector implementation. New commited records are captured from the braindose.orders
table.
The result of the Camel processing is output at $OUTPUT_DIR/$OUTPUT_FILENAME
, in this demo the complete path is /tmp/dbzdemo/dbz-camel-order.output
. Watch the output using tail
tail -f /tmp/dbzdemo/dbz-camel-order.output
Run docker compose
to bring up the demo environment.
docker compose up --build