Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Stream MySQL binary logs and consume them with Scala actors (RabbitMQ, Kafka).

branch: master

Fetching latest commit…

Octocat-spinner-32-eaf2f5

Cannot retrieve the latest commit at this time

Octocat-spinner-32 config
Octocat-spinner-32 lib
Octocat-spinner-32 project
Octocat-spinner-32 scripts
Octocat-spinner-32 src
Octocat-spinner-32 README.md
Octocat-spinner-32 guzzler-example.conf
README.md

Guzzler: Stream MySQL binary logs and act on them

Guzzler allows you to stream MySQL binary logs from a master and lets you act on them using Scala actors (consumers). Consumers are configurable in guzzler.conf along with the rest of the required parameters. Included with Guzzler is a RabbitMQ consumer that will push queries into a RabbitMQ server for consumption.

Guzzler can start, stop, restart and seek in the binary logs via a remote SSH interface. Guzzler handles connection issues or random disconnects and attempts to pick up where it left off.

Consumers either in Guzzler itself of behind RabbitMQ can analyze the queries (Guzzler provides an SQL query parser based on JSqlParser) and may decide to update counters, fire off events, log messages, etc.

Sample SSH session (no auth yet):

-=[ Welcome to Guzzler ]=-

guzzler stream stop
guzzler stream seek db-bin.000924 900993280
    guzzler stream stop
    guzzler stream resume

JSqlParser: http://sourceforge.net/projects/jsqlparser/

Something went wrong with that request. Please try again.