demo.md

Prepare

mvn clean package -f event-source/pom.xml mvn clean package -f aggregator/pom.xml docker-compose -f docker-compose-mysql up --build

Console

• Observe how order entries are produced:

mycli mysql://mysqluser@localhost:3306/inventory --password mysqlpw

• Register MySQL connector:

cat mysql-source.json | http POST http://localhost:8083/connectors/

• Browse topics

docker run --tty
--network kstreams-live-update_default
quay.io/debezium/tooling:1.2
kafkacat -b kafka:9092 -C -o end -q
-t dbserver1.inventory.orders | jq .payload

docker run --tty
--network kstreams-live-update_default
quay.io/debezium/tooling:1.2
kafkacat -b kafka:9092 -C -o beginning -q
-t dbserver1.inventory.categories | jq .payload

docker run --tty
--network kstreams-live-update_default
quay.io/debezium/tooling:1.2
kafkacat -b kafka:9092 -C -o beginning
-t sales_per_category -K " --- "

• Updated chart in browser: http://localhost:8079

Bonus: Elasticsearch

cat es-sink.json | http POST http://localhost:8083/connectors/

http "http://localhost:9200/orders/_search?pretty"

Misc.

docker-compose -f docker-compose-mysql exec kafka /kafka/bin/kafka-topics.sh --bootstrap-server kafka:9092 --list