Demonstration of using Mysql replication protocol to stream Mysql changes into Kafka queues, then read from those queues and process Mysql changes in a Node.js script.

pip install -r requirements.txt
npm install

Oh, and go setup Kafka and get it running on localhost:9092.

Set RDS_URL in your environment, or add to a local .env file and run with foreman.

First, run the Mysql replication listener:

python mysql-replicate-to-kafka.py

and then run the Node.js app:

node consumer.js

Now go make some changes to your database and see them appear in the console of the node app.