debezium_tables.sql

CREATE TABLE MOVIES(movie_id INT(10), title VARCHAR(30), year VARCHAR(4), budget INT(8));
CREATE TABLE SALES(movie_id INT(10), sale_id INT(10), total INT(10));