[DRAFT]

What's this software for?

This repository contains the data processing software to convert and push the data stored using the Debezium connector to the inBlocks precedence REST API.

demo

Run it!

From Docker

docker pull inblocks/precedence-debezium
docker run --rm \
    --network host \
    -e PRECEDENCE_API=http://localhost:9000 \
    -e PRECEDENCE_APPLICATION_ID=precedence-demo-inventory \
    -e PRECEDENCE_BOOTSTRAP_SERVERS=localhost:9093 \
    -e PRECEDENCE_INPUT_TOPIC_PATTERN=^demo\.inventory\..* \
    -e PRECEDENCE_STORE=true \
    inblocks/precedence-debezium

From sources

# Maven build
mvn package

export PRECEDENCE_API=http://localhost:9000
export PRECEDENCE_APPLICATION_ID=precedence-demo-inventory
export PRECEDENCE_BOOTSTRAP_SERVERS=localhost:9093
export PRECEDENCE_INPUT_TOPIC_PATTERN=^demo\.inventory\..*
export PRECEDENCE_STORE=true

java -cp ./target/debezium.jar io.inblocks.precedence.Debezium

Ongoing developments

• inBlocks precedence REST API authentication (SaaS)
• precedence Java client (dedicated project)