Skip to content

Latest commit

 

History

History
20 lines (14 loc) · 662 Bytes

README.md

File metadata and controls

20 lines (14 loc) · 662 Bytes

Debezium KSQL Demo

This demo accompanies the blog post Querying Debezium Change Data Events With KSQL.

# Start the Kafka, Kafka Connect, KSQL server and CLI etc.
export DEBEZIUM_VERSION=2.1
docker-compose up

# Start Debezium MySQL connector
curl -i -X POST -H "Accept:application/json" -H  "Content-Type:application/json" http://localhost:8083/connectors/ -d @register-mysql.json

# Launch KSQL CLI
docker-compose exec ksql-cli ksql http://ksql-server:8088

# Run KSQL commands as described in the blog post...

# Shut down the cluster
docker-compose down