Skip to content

Latest commit

 

History

History
 
 

ksql

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 

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