sportscell / maxwell

Maxwell's daemon, a mysql-to-json kafka producer and we made Maxwell Active-Standby Mode.

Maxwell = Mysql + Kafka

This is Maxwell's daemon, an application that reads MySQL binlogs and writes row updates to Kafka as JSON. It's playing in the same space as mypipe and databus, but differentiates itself with these features:

• Works with an unpatched mysql
• Parses ALTER/CREATE/DROP table statements, which allows Maxwell to always have a correct view of the mysql schema
• Stores its replication position and needed data within the mysql server itself
• Requires no external dependencies (save Kafka, if used)
• Eschews the complexity of Avro for plain old JSON.
• Minimal setup

Maxwell is intended as a source for event-based readers, eg various ETL applications, search indexing, stat emitters.

• Download: https://github.com/zendesk/maxwell/releases/download/v1.1.5/maxwell-1.1.5.tar.gz
• Source: https://github.com/zendesk/maxwell

  mysql> insert into `test`.`maxwell` set id = 1, daemon = 'Stanislaw Lem';
  maxwell: {
    "database": "test",
    "table": "maxwell",
    "type": "insert",
    "ts": 1449786310,
    "xid": 940752,
    "commit": true,
    "data": { "id":1, "daemon": "Stanislaw Lem" }
  }

  mysql> update test.maxwell set daemon = 'firebus!  firebus!' where id = 1;
  maxwell: {
    "database": "test",
    "table": "maxwell",
    "type": "update",
    "ts": 1449786341,
    "xid": 940786,
    "commit": true,
    "data": {"id":1, "daemon": "Firebus!  Firebus!"},
    "old":  {"daemon": "Stanislaw Lem"}
  }

###Maxwell HA Mode

Maxwell is supported HA Mode ( Active-Standby Mode ).

./bin/maxwell-active-standby \ 
    --replication_host=replication_database \
    --replication_user=user \
    --replication_password=password \
    --replication_port=3306 \
    --user=maxwell \
    --password=maxwell \
    --host=maxwell_schema_database \
    --producer=stdout \
    
    ## Opstions for Maxwell HA Mode.
    --zkAddress=localhost:2181 \
    --clusterName=Maxwell_HAMODE \
    --instanceName=node1 \
    --nodeHostName=localhost \
    --clusterPort=12000 \
    --startController=true 

<script> jQuery(document).ready(function () { jQuery("#maxwell-header").append( jQuery("

") ); jQuery("pre").addClass("home-code"); }); </script>