mysql-debezium-cdc-to-mongo: A Shell repository from Sunnyvale S.r.l.

List DB test.tasks records

$ docker exec -i mysql mysql -uroot -ppassword  <<< "select * from test.tasks;"

Insert a DB record in test.tasks table

$ docker exec -i mysql mysql -uroot -ppassword  <<< "INSERT INTO test.tasks (\`title\`,\`status\`,\`priority\`,\`description\`,\`created_at\`)VALUES('test',1,1,'test',CURRENT_TIMESTAMP);"

List Kafka topics

$ docker exec -i kafka /opt/kafka/bin/kafka-topics.sh --list --bootstrap-server=kafka:9092

Browse CDC Kafka topic

$ docker exec -i kafka /opt/kafka/bin/kafka-console-consumer.sh \
  --topic mysql.test.tasks \
  --bootstrap-server kafka:9092 \
  --from-beginning \
  --property print.key=true \
  --property key.separator="-"

$ docker exec -i mongodb mongo --authenticationDatabase admin -u root -p password --quiet --eval  "db.getCollection('cdc').find().forEach(printjson)" mongodb://localhost:27017/mydata

docker exec -i mongodb mongoimport --authenticationDatabase admin -u root -p password --db mydata --collection cdc <<EOF
{
        "name": "denis"
}
EOF

sunnyvale-it/mysql-debezium-cdc-to-mongo