$ npm install

## In one terminal, start the test consumer:
$ node testConsumer.js
zk ==>"127.0.0.1:2181/"<==
Kafka consumer ready!

## In another terminal, start the test producer and produce a message:
$ node testProducer.js
zk ==>"127.0.0.1:2181/"<==
Kafka producer ready!
results ==>{
  "metric": {
    "0": 0
  }
}<==

## In the terminal running the test consumer, you will see the message:
message ==>{
  "topic": "metric",
  "value": "{\"name\":\"MYSQL_READS\",\"displayName\":\"MySQL Read Operations\",\"description\":\"The number of MySQL read operations per seconds\",\"unit\":\"number\",\"displayNameShort\":\"mysql-reads\",\"d efaultAggregate\":\"AVG\",\"isDisabled\":false,\"isDeleted\":false,\"defaultResolutionMS\":1000,\"type\":\"system\"}","offset": 0,"partition": 0,"highWaterOffset": 1,"key": null
}<==

$ brew cask install caskroom/versions/java8

$ brew install kafka

$ brew services start zookeeper
==> Successfully started `zookeeper` (label: homebrew.mxcl.zookeeper)

$ zkCli -server 127.0.0.1:2181
[zk: 127.0.0.1:2181(CONNECTED) 0] ls /
[zookeeper]
[zk: 127.0.0.1:2181(CONNECTED) 1] quit
Quitting...

$ brew services start kafka
==> Successfully started `kafka` (label: homebrew.mxcl.kafka)

$ kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic metric
Created topic "metric".

$ kafka-topics --list --zookeeper localhost:2181
metric