Alejandro Pedraza alpeb

Introduction to Kafka

Kafka acts as a kind of write-ahead log (WAL) that records messages to a persistent store (disk) and allows subscribers to read and apply these changes to their own stores in a system appropriate time-frame.

Terminology:

Producers send messages to brokers
Consumers read messages from brokers
Messages are sent to a topic

Business Models

Advertising

Models	Examples
Display ads	Yahoo!
Search ads	Google

	load.ivy("org.postgresql" % "postgresql" % "9.4-1206-jdbc4")
	load.ivy("com.typesafe.slick" %% "slick" % "3.1.1")
	load.ivy("org.slf4j" % "slf4j-nop" % "1.6.4")

	import slick.driver.PostgresDriver
	import slick.driver.PostgresDriver.api._
	import scala.concurrent.ExecutionContext.Implicits.global
	import slick.jdbc.GetResult._
	import scala.concurrent.Future
	import scala.concurrent.Await

	-- Remove the history from
	rm -rf .git

	-- recreate the repos from the current content only
	git init
	git add .
	git commit -m "Initial commit"

	-- push to the github remote repos ensuring you overwrite history
	git remote add origin [email protected]:<YOUR ACCOUNT>/<YOUR REPOS>.git

	package mojolly.io

	import org.jboss.netty.bootstrap.ClientBootstrap
	import org.jboss.netty.channel._
	import socket.nio.NioClientSocketChannelFactory
	import java.util.concurrent.Executors
	import org.jboss.netty.handler.codec.http._
	import collection.JavaConversions._
	import websocketx._
	import java.net.{InetSocketAddress, URI}

	minikube start --kubernetes-version=v1.7.0 --extra-config=apiserver.Authorization.Mode=RBAC

	kubectl create clusterrolebinding add-on-cluster-admin --clusterrole=cluster-admin --serviceaccount=kube-system:default

	minikube dashboard

	The z in scalaz means this: it was early 2008 and I was working for a Java consultancy and so of course, I used the most appropriate tool for the job: scala. But it had terrible libraries, so I offered to fix those while also meeting my other objectives. Turns out that the Scala guys were extremely hostile to even half-decent libraries (and still are to this day). I still struggle to wrap my head around this sometimes.

	Anyway, so I thought, well fuck it, I will just keep them to myself for now. My (awesome) employer had already agreed that we'd probably open-source such a thing, but I was concerned most about my primary goal. So then it came time to "name" this library. I had named it "scalax" simply so that I did not have the inclination to think of a proper name. Then I found out that such a library was being developed and with my internal name! Whatever, I thought.

	So I looked at this scalax library, hoping that I could just abandon my efforts and jump on board with everyone else -- they too had figure