KyleAMathews

### Keybase proof

I hereby claim:

  * I am kyleamathews on github.
  * I am kylemathews (https://keybase.io/kylemathews) on keybase.
  * I have a public key whose fingerprint is BE2E BC1D 9BCB 884F 388C  755E 96DD 80AE BD38 773B

To claim this, I am signing this object:

KyleAMathews

Keybase proof

I hereby claim:

• I am kyleamathews on github.
• I am kylemathews (https://keybase.io/kylemathews) on keybase.
• I have a public key whose fingerprint is BE2E BC1D 9BCB 884F 388C 755E 96DD 80AE BD38 773B

To claim this, I am signing this object:

KyleAMathews

Keybase proof

I hereby claim:

• I am kyleamathews on github.
• I am kylemathews (https://keybase.io/kylemathews) on keybase.
• I have a public key whose fingerprint is E9DF 89EA 4B79 8E29 0240 1598 BF26 FBE1 9DD1 0A8E

To claim this, I am signing this object:

KyleAMathews

#!/bin/bash

# Start DBs
echo "Create test instances of Rethinkdb and Influxdb:"
number=$RANDOM
rethinkdb=`docker run -d --name rethinkdb-$number dockerfile/rethinkdb`
influxdb=`docker run -d --name influxdb-$number tutum/influxdb`
echo "Success!"
echo ""

KyleAMathews

ROUTES = Routes({
    location: "history"
}, Route({
    handler: Application
}, Route({
    name: "not-found",
    path: prefixedPath("/404"),
    handler: NotFound
}), Route({
    name: "home",

KyleAMathews

Mu: making programs easier to understand in the large

Imagine a world where you can:

a) think of a tiny improvement to a program you use, clone its sources, orient yourself on its organization and make your tiny improvement, all in a single afternoon.

b) Record your program as it runs, and easily convert arbitrary logs of runs into reproducible automatic tests.

KyleAMathews

Disclaimer

I'm still very new to Kafka, eventsourcing, stream processing, etc. I'm in the middle of building my first production system with this stuff and am writing this at the request of a few folks on Twitter. So if you do have experience, please do me and anyone else reading this a favor by pointing out things I get wrong :)

Inspirations

• The Log — http://engineering.linkedin.com/distributed-systems/log-what-every-software-engineer-should-know-about-real-time-datas-unifying
• Turning the database inside out — http://www.confluent.io/blog/2015/03/04/turning-the-database-inside-out-with-apache-samza/
• Why local state is a fundamental primitive in stream processing — http://radar.oreilly.com/2014/07/why-local-state-is-a-fundamental-primitive-in-stream-processing.html
• Samza
• Various functional systems been exposed to over past year or so, React, Flux, RX, etc.

KyleAMathews

config = require 'config'
redis = require 'redis'
mysql = require 'mysql'
request = require 'request'
assign = require 'object-assign'
_ = require 'underscore'

graphql = require('../utils/graphql')

# Listen to Kafka for new pageOpens, pageCreates

KyleAMathews

import React from 'react'
import ReactDOM from 'react-dom'
import { Router, Route, Link } from 'react-router';
import { history } from 'react-router/lib/HashHistory';
import ReactRouterRelay from 'react-router-relay'
import Relay from 'relay'

// Route components
import { App } from './components/app'
import PostsIndex from './components/posts_index'

KyleAMathews

import Relay from 'react-relay'

export default class ClickButtonMutation extends Relay.Mutation {
  static fragments = {
    viewer: () => Relay.QL`
      fragment on User {
        id
        buttonClicked
      }
    `,