mysql2-replication

require "mysql2-replication"

client = Mysql2::Client.new(username: "root",
                            password: "secret")
# Get the latest binlog file and position from source.
# You can specify them manually.
master_status = client.query("SHOW MASTER STATUS").first
file = master_status["File"]
position = master_status["Position"]

replication_client = Mysql2Replication::Client(client)
replication_client.file_name = file
replication_client.start_position = position
replication_client.open do
  replication_client.each do |event|
    pp event
  end
end